Lines Matching defs:ceph_connection

184 struct ceph_connection {  struct
187 	const struct ceph_connection_operations *ops;  argument
189 	struct ceph_messenger *msgr;
191 	atomic_t sock_state;
192 	struct socket *sock;
193 	struct ceph_entity_addr peer_addr; /* peer address */
194 	struct ceph_entity_addr peer_addr_for_me;
196 	unsigned long flags;
197 	unsigned long state;
198 	const char *error_msg;  /* error message, if any */
200 	struct ceph_entity_name peer_name; /* peer name */
202 	u64 peer_features;
203 	u32 connect_seq;      /* identify the most recent connection
205 	u32 peer_global_seq;  /* peer's global seq for this connection */
207 	int auth_retry;       /* true if we need a newer authorizer */
208 	void *auth_reply_buf;   /* where to put the authorizer reply */
209 	int auth_reply_buf_len;
211 	struct mutex mutex;
214 	struct list_head out_queue;
215 	struct list_head out_sent;   /* sending or sent but unacked */
216 	u64 out_seq;		     /* last message queued for send */
218 	u64 in_seq, in_seq_acked;  /* last message received, acked */
221 	char in_banner[CEPH_BANNER_MAX_LEN];
222 	struct ceph_msg_connect out_connect;
223 	struct ceph_msg_connect_reply in_reply;
224 	struct ceph_entity_addr actual_peer_addr;
227 	struct ceph_msg_header out_hdr;
228 	struct ceph_msg *out_msg;        /* sending message (== tail of
230 	bool out_msg_done;
232 	struct kvec out_kvec[8],         /* sending header/footer data */
233 		*out_kvec_cur;
234 	int out_kvec_left;   /* kvec's left in out_kvec */
235 	int out_skip;        /* skip this many bytes */
236 	int out_kvec_bytes;  /* total bytes left */
237 	int out_more;        /* there is more data after the kvecs */
238 	__le64 out_temp_ack; /* for writing an ack */
241 	struct ceph_msg_header in_hdr;
242 	struct ceph_msg *in_msg;
243 	u32 in_front_crc, in_middle_crc, in_data_crc;  /* calculated crc */
245 	char in_tag;         /* protocol control byte */
246 	int in_base_pos;     /* bytes read */
247 	__le64 in_temp_ack;  /* for reading an ack */
271 extern void ceph_con_init(struct ceph_connection *con, void *private,  argument