Lines Matching defs:con
131 struct ceph_connection *con = in ceph_data_ready() local
143 struct ceph_connection *con = in ceph_write_space() local
161 struct ceph_connection *con = in ceph_state_change() local
194 struct ceph_connection *con) in set_sock_callbacks()
211 static struct socket *ceph_tcp_connect(struct ceph_connection *con) in ceph_tcp_connect()
291 static int con_close_socket(struct ceph_connection *con) in con_close_socket()
324 static void reset_connection(struct ceph_connection *con) in reset_connection()
349 void ceph_con_close(struct ceph_connection *con) in ceph_con_close()
370 void ceph_con_open(struct ceph_connection *con, struct ceph_entity_addr *addr) in ceph_con_open()
384 bool ceph_con_opened(struct ceph_connection *con) in ceph_con_opened()
392 struct ceph_connection *ceph_con_get(struct ceph_connection *con) in ceph_con_get()
401 void ceph_con_put(struct ceph_connection *con) in ceph_con_put()
415 void ceph_con_init(struct ceph_messenger *msgr, struct ceph_connection *con) in ceph_con_init()
450 static void prepare_write_message_footer(struct ceph_connection *con, int v) in prepare_write_message_footer()
467 static void prepare_write_message(struct ceph_connection *con) in prepare_write_message()
565 static void prepare_write_ack(struct ceph_connection *con) in prepare_write_ack()
586 static void prepare_write_keepalive(struct ceph_connection *con) in prepare_write_keepalive()
601 static int prepare_connect_authorizer(struct ceph_connection *con) in prepare_connect_authorizer()
635 struct ceph_connection *con) in prepare_write_banner()
651 struct ceph_connection *con, in prepare_write_connect()
703 static int write_partial_kvec(struct ceph_connection *con) in write_partial_kvec()
771 static int write_partial_msg_pages(struct ceph_connection *con) in write_partial_msg_pages()
905 static int write_partial_skip(struct ceph_connection *con) in write_partial_skip()
928 static void prepare_read_banner(struct ceph_connection *con) in prepare_read_banner()
934 static void prepare_read_connect(struct ceph_connection *con) in prepare_read_connect()
940 static void prepare_read_ack(struct ceph_connection *con) in prepare_read_ack()
946 static void prepare_read_tag(struct ceph_connection *con) in prepare_read_tag()
956 static int prepare_read_message(struct ceph_connection *con) in prepare_read_message()
966 static int read_partial(struct ceph_connection *con, in read_partial()
985 static int read_partial_banner(struct ceph_connection *con) in read_partial_banner()
1007 static int read_partial_connect(struct ceph_connection *con) in read_partial_connect()
1033 static int verify_hello(struct ceph_connection *con) in verify_hello()
1253 static int process_banner(struct ceph_connection *con) in process_banner()
1301 static void fail_protocol(struct ceph_connection *con) in fail_protocol()
1312 static int process_connect(struct ceph_connection *con) in process_connect()
1464 static int read_partial_ack(struct ceph_connection *con) in read_partial_ack()
1476 static void process_ack(struct ceph_connection *con) in process_ack()
1499 static int read_partial_message_section(struct ceph_connection *con, in read_partial_message_section()
1528 static int read_partial_message_pages(struct ceph_connection *con, in read_partial_message_pages()
1561 static int read_partial_message_bio(struct ceph_connection *con, in read_partial_message_bio()
1600 static int read_partial_message(struct ceph_connection *con) in read_partial_message()
1776 static void process_message(struct ceph_connection *con) in process_message()
1809 static int try_write(struct ceph_connection *con) in try_write()
1905 static int try_read(struct ceph_connection *con) in try_read()
2031 static void queue_con(struct ceph_connection *con) in queue_con()
2057 struct ceph_connection *con = container_of(work, struct ceph_connection, in con_work() local
2124 static void ceph_fault(struct ceph_connection *con) in ceph_fault()
2251 static void clear_standby(struct ceph_connection *con) in clear_standby()
2267 void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) in ceph_con_send()
2305 void ceph_con_revoke(struct ceph_connection *con, struct ceph_msg *msg) in ceph_con_revoke()
2330 void ceph_con_revoke_message(struct ceph_connection *con, struct ceph_msg *msg) in ceph_con_revoke_message()
2360 void ceph_con_keepalive(struct ceph_connection *con) in ceph_con_keepalive()
2462 static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) in ceph_alloc_middle()
2481 static struct ceph_msg *ceph_alloc_msg(struct ceph_connection *con, in ceph_alloc_msg()