Lines Matching refs:ceph_connection
119 static void con_flag_clear(struct ceph_connection *con, unsigned long con_flag) in con_flag_clear()
126 static void con_flag_set(struct ceph_connection *con, unsigned long con_flag) in con_flag_set()
133 static bool con_flag_test(struct ceph_connection *con, unsigned long con_flag) in con_flag_test()
140 static bool con_flag_test_and_clear(struct ceph_connection *con, in con_flag_test_and_clear()
148 static bool con_flag_test_and_set(struct ceph_connection *con, in con_flag_test_and_set()
171 static void queue_con(struct ceph_connection *con);
172 static void cancel_con(struct ceph_connection *con);
174 static void con_fault(struct ceph_connection *con);
312 static void con_sock_state_init(struct ceph_connection *con) in con_sock_state_init()
323 static void con_sock_state_connecting(struct ceph_connection *con) in con_sock_state_connecting()
334 static void con_sock_state_connected(struct ceph_connection *con) in con_sock_state_connected()
345 static void con_sock_state_closing(struct ceph_connection *con) in con_sock_state_closing()
358 static void con_sock_state_closed(struct ceph_connection *con) in con_sock_state_closed()
379 struct ceph_connection *con = sk->sk_user_data; in ceph_sock_data_ready()
394 struct ceph_connection *con = sk->sk_user_data; in ceph_sock_write_space()
417 struct ceph_connection *con = sk->sk_user_data; in ceph_sock_state_change()
446 struct ceph_connection *con) in set_sock_callbacks()
463 static int ceph_tcp_connect(struct ceph_connection *con) in ceph_tcp_connect()
621 static int con_close_socket(struct ceph_connection *con) in con_close_socket()
663 static void reset_connection(struct ceph_connection *con) in reset_connection()
693 void ceph_con_close(struct ceph_connection *con) in ceph_con_close()
716 void ceph_con_open(struct ceph_connection *con, in ceph_con_open()
739 bool ceph_con_opened(struct ceph_connection *con) in ceph_con_opened()
747 void ceph_con_init(struct ceph_connection *con, void *private, in ceph_con_init()
785 static void con_out_kvec_reset(struct ceph_connection *con) in con_out_kvec_reset()
794 static void con_out_kvec_add(struct ceph_connection *con, in con_out_kvec_add()
813 static int con_out_kvec_skip(struct ceph_connection *con) in con_out_kvec_skip()
1242 static size_t sizeof_footer(struct ceph_connection *con) in sizeof_footer()
1263 static void prepare_write_message_footer(struct ceph_connection *con) in prepare_write_message_footer()
1286 static void prepare_write_message(struct ceph_connection *con) in prepare_write_message()
1376 static void prepare_write_ack(struct ceph_connection *con) in prepare_write_ack()
1397 static void prepare_write_seq(struct ceph_connection *con) in prepare_write_seq()
1415 static void prepare_write_keepalive(struct ceph_connection *con) in prepare_write_keepalive()
1437 static int get_connect_authorizer(struct ceph_connection *con) in get_connect_authorizer()
1462 static void prepare_write_banner(struct ceph_connection *con) in prepare_write_banner()
1472 static void __prepare_write_connect(struct ceph_connection *con) in __prepare_write_connect()
1483 static int prepare_write_connect(struct ceph_connection *con) in prepare_write_connect()
1528 static int write_partial_kvec(struct ceph_connection *con) in write_partial_kvec()
1584 static int write_partial_message_data(struct ceph_connection *con) in write_partial_message_data()
1648 static int write_partial_skip(struct ceph_connection *con) in write_partial_skip()
1669 static void prepare_read_banner(struct ceph_connection *con) in prepare_read_banner()
1675 static void prepare_read_connect(struct ceph_connection *con) in prepare_read_connect()
1681 static void prepare_read_ack(struct ceph_connection *con) in prepare_read_ack()
1687 static void prepare_read_seq(struct ceph_connection *con) in prepare_read_seq()
1694 static void prepare_read_tag(struct ceph_connection *con) in prepare_read_tag()
1701 static void prepare_read_keepalive_ack(struct ceph_connection *con) in prepare_read_keepalive_ack()
1710 static int prepare_read_message(struct ceph_connection *con) in prepare_read_message()
1720 static int read_partial(struct ceph_connection *con, in read_partial()
1738 static int read_partial_banner(struct ceph_connection *con) in read_partial_banner()
1769 static int read_partial_connect(struct ceph_connection *con) in read_partial_connect()
1810 static int verify_hello(struct ceph_connection *con) in verify_hello()
2032 static int process_banner(struct ceph_connection *con) in process_banner()
2078 static int process_connect(struct ceph_connection *con) in process_connect()
2275 static int read_partial_ack(struct ceph_connection *con) in read_partial_ack()
2286 static void process_ack(struct ceph_connection *con) in process_ack()
2316 static int read_partial_message_section(struct ceph_connection *con, in read_partial_message_section()
2339 static int read_partial_msg_data(struct ceph_connection *con) in read_partial_msg_data()
2384 static int ceph_con_in_msg_alloc(struct ceph_connection *con, int *skip);
2386 static int read_partial_message(struct ceph_connection *con) in read_partial_message()
2547 static void process_message(struct ceph_connection *con) in process_message()
2574 static int read_keepalive_ack(struct ceph_connection *con) in read_keepalive_ack()
2590 static int try_write(struct ceph_connection *con) in try_write()
2686 static int try_read(struct ceph_connection *con) in try_read()
2837 static int queue_con_delay(struct ceph_connection *con, unsigned long delay) in queue_con_delay()
2854 static void queue_con(struct ceph_connection *con) in queue_con()
2859 static void cancel_con(struct ceph_connection *con) in cancel_con()
2867 static bool con_sock_closed(struct ceph_connection *con) in con_sock_closed()
2896 static bool con_backoff(struct ceph_connection *con) in con_backoff()
2916 static void con_fault_finish(struct ceph_connection *con) in con_fault_finish()
2940 struct ceph_connection *con = container_of(work, struct ceph_connection, in ceph_con_workfn()
3005 static void con_fault(struct ceph_connection *con) in con_fault()
3085 static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con) in msg_con_set()
3094 static void clear_standby(struct ceph_connection *con) in clear_standby()
3109 void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) in ceph_con_send()
3151 struct ceph_connection *con = msg->con; in ceph_msg_revoke()
3197 struct ceph_connection *con = msg->con; in ceph_msg_revoke_incoming()
3232 void ceph_con_keepalive(struct ceph_connection *con) in ceph_con_keepalive()
3244 bool ceph_con_keepalive_expired(struct ceph_connection *con, in ceph_con_keepalive_expired()
3413 static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) in ceph_alloc_middle()
3444 static int ceph_con_in_msg_alloc(struct ceph_connection *con, int *skip) in ceph_con_in_msg_alloc()