Searched refs:ceph_connection (Results 1 – 10 of 10) sorted by relevance
/Linux-v6.1/include/linux/ceph/ |
D | messenger.h | 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); [all …]
|
D | mon_client.h | 85 struct ceph_connection con;
|
D | osd_client.h | 39 struct ceph_connection o_con;
|
/Linux-v6.1/net/ceph/ |
D | messenger_v2.c | 107 static int ceph_tcp_recv(struct ceph_connection *con) in ceph_tcp_recv() 195 static int ceph_tcp_send(struct ceph_connection *con) in ceph_tcp_send() 210 static void add_in_kvec(struct ceph_connection *con, void *buf, int len) in add_in_kvec() 223 static void reset_in_kvecs(struct ceph_connection *con) in reset_in_kvecs() 231 static void set_in_bvec(struct ceph_connection *con, const struct bio_vec *bv) in set_in_bvec() 239 static void set_in_skip(struct ceph_connection *con, int len) in set_in_skip() 247 static void add_out_kvec(struct ceph_connection *con, void *buf, int len) in add_out_kvec() 261 static void reset_out_kvecs(struct ceph_connection *con) in reset_out_kvecs() 272 static void set_out_bvec(struct ceph_connection *con, const struct bio_vec *bv, in set_out_bvec() 284 static void set_out_bvec_zero(struct ceph_connection *con) in set_out_bvec_zero() [all …]
|
D | messenger_v1.c | 111 static void con_out_kvec_reset(struct ceph_connection *con) in con_out_kvec_reset() 120 static void con_out_kvec_add(struct ceph_connection *con, in con_out_kvec_add() 139 static int con_out_kvec_skip(struct ceph_connection *con) in con_out_kvec_skip() 154 static size_t sizeof_footer(struct ceph_connection *con) in sizeof_footer() 172 static void prepare_write_message_footer(struct ceph_connection *con) in prepare_write_message_footer() 195 static void prepare_write_message(struct ceph_connection *con) in prepare_write_message() 267 static void prepare_write_ack(struct ceph_connection *con) in prepare_write_ack() 288 static void prepare_write_seq(struct ceph_connection *con) in prepare_write_seq() 306 static void prepare_write_keepalive(struct ceph_connection *con) in prepare_write_keepalive() 328 static int get_connect_authorizer(struct ceph_connection *con) in get_connect_authorizer() [all …]
|
D | messenger.c | 99 void ceph_con_flag_clear(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_clear() 106 void ceph_con_flag_set(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_set() 113 bool ceph_con_flag_test(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_test() 120 bool ceph_con_flag_test_and_clear(struct ceph_connection *con, in ceph_con_flag_test_and_clear() 128 bool ceph_con_flag_test_and_set(struct ceph_connection *con, in ceph_con_flag_test_and_set() 144 static void queue_con(struct ceph_connection *con); 145 static void cancel_con(struct ceph_connection *con); 147 static void con_fault(struct ceph_connection *con); 279 static void con_sock_state_init(struct ceph_connection *con) in con_sock_state_init() 290 static void con_sock_state_connecting(struct ceph_connection *con) in con_sock_state_connecting() [all …]
|
D | mon_client.c | 706 static struct ceph_msg *get_generic_reply(struct ceph_connection *con, in get_generic_reply() 1350 static int mon_get_auth_request(struct ceph_connection *con, in mon_get_auth_request() 1369 static int mon_handle_auth_reply_more(struct ceph_connection *con, in mon_handle_auth_reply_more() 1390 static int mon_handle_auth_done(struct ceph_connection *con, in mon_handle_auth_done() 1413 static int mon_handle_auth_bad_method(struct ceph_connection *con, in mon_handle_auth_bad_method() 1435 static void mon_dispatch(struct ceph_connection *con, struct ceph_msg *msg) in mon_dispatch() 1484 static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con, in mon_alloc_msg() 1544 static void mon_fault(struct ceph_connection *con) in mon_fault() 1567 static struct ceph_connection *mon_get_con(struct ceph_connection *con) in mon_get_con() 1572 static void mon_put_con(struct ceph_connection *con) in mon_put_con()
|
D | osd_client.c | 4203 static void osd_fault(struct ceph_connection *con) in osd_fault() 5315 static void osd_dispatch(struct ceph_connection *con, struct ceph_msg *msg) in osd_dispatch() 5348 static struct ceph_msg *get_reply(struct ceph_connection *con, in get_reply() 5437 static struct ceph_msg *osd_alloc_msg(struct ceph_connection *con, in osd_alloc_msg() 5463 static struct ceph_connection *osd_get_con(struct ceph_connection *con) in osd_get_con() 5471 static void osd_put_con(struct ceph_connection *con) in osd_put_con() 5486 osd_get_authorizer(struct ceph_connection *con, int *proto, int force_new) in osd_get_authorizer() 5502 static int osd_add_authorizer_challenge(struct ceph_connection *con, in osd_add_authorizer_challenge() 5513 static int osd_verify_authorizer_reply(struct ceph_connection *con) in osd_verify_authorizer_reply() 5525 static int osd_invalidate_authorizer(struct ceph_connection *con) in osd_invalidate_authorizer() [all …]
|
/Linux-v6.1/fs/ceph/ |
D | mds_client.c | 5278 static struct ceph_connection *mds_get_con(struct ceph_connection *con) in mds_get_con() 5287 static void mds_put_con(struct ceph_connection *con) in mds_put_con() 5298 static void mds_peer_reset(struct ceph_connection *con) in mds_peer_reset() 5307 static void mds_dispatch(struct ceph_connection *con, struct ceph_msg *msg) in mds_dispatch() 5366 mds_get_authorizer(struct ceph_connection *con, int *proto, int force_new) in mds_get_authorizer() 5382 static int mds_add_authorizer_challenge(struct ceph_connection *con, in mds_add_authorizer_challenge() 5393 static int mds_verify_authorizer_reply(struct ceph_connection *con) in mds_verify_authorizer_reply() 5405 static int mds_invalidate_authorizer(struct ceph_connection *con) in mds_invalidate_authorizer() 5416 static int mds_get_auth_request(struct ceph_connection *con, in mds_get_auth_request() 5435 static int mds_handle_auth_reply_more(struct ceph_connection *con, in mds_handle_auth_reply_more() [all …]
|
D | mds_client.h | 189 struct ceph_connection s_con;
|