196 void ceph_encode_my_addr(struct ceph_messenger *msgr)  in ceph_encode_my_addr()  argument
198 	if (!ceph_msgr2(from_msgr(msgr))) {  in ceph_encode_my_addr()
199 		memcpy(&msgr->my_enc_addr, &msgr->inst.addr,  in ceph_encode_my_addr()
200 		       sizeof(msgr->my_enc_addr));  in ceph_encode_my_addr()
201 		ceph_encode_banner_addr(&msgr->my_enc_addr);  in ceph_encode_my_addr()
347 	if (atomic_read(&con->msgr->stopping)) {  in ceph_sock_data_ready()
443 	ret = sock_create_kern(read_pnet(&con->msgr->net), ss.ss_family,  in ceph_tcp_connect()
470 	if (ceph_test_opt(from_msgr(con->msgr), TCP_NODELAY))  in ceph_tcp_connect()
519 	if (ceph_msgr2(from_msgr(con->msgr)))  in ceph_con_reset_protocol()
557 	if (ceph_msgr2(from_msgr(con->msgr)))  in ceph_con_reset_session()
613 	if (ceph_msgr2(from_msgr(con->msgr)))  in ceph_con_opened()
624 	struct ceph_messenger *msgr)  in ceph_con_init()  argument
630 	con->msgr = msgr;  in ceph_con_init()
647 u32 ceph_get_global_seq(struct ceph_messenger *msgr, u32 gt)  in ceph_get_global_seq()  argument
651 	spin_lock(&msgr->global_seq_lock);  in ceph_get_global_seq()
652 	if (msgr->global_seq < gt)  in ceph_get_global_seq()
653 		msgr->global_seq = gt;  in ceph_get_global_seq()
654 	ret = ++msgr->global_seq;  in ceph_get_global_seq()
655 	spin_unlock(&msgr->global_seq_lock);  in ceph_get_global_seq()
1526 		if (ceph_msgr2(from_msgr(con->msgr)))  in ceph_con_workfn()
1539 		if (ceph_msgr2(from_msgr(con->msgr)))  in ceph_con_workfn()
1612 void ceph_messenger_reset_nonce(struct ceph_messenger *msgr)  in ceph_messenger_reset_nonce()  argument
1614 	u32 nonce = le32_to_cpu(msgr->inst.addr.nonce) + 1000000;  in ceph_messenger_reset_nonce()
1615 	msgr->inst.addr.nonce = cpu_to_le32(nonce);  in ceph_messenger_reset_nonce()
1616 	ceph_encode_my_addr(msgr);  in ceph_messenger_reset_nonce()
1622 void ceph_messenger_init(struct ceph_messenger *msgr,  in ceph_messenger_init()  argument
1625 	spin_lock_init(&msgr->global_seq_lock);  in ceph_messenger_init()
1628 		memcpy(&msgr->inst.addr.in_addr, &myaddr->in_addr,  in ceph_messenger_init()
1629 		       sizeof(msgr->inst.addr.in_addr));  in ceph_messenger_init()
1630 		ceph_addr_set_port(&msgr->inst.addr, 0);  in ceph_messenger_init()
1637 	msgr->inst.addr.type = CEPH_ENTITY_ADDR_TYPE_ANY;  in ceph_messenger_init()
1641 		get_random_bytes(&msgr->inst.addr.nonce,  in ceph_messenger_init()
1642 				 sizeof(msgr->inst.addr.nonce));  in ceph_messenger_init()
1643 	} while (!msgr->inst.addr.nonce);  in ceph_messenger_init()
1644 	ceph_encode_my_addr(msgr);  in ceph_messenger_init()
1646 	atomic_set(&msgr->stopping, 0);  in ceph_messenger_init()
1647 	write_pnet(&msgr->net, get_net(current->nsproxy->net_ns));  in ceph_messenger_init()
1649 	dout("%s %p\n", __func__, msgr);  in ceph_messenger_init()
1652 void ceph_messenger_fini(struct ceph_messenger *msgr)  in ceph_messenger_fini()  argument
1654 	put_net(read_pnet(&msgr->net));  in ceph_messenger_fini()
1686 	msg->hdr.src = con->msgr->inst.name;  in ceph_con_send()
1747 		if (ceph_msgr2(from_msgr(con->msgr)))  in ceph_msg_revoke()
1776 		if (ceph_msgr2(from_msgr(con->msgr)))  in ceph_msg_revoke_incoming()