Lines Matching defs:ceph_connection
269 struct ceph_connection { struct
272 const struct ceph_connection_operations *ops; argument
274 struct ceph_messenger *msgr;
276 atomic_t sock_state;
277 struct socket *sock;
278 struct ceph_entity_addr peer_addr; /* peer address */
279 struct ceph_entity_addr peer_addr_for_me;
281 unsigned long flags;
282 unsigned long state;
283 const char *error_msg; /* error message, if any */
285 struct ceph_entity_name peer_name; /* peer name */
287 u64 peer_features;
288 u32 connect_seq; /* identify the most recent connection
290 u32 peer_global_seq; /* peer's global seq for this connection */
292 struct ceph_auth_handshake *auth;
293 int auth_retry; /* true if we need a newer authorizer */
295 struct mutex mutex;
298 struct list_head out_queue;
299 struct list_head out_sent; /* sending or sent but unacked */
300 u64 out_seq; /* last message queued for send */
302 u64 in_seq, in_seq_acked; /* last message received, acked */
305 char in_banner[CEPH_BANNER_MAX_LEN];
306 struct ceph_msg_connect out_connect;
307 struct ceph_msg_connect_reply in_reply;
308 struct ceph_entity_addr actual_peer_addr;
311 struct ceph_msg_header out_hdr;
312 struct ceph_msg *out_msg; /* sending message (== tail of
314 bool out_msg_done;
316 struct kvec out_kvec[8], /* sending header/footer data */
317 *out_kvec_cur;
318 int out_kvec_left; /* kvec's left in out_kvec */
319 int out_skip; /* skip this many bytes */
320 int out_kvec_bytes; /* total bytes left */
321 int out_more; /* there is more data after the kvecs */
322 __le64 out_temp_ack; /* for writing an ack */
323 struct ceph_timespec out_temp_keepalive2; /* for writing keepalive2
327 struct ceph_msg_header in_hdr;
328 struct ceph_msg *in_msg;
329 u32 in_front_crc, in_middle_crc, in_data_crc; /* calculated crc */
331 char in_tag; /* protocol control byte */
332 int in_base_pos; /* bytes read */
356 extern void ceph_con_init(struct ceph_connection *con, void *private, argument