linux/ceph/messenger.h

30 	void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
34 				struct ceph_connection *con,
36 	int (*add_authorizer_challenge)(struct ceph_connection *con,
39 	int (*verify_authorizer_reply) (struct ceph_connection *con);
40 	int (*invalidate_authorizer)(struct ceph_connection *con);
43 	void (*fault) (struct ceph_connection *con);
47 	void (*peer_reset) (struct ceph_connection *con);
49 	struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
59 	int (*get_auth_request)(struct ceph_connection *con,
62 	int (*handle_auth_reply_more)(struct ceph_connection *con,
66 	int (*handle_auth_done)(struct ceph_connection *con,
70 	int (*handle_auth_bad_method)(struct ceph_connection *con,
77 	 * @con: connection we're reading from
94 	int (*sparse_read)(struct ceph_connection *con,
280 	struct ceph_connection *con;
517 void ceph_con_flag_clear(struct ceph_connection *con, unsigned long con_flag);
518 void ceph_con_flag_set(struct ceph_connection *con, unsigned long con_flag);
519 bool ceph_con_flag_test(struct ceph_connection *con, unsigned long con_flag);
520 bool ceph_con_flag_test_and_clear(struct ceph_connection *con,
522 bool ceph_con_flag_test_and_set(struct ceph_connection *con,
527 int ceph_tcp_connect(struct ceph_connection *con);
528 int ceph_con_close_socket(struct ceph_connection *con);
529 void ceph_con_reset_session(struct ceph_connection *con);
532 void ceph_con_discard_sent(struct ceph_connection *con, u64 ack_seq);
533 void ceph_con_discard_requeued(struct ceph_connection *con, u64 reconnect_seq);
548 void ceph_con_process_message(struct ceph_connection *con);
549 int ceph_con_in_msg_alloc(struct ceph_connection *con,
551 void ceph_con_get_out_msg(struct ceph_connection *con);
554 int ceph_con_v1_try_read(struct ceph_connection *con);
555 int ceph_con_v1_try_write(struct ceph_connection *con);
556 void ceph_con_v1_revoke(struct ceph_connection *con);
557 void ceph_con_v1_revoke_incoming(struct ceph_connection *con);
558 bool ceph_con_v1_opened(struct ceph_connection *con);
559 void ceph_con_v1_reset_session(struct ceph_connection *con);
560 void ceph_con_v1_reset_protocol(struct ceph_connection *con);
563 int ceph_con_v2_try_read(struct ceph_connection *con);
564 int ceph_con_v2_try_write(struct ceph_connection *con);
565 void ceph_con_v2_revoke(struct ceph_connection *con);
566 void ceph_con_v2_revoke_incoming(struct ceph_connection *con);
567 bool ceph_con_v2_opened(struct ceph_connection *con);
568 void ceph_con_v2_reset_session(struct ceph_connection *con);
569 void ceph_con_v2_reset_protocol(struct ceph_connection *con);
587 extern void ceph_con_init(struct ceph_connection *con, void *private,
590 extern void ceph_con_open(struct ceph_connection *con,
593 extern bool ceph_con_opened(struct ceph_connection *con);
594 extern void ceph_con_close(struct ceph_connection *con);
595 extern void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg);
600 extern void ceph_con_keepalive(struct ceph_connection *con);
601 extern bool ceph_con_keepalive_expired(struct ceph_connection *con,