Lines Matching defs:msgr
222 static void encode_my_addr(struct ceph_messenger *msgr)
224 memcpy(&msgr->my_enc_addr, &msgr->inst.addr, sizeof(msgr->my_enc_addr));
225 ceph_encode_banner_addr(&msgr->my_enc_addr);
277 ceph_msgr_wq = alloc_workqueue("ceph-msgr", WQ_MEM_RECLAIM, 0);
370 if (atomic_read(&con->msgr->stopping)) {
464 ret = sock_create_kern(read_pnet(&con->msgr->net), ss.ss_family,
493 if (ceph_test_opt(from_msgr(con->msgr), TCP_NODELAY))
720 struct ceph_messenger *msgr)
726 con->msgr = msgr;
744 static u32 get_global_seq(struct ceph_messenger *msgr, u32 gt)
748 spin_lock(&msgr->global_seq_lock);
749 if (msgr->global_seq < gt)
750 msgr->global_seq = gt;
751 ret = ++msgr->global_seq;
752 spin_unlock(&msgr->global_seq_lock);
1433 con_out_kvec_add(con, sizeof (con->msgr->my_enc_addr),
1434 &con->msgr->my_enc_addr);
1453 unsigned int global_seq = get_global_seq(con->msgr, 0);
1475 cpu_to_le64(from_msgr(con->msgr)->supported_features);
1556 bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC);
2031 if (addr_is_blank(&con->msgr->inst.addr)) {
2032 int port = addr_port(&con->msgr->inst.addr);
2034 memcpy(&con->msgr->inst.addr.in_addr,
2037 addr_set_port(&con->msgr->inst.addr, port);
2038 encode_my_addr(con->msgr);
2040 ceph_pr_addr(&con->msgr->inst.addr));
2048 u64 sup_feat = from_msgr(con->msgr)->supported_features;
2049 u64 req_feat = from_msgr(con->msgr)->required_features;
2177 get_global_seq(con->msgr,
2314 bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC);
2363 bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC);
3030 void ceph_messenger_reset_nonce(struct ceph_messenger *msgr)
3032 u32 nonce = le32_to_cpu(msgr->inst.addr.nonce) + 1000000;
3033 msgr->inst.addr.nonce = cpu_to_le32(nonce);
3034 encode_my_addr(msgr);
3040 void ceph_messenger_init(struct ceph_messenger *msgr,
3043 spin_lock_init(&msgr->global_seq_lock);
3046 msgr->inst.addr = *myaddr;
3049 msgr->inst.addr.type = 0;
3050 get_random_bytes(&msgr->inst.addr.nonce, sizeof(msgr->inst.addr.nonce));
3051 encode_my_addr(msgr);
3053 atomic_set(&msgr->stopping, 0);
3054 write_pnet(&msgr->net, get_net(current->nsproxy->net_ns));
3056 dout("%s %p\n", __func__, msgr);
3060 void ceph_messenger_fini(struct ceph_messenger *msgr)
3062 put_net(read_pnet(&msgr->net));
3093 msg->hdr.src = con->msgr->inst.name;