Lines Matching refs:msgr
197 void ceph_encode_my_addr(struct ceph_messenger *msgr) in ceph_encode_my_addr() argument
199 if (!ceph_msgr2(from_msgr(msgr))) { in ceph_encode_my_addr()
200 memcpy(&msgr->my_enc_addr, &msgr->inst.addr, in ceph_encode_my_addr()
201 sizeof(msgr->my_enc_addr)); in ceph_encode_my_addr()
202 ceph_encode_banner_addr(&msgr->my_enc_addr); in ceph_encode_my_addr()
351 if (atomic_read(&con->msgr->stopping)) { in ceph_sock_data_ready()
447 ret = sock_create_kern(read_pnet(&con->msgr->net), ss.ss_family, in ceph_tcp_connect()
475 if (ceph_test_opt(from_msgr(con->msgr), TCP_NODELAY)) in ceph_tcp_connect()
528 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_con_reset_protocol()
566 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_con_reset_session()
622 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_con_opened()
633 struct ceph_messenger *msgr) in ceph_con_init() argument
639 con->msgr = msgr; in ceph_con_init()
656 u32 ceph_get_global_seq(struct ceph_messenger *msgr, u32 gt) in ceph_get_global_seq() argument
660 spin_lock(&msgr->global_seq_lock); in ceph_get_global_seq()
661 if (msgr->global_seq < gt) in ceph_get_global_seq()
662 msgr->global_seq = gt; in ceph_get_global_seq()
663 ret = ++msgr->global_seq; in ceph_get_global_seq()
664 spin_unlock(&msgr->global_seq_lock); in ceph_get_global_seq()
1506 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_con_workfn()
1519 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_con_workfn()
1592 void ceph_messenger_reset_nonce(struct ceph_messenger *msgr) in ceph_messenger_reset_nonce() argument
1594 u32 nonce = le32_to_cpu(msgr->inst.addr.nonce) + 1000000; in ceph_messenger_reset_nonce()
1595 msgr->inst.addr.nonce = cpu_to_le32(nonce); in ceph_messenger_reset_nonce()
1596 ceph_encode_my_addr(msgr); in ceph_messenger_reset_nonce()
1602 void ceph_messenger_init(struct ceph_messenger *msgr, in ceph_messenger_init() argument
1605 spin_lock_init(&msgr->global_seq_lock); in ceph_messenger_init()
1608 memcpy(&msgr->inst.addr.in_addr, &myaddr->in_addr, in ceph_messenger_init()
1609 sizeof(msgr->inst.addr.in_addr)); in ceph_messenger_init()
1610 ceph_addr_set_port(&msgr->inst.addr, 0); in ceph_messenger_init()
1617 msgr->inst.addr.type = CEPH_ENTITY_ADDR_TYPE_ANY; in ceph_messenger_init()
1621 get_random_bytes(&msgr->inst.addr.nonce, in ceph_messenger_init()
1622 sizeof(msgr->inst.addr.nonce)); in ceph_messenger_init()
1623 } while (!msgr->inst.addr.nonce); in ceph_messenger_init()
1624 ceph_encode_my_addr(msgr); in ceph_messenger_init()
1626 atomic_set(&msgr->stopping, 0); in ceph_messenger_init()
1627 write_pnet(&msgr->net, get_net(current->nsproxy->net_ns)); in ceph_messenger_init()
1629 dout("%s %p\n", __func__, msgr); in ceph_messenger_init()
1632 void ceph_messenger_fini(struct ceph_messenger *msgr) in ceph_messenger_fini() argument
1634 put_net(read_pnet(&msgr->net)); in ceph_messenger_fini()
1666 msg->hdr.src = con->msgr->inst.name; in ceph_con_send()
1727 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_msg_revoke()
1756 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_msg_revoke_incoming()