linux/ceph/messenger.h

135 struct ceph_connection {  struct
139 	const struct ceph_connection_operations *ops;  argument
141 	struct ceph_messenger *msgr;
142 	struct socket *sock;
143 	unsigned long state;	/* connection state (see flags above) */
144 	const char *error_msg;  /* error message, if any */
146 	struct ceph_entity_addr peer_addr; /* peer address */
147 	struct ceph_entity_name peer_name; /* peer name */
148 	struct ceph_entity_addr peer_addr_for_me;
149 	unsigned peer_features;
150 	u32 connect_seq;      /* identify the most recent connection
152 	u32 peer_global_seq;  /* peer's global seq for this connection */
154 	int auth_retry;       /* true if we need a newer authorizer */
155 	void *auth_reply_buf;   /* where to put the authorizer reply */
156 	int auth_reply_buf_len;
158 	struct mutex mutex;
161 	struct list_head out_queue;
162 	struct list_head out_sent;   /* sending or sent but unacked */
163 	u64 out_seq;		     /* last message queued for send */
165 	u64 in_seq, in_seq_acked;  /* last message received, acked */
168 	char in_banner[CEPH_BANNER_MAX_LEN];
169 	union {
179 	struct ceph_entity_addr actual_peer_addr;
182 	struct ceph_msg *out_msg;        /* sending message (== tail of
184 	bool out_msg_done;
185 	struct ceph_msg_pos out_msg_pos;
187 	struct kvec out_kvec[8],         /* sending header/footer data */
188 		*out_kvec_cur;
189 	int out_kvec_left;   /* kvec's left in out_kvec */
190 	int out_skip;        /* skip this many bytes */
191 	int out_kvec_bytes;  /* total bytes left */
192 	bool out_kvec_is_msg; /* kvec refers to out_msg */
193 	int out_more;        /* there is more data after the kvecs */
194 	__le64 out_temp_ack; /* for writing an ack */
197 	struct ceph_msg_header in_hdr;
198 	struct ceph_msg *in_msg;
199 	struct ceph_msg_pos in_msg_pos;
200 	u32 in_front_crc, in_middle_crc, in_data_crc;  /* calculated crc */
202 	char in_tag;         /* protocol control byte */
203 	int in_base_pos;     /* bytes read */
227 			  struct ceph_connection *con);  argument