Lines Matching defs:ceph_connection

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