ceph_connection 4598 fs/ceph/mds_client.c static struct ceph_connection *con_get(struct ceph_connection *con) ceph_connection 4610 fs/ceph/mds_client.c static void con_put(struct ceph_connection *con) ceph_connection 4622 fs/ceph/mds_client.c static void peer_reset(struct ceph_connection *con) ceph_connection 4631 fs/ceph/mds_client.c static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) ceph_connection 4689 fs/ceph/mds_client.c static struct ceph_auth_handshake *get_authorizer(struct ceph_connection *con, ceph_connection 4717 fs/ceph/mds_client.c static int add_authorizer_challenge(struct ceph_connection *con, ceph_connection 4728 fs/ceph/mds_client.c static int verify_authorizer_reply(struct ceph_connection *con) ceph_connection 4737 fs/ceph/mds_client.c static int invalidate_authorizer(struct ceph_connection *con) ceph_connection 4748 fs/ceph/mds_client.c static struct ceph_msg *mds_alloc_msg(struct ceph_connection *con, ceph_connection 166 fs/ceph/mds_client.h struct ceph_connection s_con; ceph_connection 18 include/linux/ceph/messenger.h struct ceph_connection; ceph_connection 24 include/linux/ceph/messenger.h struct ceph_connection *(*get)(struct ceph_connection *); ceph_connection 25 include/linux/ceph/messenger.h void (*put)(struct ceph_connection *); ceph_connection 28 include/linux/ceph/messenger.h void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m); ceph_connection 32 include/linux/ceph/messenger.h struct ceph_connection *con, ceph_connection 34 include/linux/ceph/messenger.h int (*add_authorizer_challenge)(struct ceph_connection *con, ceph_connection 37 include/linux/ceph/messenger.h int (*verify_authorizer_reply) (struct ceph_connection *con); ceph_connection 38 include/linux/ceph/messenger.h int (*invalidate_authorizer)(struct ceph_connection *con); ceph_connection 41 include/linux/ceph/messenger.h void (*fault) (struct ceph_connection *con); ceph_connection 45 include/linux/ceph/messenger.h void (*peer_reset) (struct ceph_connection *con); ceph_connection 47 include/linux/ceph/messenger.h struct ceph_msg * (*alloc_msg) (struct ceph_connection *con, ceph_connection 231 include/linux/ceph/messenger.h struct ceph_connection *con; ceph_connection 343 include/linux/ceph/messenger.h extern void ceph_con_init(struct ceph_connection *con, void *private, ceph_connection 346 include/linux/ceph/messenger.h extern void ceph_con_open(struct ceph_connection *con, ceph_connection 349 include/linux/ceph/messenger.h extern bool ceph_con_opened(struct ceph_connection *con); ceph_connection 350 include/linux/ceph/messenger.h extern void ceph_con_close(struct ceph_connection *con); ceph_connection 351 include/linux/ceph/messenger.h extern void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg); ceph_connection 356 include/linux/ceph/messenger.h extern void ceph_con_keepalive(struct ceph_connection *con); ceph_connection 357 include/linux/ceph/messenger.h extern bool ceph_con_keepalive_expired(struct ceph_connection *con, ceph_connection 85 include/linux/ceph/mon_client.h struct ceph_connection con; ceph_connection 38 include/linux/ceph/osd_client.h struct ceph_connection o_con; ceph_connection 119 net/ceph/messenger.c static void con_flag_clear(struct ceph_connection *con, unsigned long con_flag) ceph_connection 126 net/ceph/messenger.c static void con_flag_set(struct ceph_connection *con, unsigned long con_flag) ceph_connection 133 net/ceph/messenger.c static bool con_flag_test(struct ceph_connection *con, unsigned long con_flag) ceph_connection 140 net/ceph/messenger.c static bool con_flag_test_and_clear(struct ceph_connection *con, ceph_connection 148 net/ceph/messenger.c static bool con_flag_test_and_set(struct ceph_connection *con, ceph_connection 170 net/ceph/messenger.c static void queue_con(struct ceph_connection *con); ceph_connection 171 net/ceph/messenger.c static void cancel_con(struct ceph_connection *con); ceph_connection 173 net/ceph/messenger.c static void con_fault(struct ceph_connection *con); ceph_connection 302 net/ceph/messenger.c static void con_sock_state_init(struct ceph_connection *con) ceph_connection 313 net/ceph/messenger.c static void con_sock_state_connecting(struct ceph_connection *con) ceph_connection 324 net/ceph/messenger.c static void con_sock_state_connected(struct ceph_connection *con) ceph_connection 335 net/ceph/messenger.c static void con_sock_state_closing(struct ceph_connection *con) ceph_connection 348 net/ceph/messenger.c static void con_sock_state_closed(struct ceph_connection *con) ceph_connection 369 net/ceph/messenger.c struct ceph_connection *con = sk->sk_user_data; ceph_connection 384 net/ceph/messenger.c struct ceph_connection *con = sk->sk_user_data; ceph_connection 407 net/ceph/messenger.c struct ceph_connection *con = sk->sk_user_data; ceph_connection 436 net/ceph/messenger.c struct ceph_connection *con) ceph_connection 453 net/ceph/messenger.c static int ceph_tcp_connect(struct ceph_connection *con) ceph_connection 600 net/ceph/messenger.c static int con_close_socket(struct ceph_connection *con) ceph_connection 642 net/ceph/messenger.c static void reset_connection(struct ceph_connection *con) ceph_connection 672 net/ceph/messenger.c void ceph_con_close(struct ceph_connection *con) ceph_connection 694 net/ceph/messenger.c void ceph_con_open(struct ceph_connection *con, ceph_connection 717 net/ceph/messenger.c bool ceph_con_opened(struct ceph_connection *con) ceph_connection 725 net/ceph/messenger.c void ceph_con_init(struct ceph_connection *con, void *private, ceph_connection 763 net/ceph/messenger.c static void con_out_kvec_reset(struct ceph_connection *con) ceph_connection 772 net/ceph/messenger.c static void con_out_kvec_add(struct ceph_connection *con, ceph_connection 791 net/ceph/messenger.c static int con_out_kvec_skip(struct ceph_connection *con) ceph_connection 1220 net/ceph/messenger.c static size_t sizeof_footer(struct ceph_connection *con) ceph_connection 1238 net/ceph/messenger.c static void prepare_write_message_footer(struct ceph_connection *con) ceph_connection 1261 net/ceph/messenger.c static void prepare_write_message(struct ceph_connection *con) ceph_connection 1351 net/ceph/messenger.c static void prepare_write_ack(struct ceph_connection *con) ceph_connection 1372 net/ceph/messenger.c static void prepare_write_seq(struct ceph_connection *con) ceph_connection 1390 net/ceph/messenger.c static void prepare_write_keepalive(struct ceph_connection *con) ceph_connection 1412 net/ceph/messenger.c static int get_connect_authorizer(struct ceph_connection *con) ceph_connection 1437 net/ceph/messenger.c static void prepare_write_banner(struct ceph_connection *con) ceph_connection 1447 net/ceph/messenger.c static void __prepare_write_connect(struct ceph_connection *con) ceph_connection 1458 net/ceph/messenger.c static int prepare_write_connect(struct ceph_connection *con) ceph_connection 1503 net/ceph/messenger.c static int write_partial_kvec(struct ceph_connection *con) ceph_connection 1559 net/ceph/messenger.c static int write_partial_message_data(struct ceph_connection *con) ceph_connection 1624 net/ceph/messenger.c static int write_partial_skip(struct ceph_connection *con) ceph_connection 1648 net/ceph/messenger.c static void prepare_read_banner(struct ceph_connection *con) ceph_connection 1654 net/ceph/messenger.c static void prepare_read_connect(struct ceph_connection *con) ceph_connection 1660 net/ceph/messenger.c static void prepare_read_ack(struct ceph_connection *con) ceph_connection 1666 net/ceph/messenger.c static void prepare_read_seq(struct ceph_connection *con) ceph_connection 1673 net/ceph/messenger.c static void prepare_read_tag(struct ceph_connection *con) ceph_connection 1680 net/ceph/messenger.c static void prepare_read_keepalive_ack(struct ceph_connection *con) ceph_connection 1689 net/ceph/messenger.c static int prepare_read_message(struct ceph_connection *con) ceph_connection 1699 net/ceph/messenger.c static int read_partial(struct ceph_connection *con, ceph_connection 1717 net/ceph/messenger.c static int read_partial_banner(struct ceph_connection *con) ceph_connection 1750 net/ceph/messenger.c static int read_partial_connect(struct ceph_connection *con) ceph_connection 1791 net/ceph/messenger.c static int verify_hello(struct ceph_connection *con) ceph_connection 2012 net/ceph/messenger.c static int process_banner(struct ceph_connection *con) ceph_connection 2055 net/ceph/messenger.c static int process_connect(struct ceph_connection *con) ceph_connection 2255 net/ceph/messenger.c static int read_partial_ack(struct ceph_connection *con) ceph_connection 2266 net/ceph/messenger.c static void process_ack(struct ceph_connection *con) ceph_connection 2296 net/ceph/messenger.c static int read_partial_message_section(struct ceph_connection *con, ceph_connection 2319 net/ceph/messenger.c static int read_partial_msg_data(struct ceph_connection *con) ceph_connection 2363 net/ceph/messenger.c static int ceph_con_in_msg_alloc(struct ceph_connection *con, int *skip); ceph_connection 2365 net/ceph/messenger.c static int read_partial_message(struct ceph_connection *con) ceph_connection 2526 net/ceph/messenger.c static void process_message(struct ceph_connection *con) ceph_connection 2553 net/ceph/messenger.c static int read_keepalive_ack(struct ceph_connection *con) ceph_connection 2569 net/ceph/messenger.c static int try_write(struct ceph_connection *con) ceph_connection 2665 net/ceph/messenger.c static int try_read(struct ceph_connection *con) ceph_connection 2816 net/ceph/messenger.c static int queue_con_delay(struct ceph_connection *con, unsigned long delay) ceph_connection 2833 net/ceph/messenger.c static void queue_con(struct ceph_connection *con) ceph_connection 2838 net/ceph/messenger.c static void cancel_con(struct ceph_connection *con) ceph_connection 2846 net/ceph/messenger.c static bool con_sock_closed(struct ceph_connection *con) ceph_connection 2875 net/ceph/messenger.c static bool con_backoff(struct ceph_connection *con) ceph_connection 2895 net/ceph/messenger.c static void con_fault_finish(struct ceph_connection *con) ceph_connection 2919 net/ceph/messenger.c struct ceph_connection *con = container_of(work, struct ceph_connection, ceph_connection 2984 net/ceph/messenger.c static void con_fault(struct ceph_connection *con) ceph_connection 3070 net/ceph/messenger.c static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con) ceph_connection 3079 net/ceph/messenger.c static void clear_standby(struct ceph_connection *con) ceph_connection 3094 net/ceph/messenger.c void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) ceph_connection 3136 net/ceph/messenger.c struct ceph_connection *con = msg->con; ceph_connection 3182 net/ceph/messenger.c struct ceph_connection *con = msg->con; ceph_connection 3217 net/ceph/messenger.c void ceph_con_keepalive(struct ceph_connection *con) ceph_connection 3230 net/ceph/messenger.c bool ceph_con_keepalive_expired(struct ceph_connection *con, ceph_connection 3400 net/ceph/messenger.c static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) ceph_connection 3431 net/ceph/messenger.c static int ceph_con_in_msg_alloc(struct ceph_connection *con, int *skip) ceph_connection 633 net/ceph/mon_client.c static struct ceph_msg *get_generic_reply(struct ceph_connection *con, ceph_connection 1231 net/ceph/mon_client.c static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) ceph_connection 1283 net/ceph/mon_client.c static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con, ceph_connection 1343 net/ceph/mon_client.c static void mon_fault(struct ceph_connection *con) ceph_connection 1366 net/ceph/mon_client.c static struct ceph_connection *con_get(struct ceph_connection *con) ceph_connection 1371 net/ceph/mon_client.c static void con_put(struct ceph_connection *con) ceph_connection 4098 net/ceph/osd_client.c static void osd_fault(struct ceph_connection *con) ceph_connection 5408 net/ceph/osd_client.c static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) ceph_connection 5441 net/ceph/osd_client.c static struct ceph_msg *get_reply(struct ceph_connection *con, ceph_connection 5530 net/ceph/osd_client.c static struct ceph_msg *alloc_msg(struct ceph_connection *con, ceph_connection 5556 net/ceph/osd_client.c static struct ceph_connection *get_osd_con(struct ceph_connection *con) ceph_connection 5564 net/ceph/osd_client.c static void put_osd_con(struct ceph_connection *con) ceph_connection 5577 net/ceph/osd_client.c static struct ceph_auth_handshake *get_authorizer(struct ceph_connection *con, ceph_connection 5605 net/ceph/osd_client.c static int add_authorizer_challenge(struct ceph_connection *con, ceph_connection 5616 net/ceph/osd_client.c static int verify_authorizer_reply(struct ceph_connection *con) ceph_connection 5625 net/ceph/osd_client.c static int invalidate_authorizer(struct ceph_connection *con)