225 static void encode_my_addr(struct ceph_messenger *msgr)  in encode_my_addr()  argument
227 	memcpy(&msgr->my_enc_addr, &msgr->inst.addr, sizeof(msgr->my_enc_addr));  in encode_my_addr()
228 	ceph_encode_addr(&msgr->my_enc_addr);  in encode_my_addr()
394 	if (atomic_read(&con->msgr->stopping)) {  in ceph_sock_data_ready()
511 	if (con->msgr->tcp_nodelay) {  in ceph_tcp_connect()
741 	struct ceph_messenger *msgr)  in ceph_con_init()  argument
747 	con->msgr = msgr;  in ceph_con_init()
765 static u32 get_global_seq(struct ceph_messenger *msgr, u32 gt)  in get_global_seq()  argument
769 	spin_lock(&msgr->global_seq_lock);  in get_global_seq()
770 	if (msgr->global_seq < gt)  in get_global_seq()
771 		msgr->global_seq = gt;  in get_global_seq()
772 	ret = ++msgr->global_seq;  in get_global_seq()
773 	spin_unlock(&msgr->global_seq_lock);  in get_global_seq()
1426 	con_out_kvec_add(con, sizeof (con->msgr->my_enc_addr),  in prepare_write_banner()
1427 					&con->msgr->my_enc_addr);  in prepare_write_banner()
1435 	unsigned int global_seq = get_global_seq(con->msgr, 0);  in prepare_write_connect()
1457 	con->out_connect.features = cpu_to_le64(con->msgr->supported_features);  in prepare_write_connect()
1551 	bool do_datacrc = !con->msgr->nocrc;  in write_partial_message_data()
2007 	if (addr_is_blank(&con->msgr->inst.addr.in_addr)) {  in process_banner()
2008 		int port = addr_port(&con->msgr->inst.addr.in_addr);  in process_banner()
2010 		memcpy(&con->msgr->inst.addr.in_addr,  in process_banner()
2013 		addr_set_port(&con->msgr->inst.addr.in_addr, port);  in process_banner()
2014 		encode_my_addr(con->msgr);  in process_banner()
2016 		     ceph_pr_addr(&con->msgr->inst.addr.in_addr));  in process_banner()
2024 	u64 sup_feat = con->msgr->supported_features;  in process_connect()
2025 	u64 req_feat = con->msgr->required_features;  in process_connect()
2123 		get_global_seq(con->msgr,  in process_connect()
2251 	const bool do_datacrc = !con->msgr->nocrc;  in read_partial_msg_data()
2297 	bool do_datacrc = !con->msgr->nocrc;  in read_partial_message()
2957 void ceph_messenger_init(struct ceph_messenger *msgr,  in ceph_messenger_init()  argument
2964 	msgr->supported_features = supported_features;  in ceph_messenger_init()
2965 	msgr->required_features = required_features;  in ceph_messenger_init()
2967 	spin_lock_init(&msgr->global_seq_lock);  in ceph_messenger_init()
2970 		msgr->inst.addr = *myaddr;  in ceph_messenger_init()
2973 	msgr->inst.addr.type = 0;  in ceph_messenger_init()
2974 	get_random_bytes(&msgr->inst.addr.nonce, sizeof(msgr->inst.addr.nonce));  in ceph_messenger_init()
2975 	encode_my_addr(msgr);  in ceph_messenger_init()
2976 	msgr->nocrc = nocrc;  in ceph_messenger_init()
2977 	msgr->tcp_nodelay = tcp_nodelay;  in ceph_messenger_init()
2979 	atomic_set(&msgr->stopping, 0);  in ceph_messenger_init()
2981 	dout("%s %p\n", __func__, msgr);  in ceph_messenger_init()
3003 	msg->hdr.src = con->msgr->inst.name;  in ceph_con_send()