Lines Matching refs:msgr
197 void ceph_encode_my_addr(struct ceph_messenger *msgr)
199 if (!ceph_msgr2(from_msgr(msgr))) {
200 memcpy(&msgr->my_enc_addr, &msgr->inst.addr,
201 sizeof(msgr->my_enc_addr));
202 ceph_encode_banner_addr(&msgr->my_enc_addr);
255 ceph_msgr_wq = alloc_workqueue("ceph-msgr", WQ_MEM_RECLAIM, 0);
351 if (atomic_read(&con->msgr->stopping)) {
447 ret = sock_create_kern(read_pnet(&con->msgr->net), ss.ss_family,
475 if (ceph_test_opt(from_msgr(con->msgr), TCP_NODELAY))
528 if (ceph_msgr2(from_msgr(con->msgr)))
566 if (ceph_msgr2(from_msgr(con->msgr)))
622 if (ceph_msgr2(from_msgr(con->msgr)))
633 struct ceph_messenger *msgr)
639 con->msgr = msgr;
656 u32 ceph_get_global_seq(struct ceph_messenger *msgr, u32 gt)
660 spin_lock(&msgr->global_seq_lock);
661 if (msgr->global_seq < gt)
662 msgr->global_seq = gt;
663 ret = ++msgr->global_seq;
664 spin_unlock(&msgr->global_seq_lock);
1573 if (ceph_msgr2(from_msgr(con->msgr)))
1586 if (ceph_msgr2(from_msgr(con->msgr)))
1659 void ceph_messenger_reset_nonce(struct ceph_messenger *msgr)
1661 u32 nonce = le32_to_cpu(msgr->inst.addr.nonce) + 1000000;
1662 msgr->inst.addr.nonce = cpu_to_le32(nonce);
1663 ceph_encode_my_addr(msgr);
1669 void ceph_messenger_init(struct ceph_messenger *msgr,
1672 spin_lock_init(&msgr->global_seq_lock);
1675 memcpy(&msgr->inst.addr.in_addr, &myaddr->in_addr,
1676 sizeof(msgr->inst.addr.in_addr));
1677 ceph_addr_set_port(&msgr->inst.addr, 0);
1684 msgr->inst.addr.type = CEPH_ENTITY_ADDR_TYPE_ANY;
1688 get_random_bytes(&msgr->inst.addr.nonce,
1689 sizeof(msgr->inst.addr.nonce));
1690 } while (!msgr->inst.addr.nonce);
1691 ceph_encode_my_addr(msgr);
1693 atomic_set(&msgr->stopping, 0);
1694 write_pnet(&msgr->net, get_net(current->nsproxy->net_ns));
1696 dout("%s %p\n", __func__, msgr);
1699 void ceph_messenger_fini(struct ceph_messenger *msgr)
1701 put_net(read_pnet(&msgr->net));
1733 msg->hdr.src = con->msgr->inst.name;
1794 if (ceph_msgr2(from_msgr(con->msgr)))
1823 if (ceph_msgr2(from_msgr(con->msgr)))