193 		struct ceph_msg *msg = monc->m_subscribe;  in __send_subscribe()  local
198 		p = msg->front.iov_base;  in __send_subscribe()
199 		end = p + msg->front_alloc_len;  in __send_subscribe()
229 		msg->front.iov_len = p - msg->front.iov_base;  in __send_subscribe()
230 		msg->hdr.front_len = cpu_to_le32(msg->front.iov_len);  in __send_subscribe()
231 		ceph_msg_revoke(msg);  in __send_subscribe()
232 		ceph_con_send(&monc->con, ceph_msg_get(msg));  in __send_subscribe()
239 				 struct ceph_msg *msg)  in handle_subscribe_ack()  argument
242 	struct ceph_mon_subscribe_ack *h = msg->front.iov_base;  in handle_subscribe_ack()
244 	if (msg->front.iov_len < sizeof(*h))  in handle_subscribe_ack()
262 	ceph_msg_dump(msg);  in handle_subscribe_ack()
356 				 struct ceph_msg *msg)  in ceph_monc_handle_map()  argument
368 	p = msg->front.iov_base;  in ceph_monc_handle_map()
369 	end = p + msg->front.iov_len;  in ceph_monc_handle_map()
547 				struct ceph_msg *msg)  in handle_statfs_reply()  argument
550 	struct ceph_mon_statfs_reply *reply = msg->front.iov_base;  in handle_statfs_reply()
551 	u64 tid = le64_to_cpu(msg->hdr.tid);  in handle_statfs_reply()
553 	if (msg->front.iov_len != sizeof(*reply))  in handle_statfs_reply()
555 	dout("handle_statfs_reply %p tid %llu\n", msg, tid);  in handle_statfs_reply()
573 	ceph_msg_dump(msg);  in handle_statfs_reply()
620 				     struct ceph_msg *msg)  in handle_get_version_reply()  argument
623 	u64 tid = le64_to_cpu(msg->hdr.tid);  in handle_get_version_reply()
624 	void *p = msg->front.iov_base;  in handle_get_version_reply()
625 	void *end = p + msg->front_alloc_len;  in handle_get_version_reply()
628 	dout("%s %p tid %llu\n", __func__, msg, tid);  in handle_get_version_reply()
651 	ceph_msg_dump(msg);  in handle_get_version_reply()
729 				struct ceph_msg *msg)  in handle_poolop_reply()  argument
732 	struct ceph_mon_poolop_reply *reply = msg->front.iov_base;  in handle_poolop_reply()
733 	u64 tid = le64_to_cpu(msg->hdr.tid);  in handle_poolop_reply()
735 	if (msg->front.iov_len < sizeof(*reply))  in handle_poolop_reply()
737 	dout("handle_poolop_reply %p tid %llu\n", msg, tid);  in handle_poolop_reply()
743 		    get_poolop_reply_buf(msg->front.iov_base + sizeof(*reply),  in handle_poolop_reply()
744 				     msg->front.iov_len - sizeof(*reply),  in handle_poolop_reply()
761 	ceph_msg_dump(msg);  in handle_poolop_reply()
1014 			      struct ceph_msg *msg)  in handle_auth_reply()  argument
1024 	ret = ceph_handle_auth_reply(monc->auth, msg->front.iov_base,  in handle_auth_reply()
1025 				     msg->front.iov_len,  in handle_auth_reply()
1090 static void dispatch(struct ceph_connection *con, struct ceph_msg *msg)  in dispatch()  argument
1093 	int type = le16_to_cpu(msg->hdr.type);  in dispatch()
1100 		handle_auth_reply(monc, msg);  in dispatch()
1104 		handle_subscribe_ack(monc, msg);  in dispatch()
1108 		handle_statfs_reply(monc, msg);  in dispatch()
1112 		handle_get_version_reply(monc, msg);  in dispatch()
1116 		handle_poolop_reply(monc, msg);  in dispatch()
1120 		ceph_monc_handle_map(monc, msg);  in dispatch()
1124 		ceph_osdc_handle_map(&monc->client->osdc, msg);  in dispatch()
1130 		    monc->client->extra_mon_dispatch(monc->client, msg) == 0)  in dispatch()
1136 	ceph_msg_put(msg);  in dispatch()