Lines Matching refs:ceph_connection
19 struct ceph_connection;
25 struct ceph_connection *(*get)(struct ceph_connection *);
26 void (*put)(struct ceph_connection *);
29 void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
33 struct ceph_connection *con,
35 int (*add_authorizer_challenge)(struct ceph_connection *con,
38 int (*verify_authorizer_reply) (struct ceph_connection *con);
39 int (*invalidate_authorizer)(struct ceph_connection *con);
42 void (*fault) (struct ceph_connection *con);
46 void (*peer_reset) (struct ceph_connection *con);
48 struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
58 int (*get_auth_request)(struct ceph_connection *con,
61 int (*handle_auth_reply_more)(struct ceph_connection *con,
65 int (*handle_auth_done)(struct ceph_connection *con,
69 int (*handle_auth_bad_method)(struct ceph_connection *con,
249 struct ceph_connection *con;
429 struct ceph_connection { struct
475 void ceph_con_flag_clear(struct ceph_connection *con, unsigned long con_flag); argument
476 void ceph_con_flag_set(struct ceph_connection *con, unsigned long con_flag);
477 bool ceph_con_flag_test(struct ceph_connection *con, unsigned long con_flag);
478 bool ceph_con_flag_test_and_clear(struct ceph_connection *con,
480 bool ceph_con_flag_test_and_set(struct ceph_connection *con,
485 int ceph_tcp_connect(struct ceph_connection *con);
486 int ceph_con_close_socket(struct ceph_connection *con);
487 void ceph_con_reset_session(struct ceph_connection *con);
490 void ceph_con_discard_sent(struct ceph_connection *con, u64 ack_seq);
491 void ceph_con_discard_requeued(struct ceph_connection *con, u64 reconnect_seq);
507 void ceph_con_process_message(struct ceph_connection *con);
508 int ceph_con_in_msg_alloc(struct ceph_connection *con,
510 void ceph_con_get_out_msg(struct ceph_connection *con);
513 int ceph_con_v1_try_read(struct ceph_connection *con);
514 int ceph_con_v1_try_write(struct ceph_connection *con);
515 void ceph_con_v1_revoke(struct ceph_connection *con);
516 void ceph_con_v1_revoke_incoming(struct ceph_connection *con);
517 bool ceph_con_v1_opened(struct ceph_connection *con);
518 void ceph_con_v1_reset_session(struct ceph_connection *con);
519 void ceph_con_v1_reset_protocol(struct ceph_connection *con);
522 int ceph_con_v2_try_read(struct ceph_connection *con);
523 int ceph_con_v2_try_write(struct ceph_connection *con);
524 void ceph_con_v2_revoke(struct ceph_connection *con);
525 void ceph_con_v2_revoke_incoming(struct ceph_connection *con);
526 bool ceph_con_v2_opened(struct ceph_connection *con);
527 void ceph_con_v2_reset_session(struct ceph_connection *con);
528 void ceph_con_v2_reset_protocol(struct ceph_connection *con);
546 extern void ceph_con_init(struct ceph_connection *con, void *private,
549 extern void ceph_con_open(struct ceph_connection *con,
552 extern bool ceph_con_opened(struct ceph_connection *con);
553 extern void ceph_con_close(struct ceph_connection *con);
554 extern void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg);
559 extern void ceph_con_keepalive(struct ceph_connection *con);
560 extern bool ceph_con_keepalive_expired(struct ceph_connection *con,