linux/ceph/messenger.h

254 struct ceph_connection {  struct
257 	const struct ceph_connection_operations *ops;  argument
259 	struct ceph_messenger *msgr;
261 	atomic_t sock_state;
262 	struct socket *sock;
263 	struct ceph_entity_addr peer_addr; /* peer address */
264 	struct ceph_entity_addr peer_addr_for_me;
266 	unsigned long flags;
267 	unsigned long state;
268 	const char *error_msg;  /* error message, if any */
270 	struct ceph_entity_name peer_name; /* peer name */
272 	u64 peer_features;
273 	u32 connect_seq;      /* identify the most recent connection
275 	u32 peer_global_seq;  /* peer's global seq for this connection */
277 	struct ceph_auth_handshake *auth;
278 	int auth_retry;       /* true if we need a newer authorizer */
280 	struct mutex mutex;
283 	struct list_head out_queue;
284 	struct list_head out_sent;   /* sending or sent but unacked */
285 	u64 out_seq;		     /* last message queued for send */
287 	u64 in_seq, in_seq_acked;  /* last message received, acked */
290 	char in_banner[CEPH_BANNER_MAX_LEN];
291 	struct ceph_msg_connect out_connect;
292 	struct ceph_msg_connect_reply in_reply;
293 	struct ceph_entity_addr actual_peer_addr;
296 	struct ceph_msg_header out_hdr;
297 	struct ceph_msg *out_msg;        /* sending message (== tail of
299 	bool out_msg_done;
301 	struct kvec out_kvec[8],         /* sending header/footer data */
302 		*out_kvec_cur;
303 	int out_kvec_left;   /* kvec's left in out_kvec */
304 	int out_skip;        /* skip this many bytes */
305 	int out_kvec_bytes;  /* total bytes left */
306 	int out_more;        /* there is more data after the kvecs */
307 	__le64 out_temp_ack; /* for writing an ack */
308 	struct ceph_timespec out_temp_keepalive2; /* for writing keepalive2
312 	struct ceph_msg_header in_hdr;
313 	struct ceph_msg *in_msg;
314 	u32 in_front_crc, in_middle_crc, in_data_crc;  /* calculated crc */
316 	char in_tag;         /* protocol control byte */
317 	int in_base_pos;     /* bytes read */
318 	__le64 in_temp_ack;  /* for reading an ack */
343 extern void ceph_con_init(struct ceph_connection *con, void *private,  argument