Lines Matching defs:con

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()
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()
301 static void con_sock_state_connected(struct ceph_connection *con) in con_sock_state_connected()
312 static void con_sock_state_closing(struct ceph_connection *con) in con_sock_state_closing()
325 static void con_sock_state_closed(struct ceph_connection *con) in con_sock_state_closed()
346 struct ceph_connection *con = sk->sk_user_data; in ceph_sock_data_ready() local
361 struct ceph_connection *con = sk->sk_user_data; in ceph_sock_write_space() local
384 struct ceph_connection *con = sk->sk_user_data; in ceph_sock_state_change() local
413 struct ceph_connection *con) in set_sock_callbacks()
430 int ceph_tcp_connect(struct ceph_connection *con) in ceph_tcp_connect()
480 int ceph_con_close_socket(struct ceph_connection *con) in ceph_con_close_socket()
503 static void ceph_con_reset_protocol(struct ceph_connection *con) in ceph_con_reset_protocol()
545 void ceph_con_reset_session(struct ceph_connection *con) in ceph_con_reset_session()
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()
611 bool ceph_con_opened(struct ceph_connection *con) in ceph_con_opened()
622 void ceph_con_init(struct ceph_connection *con, void *private, in ceph_con_init()
662 void ceph_con_discard_sent(struct ceph_connection *con, u64 ack_seq) in ceph_con_discard_sent()
687 void ceph_con_discard_requeued(struct ceph_connection *con, u64 reconnect_seq) in ceph_con_discard_requeued()
1354 void ceph_con_process_message(struct ceph_connection *con) in ceph_con_process_message()
1387 static int queue_con_delay(struct ceph_connection *con, unsigned long delay) in queue_con_delay()
1407 static void queue_con(struct ceph_connection *con) in queue_con()
1412 static void cancel_con(struct ceph_connection *con) in cancel_con()
1420 static bool con_sock_closed(struct ceph_connection *con) in con_sock_closed()
1452 static bool con_backoff(struct ceph_connection *con) in con_backoff()
1472 static void con_fault_finish(struct ceph_connection *con) in con_fault_finish()
1496 struct ceph_connection *con = container_of(work, struct ceph_connection, in ceph_con_workfn() local
1567 static void con_fault(struct ceph_connection *con) in con_fault()
1657 static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con) in msg_con_set()
1666 static void clear_standby(struct ceph_connection *con) in clear_standby()
1683 void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) in ceph_con_send()
1725 struct ceph_connection *con = msg->con; in ceph_msg_revoke() local
1765 struct ceph_connection *con = msg->con; in ceph_msg_revoke_incoming() local
1792 void ceph_con_keepalive(struct ceph_connection *con) in ceph_con_keepalive()
1805 bool ceph_con_keepalive_expired(struct ceph_connection *con, in ceph_con_keepalive_expired()
1975 static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) in ceph_alloc_middle()
2006 int ceph_con_in_msg_alloc(struct ceph_connection *con, in ceph_con_in_msg_alloc()
2053 void ceph_con_get_out_msg(struct ceph_connection *con) in ceph_con_get_out_msg()