222 static void encode_my_addr(struct ceph_messenger *msgr)  in encode_my_addr()  argument
224 	memcpy(&msgr->my_enc_addr, &msgr->inst.addr, sizeof(msgr->my_enc_addr));  in encode_my_addr()
225 	ceph_encode_banner_addr(&msgr->my_enc_addr);  in encode_my_addr()
370 	if (atomic_read(&con->msgr->stopping)) {  in ceph_sock_data_ready()
464 	ret = sock_create_kern(read_pnet(&con->msgr->net), ss.ss_family,  in ceph_tcp_connect()
493 	if (ceph_test_opt(from_msgr(con->msgr), TCP_NODELAY)) {  in ceph_tcp_connect()
727 	struct ceph_messenger *msgr)  in ceph_con_init()  argument
733 	con->msgr = msgr;  in ceph_con_init()
751 static u32 get_global_seq(struct ceph_messenger *msgr, u32 gt)  in get_global_seq()  argument
755 	spin_lock(&msgr->global_seq_lock);  in get_global_seq()
756 	if (msgr->global_seq < gt)  in get_global_seq()
757 		msgr->global_seq = gt;  in get_global_seq()
758 	ret = ++msgr->global_seq;  in get_global_seq()
759 	spin_unlock(&msgr->global_seq_lock);  in get_global_seq()
1440 	con_out_kvec_add(con, sizeof (con->msgr->my_enc_addr),  in prepare_write_banner()
1441 					&con->msgr->my_enc_addr);  in prepare_write_banner()
1460 	unsigned int global_seq = get_global_seq(con->msgr, 0);  in prepare_write_connect()
1482 	    cpu_to_le64(from_msgr(con->msgr)->supported_features);  in prepare_write_connect()
1563 	bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC);  in write_partial_message_data()
2040 	if (addr_is_blank(&con->msgr->inst.addr)) {  in process_banner()
2041 		int port = addr_port(&con->msgr->inst.addr);  in process_banner()
2043 		memcpy(&con->msgr->inst.addr.in_addr,  in process_banner()
2046 		addr_set_port(&con->msgr->inst.addr, port);  in process_banner()
2047 		encode_my_addr(con->msgr);  in process_banner()
2049 		     ceph_pr_addr(&con->msgr->inst.addr));  in process_banner()
2057 	u64 sup_feat = from_msgr(con->msgr)->supported_features;  in process_connect()
2058 	u64 req_feat = from_msgr(con->msgr)->required_features;  in process_connect()
2186 		get_global_seq(con->msgr,  in process_connect()
2323 	bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC);  in read_partial_msg_data()
2372 	bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC);  in read_partial_message()
3034 void ceph_messenger_reset_nonce(struct ceph_messenger *msgr)  in ceph_messenger_reset_nonce()  argument
3036 	u32 nonce = le32_to_cpu(msgr->inst.addr.nonce) + 1000000;  in ceph_messenger_reset_nonce()
3037 	msgr->inst.addr.nonce = cpu_to_le32(nonce);  in ceph_messenger_reset_nonce()
3038 	encode_my_addr(msgr);  in ceph_messenger_reset_nonce()
3044 void ceph_messenger_init(struct ceph_messenger *msgr,  in ceph_messenger_init()  argument
3047 	spin_lock_init(&msgr->global_seq_lock);  in ceph_messenger_init()
3050 		msgr->inst.addr = *myaddr;  in ceph_messenger_init()
3053 	msgr->inst.addr.type = 0;  in ceph_messenger_init()
3054 	get_random_bytes(&msgr->inst.addr.nonce, sizeof(msgr->inst.addr.nonce));  in ceph_messenger_init()
3055 	encode_my_addr(msgr);  in ceph_messenger_init()
3057 	atomic_set(&msgr->stopping, 0);  in ceph_messenger_init()
3058 	write_pnet(&msgr->net, get_net(current->nsproxy->net_ns));  in ceph_messenger_init()
3060 	dout("%s %p\n", __func__, msgr);  in ceph_messenger_init()
3064 void ceph_messenger_fini(struct ceph_messenger *msgr)  in ceph_messenger_fini()  argument
3066 	put_net(read_pnet(&msgr->net));  in ceph_messenger_fini()
3097 	msg->hdr.src = con->msgr->inst.name;  in ceph_con_send()