Searched refs:ceph_connection (Results 1 – 10 of 10) sorted by relevance
/linux/include/linux/ceph/ |
H A D | messenger.h | 19 struct ceph_connection; 26 struct ceph_connection *(*get)(struct ceph_connection *); 27 void (*put)(struct ceph_connection *); 34 struct ceph_connection *con, 43 void (*fault) (struct ceph_connection *con); 47 void (*peer_reset) (struct ceph_connection *con); 59 int (*get_auth_request)(struct ceph_connection *con, 66 int (*handle_auth_done)(struct ceph_connection *con, 94 int (*sparse_read)(struct ceph_connection *con, 280 struct ceph_connection *con; [all …]
|
H A D | mon_client.h | 85 struct ceph_connection con;
|
H A D | osd_client.h | 87 struct ceph_connection o_con;
|
/linux/net/ceph/ |
H A D | messenger_v1.c | 110 static void con_out_kvec_reset(struct ceph_connection *con) in con_out_kvec_reset() 119 static void con_out_kvec_add(struct ceph_connection *con, in con_out_kvec_add() 138 static int con_out_kvec_skip(struct ceph_connection *con) in con_out_kvec_skip() 153 static size_t sizeof_footer(struct ceph_connection *con) in sizeof_footer() 599 static int read_partial(struct ceph_connection *con, in read_partial() 690 static int verify_hello(struct ceph_connection *con) in verify_hello() 701 static int process_banner(struct ceph_connection *con) in process_banner() 952 static void process_ack(struct ceph_connection *con) in process_ack() 1326 int ceph_con_v1_try_read(struct ceph_connection *con) in ceph_con_v1_try_read() 1567 void ceph_con_v1_revoke(struct ceph_connection *con) in ceph_con_v1_revoke() [all …]
|
H A D | messenger_v2.c | 109 static int ceph_tcp_recv(struct ceph_connection *con) in ceph_tcp_recv() 196 static int ceph_tcp_send(struct ceph_connection *con) in ceph_tcp_send() 224 static void reset_in_kvecs(struct ceph_connection *con) in reset_in_kvecs() 262 static void reset_out_kvecs(struct ceph_connection *con) in reset_out_kvecs() 320 static void free_conn_bufs(struct ceph_connection *con) in free_conn_bufs() 354 static bool con_secure(struct ceph_connection *con) in con_secure() 703 static int setup_crypto(struct ceph_connection *con, in setup_crypto() 1126 static int decrypt_tail(struct ceph_connection *con) in decrypt_tail() 1365 static int prepare_hello(struct ceph_connection *con) in prepare_hello() 1577 static int prepare_ack(struct ceph_connection *con) in prepare_ack() [all …]
|
H A D | messenger.c | 145 static void queue_con(struct ceph_connection *con); 347 struct ceph_connection *con = sk->sk_user_data; in ceph_sock_data_ready() 365 struct ceph_connection *con = sk->sk_user_data; in ceph_sock_write_space() 388 struct ceph_connection *con = sk->sk_user_data; in ceph_sock_state_change() 417 struct ceph_connection *con) in set_sock_callbacks() 434 int ceph_tcp_connect(struct ceph_connection *con) in ceph_tcp_connect() 575 void ceph_con_close(struct ceph_connection *con) in ceph_con_close() 597 void ceph_con_open(struct ceph_connection *con, in ceph_con_open() 1543 struct ceph_connection *con = container_of(work, struct ceph_connection, in ceph_con_workfn() 1772 struct ceph_connection *con = msg->con; in ceph_msg_revoke() [all …]
|
H A 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()
|
H A D | osd_client.c | 4294 static void osd_fault(struct ceph_connection *con) in osd_fault() 5458 static struct ceph_msg *get_reply(struct ceph_connection *con, in get_reply() 5551 static struct ceph_msg *osd_alloc_msg(struct ceph_connection *con, in osd_alloc_msg() 5577 static struct ceph_connection *osd_get_con(struct ceph_connection *con) in osd_get_con() 5585 static void osd_put_con(struct ceph_connection *con) in osd_put_con() 5639 static int osd_invalidate_authorizer(struct ceph_connection *con) in osd_invalidate_authorizer() 5649 static int osd_get_auth_request(struct ceph_connection *con, in osd_get_auth_request() 5668 static int osd_handle_auth_reply_more(struct ceph_connection *con, in osd_handle_auth_reply_more() 5688 static int osd_handle_auth_done(struct ceph_connection *con, in osd_handle_auth_done() 5764 static int prep_next_sparse_read(struct ceph_connection *con, in prep_next_sparse_read() [all …]
|
/linux/fs/ceph/ |
H A D | mds_client.c | 6174 static struct ceph_connection *mds_get_con(struct ceph_connection *con) in mds_get_con() 6183 static void mds_put_con(struct ceph_connection *con) in mds_put_con() 6194 static void mds_peer_reset(struct ceph_connection *con) in mds_peer_reset() 6282 static int mds_add_authorizer_challenge(struct ceph_connection *con, in mds_add_authorizer_challenge() 6293 static int mds_verify_authorizer_reply(struct ceph_connection *con) in mds_verify_authorizer_reply() 6305 static int mds_invalidate_authorizer(struct ceph_connection *con) in mds_invalidate_authorizer() 6316 static int mds_get_auth_request(struct ceph_connection *con, in mds_get_auth_request() 6335 static int mds_handle_auth_reply_more(struct ceph_connection *con, in mds_handle_auth_reply_more() 6355 static int mds_handle_auth_done(struct ceph_connection *con, in mds_handle_auth_done() 6369 static int mds_handle_auth_bad_method(struct ceph_connection *con, in mds_handle_auth_bad_method() [all …]
|
H A D | mds_client.h | 223 struct ceph_connection s_con;
|