Searched refs:ceph_connection (Results 1 – 10 of 10) sorted by relevance
| /linux/include/linux/ceph/ |
| A D | messenger.h | 19 struct ceph_connection;
25 struct ceph_connection *(*get)(struct ceph_connection *);
26 void (*put)(struct ceph_connection *);
33 struct ceph_connection *con,
42 void (*fault) (struct ceph_connection *con);
46 void (*peer_reset) (struct ceph_connection *con);
58 int (*get_auth_request)(struct ceph_connection *con,
65 int (*handle_auth_done)(struct ceph_connection *con,
249 struct ceph_connection *con;
429 struct ceph_connection { struct
[all …]
|
| A D | mon_client.h | 85 struct ceph_connection con;
|
| A D | osd_client.h | 39 struct ceph_connection o_con;
|
| /linux/net/ceph/ |
| A D | messenger_v2.c | 106 static int ceph_tcp_recv(struct ceph_connection *con) in ceph_tcp_recv()
194 static int ceph_tcp_send(struct ceph_connection *con) in ceph_tcp_send()
222 static void reset_in_kvecs(struct ceph_connection *con) in reset_in_kvecs()
319 static void free_conn_bufs(struct ceph_connection *con) in free_conn_bufs()
353 static bool con_secure(struct ceph_connection *con) in con_secure()
691 static int setup_crypto(struct ceph_connection *con, in setup_crypto()
1241 static int prepare_hello(struct ceph_connection *con) in prepare_hello()
1453 static int prepare_ack(struct ceph_connection *con) in prepare_ack()
2752 static void finish_skip(struct ceph_connection *con) in finish_skip()
2854 static void queue_data(struct ceph_connection *con) in queue_data()
[all …]
|
| A D | messenger_v1.c | 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()
605 static int read_partial(struct ceph_connection *con, in read_partial()
696 static int verify_hello(struct ceph_connection *con) in verify_hello()
707 static int process_banner(struct ceph_connection *con) in process_banner()
958 static void process_ack(struct ceph_connection *con) in process_ack()
1208 int ceph_con_v1_try_read(struct ceph_connection *con) in ceph_con_v1_try_read()
1355 int ceph_con_v1_try_write(struct ceph_connection *con) in ceph_con_v1_try_write()
1449 void ceph_con_v1_revoke(struct ceph_connection *con) in ceph_con_v1_revoke()
[all …]
|
| A D | messenger.c | 144 static void queue_con(struct ceph_connection *con);
346 struct ceph_connection *con = sk->sk_user_data; in ceph_sock_data_ready()
361 struct ceph_connection *con = sk->sk_user_data; in ceph_sock_write_space()
384 struct ceph_connection *con = sk->sk_user_data; in ceph_sock_state_change()
413 struct ceph_connection *con) in set_sock_callbacks()
430 int ceph_tcp_connect(struct ceph_connection *con) in ceph_tcp_connect()
566 void ceph_con_close(struct ceph_connection *con) in ceph_con_close()
588 void ceph_con_open(struct ceph_connection *con, in ceph_con_open()
1496 struct ceph_connection *con = container_of(work, struct ceph_connection, in ceph_con_workfn()
1725 struct ceph_connection *con = msg->con; in ceph_msg_revoke()
[all …]
|
| 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()
|
| A D | osd_client.c | 4178 static void osd_fault(struct ceph_connection *con) in osd_fault()
5406 static struct ceph_msg *get_reply(struct ceph_connection *con, in get_reply()
5495 static struct ceph_msg *osd_alloc_msg(struct ceph_connection *con, in osd_alloc_msg()
5521 static struct ceph_connection *osd_get_con(struct ceph_connection *con) in osd_get_con()
5529 static void osd_put_con(struct ceph_connection *con) in osd_put_con()
5571 static int osd_verify_authorizer_reply(struct ceph_connection *con) in osd_verify_authorizer_reply()
5583 static int osd_invalidate_authorizer(struct ceph_connection *con) in osd_invalidate_authorizer()
5593 static int osd_get_auth_request(struct ceph_connection *con, in osd_get_auth_request()
5612 static int osd_handle_auth_reply_more(struct ceph_connection *con, in osd_handle_auth_reply_more()
5632 static int osd_handle_auth_done(struct ceph_connection *con, in osd_handle_auth_done()
[all …]
|
| /linux/fs/ceph/ |
| A D | mds_client.c | 5058 static struct ceph_connection *mds_get_con(struct ceph_connection *con) in mds_get_con()
5067 static void mds_put_con(struct ceph_connection *con) in mds_put_con()
5078 static void mds_peer_reset(struct ceph_connection *con) in mds_peer_reset()
5162 static int mds_add_authorizer_challenge(struct ceph_connection *con, in mds_add_authorizer_challenge()
5173 static int mds_verify_authorizer_reply(struct ceph_connection *con) in mds_verify_authorizer_reply()
5185 static int mds_invalidate_authorizer(struct ceph_connection *con) in mds_invalidate_authorizer()
5196 static int mds_get_auth_request(struct ceph_connection *con, in mds_get_auth_request()
5215 static int mds_handle_auth_reply_more(struct ceph_connection *con, in mds_handle_auth_reply_more()
5235 static int mds_handle_auth_done(struct ceph_connection *con, in mds_handle_auth_done()
5249 static int mds_handle_auth_bad_method(struct ceph_connection *con, in mds_handle_auth_bad_method()
[all …]
|
| A D | mds_client.h | 185 struct ceph_connection s_con;
|
Completed in 51 milliseconds