Home
last modified time | relevance | path

Searched defs:con (Results 1 – 7 of 7) sorted by relevance

/net/ceph/
Dmessenger_v1.c111 static void con_out_kvec_reset(struct ceph_connection *con) in con_out_kvec_reset()
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()
172 static void prepare_write_message_footer(struct ceph_connection *con) in prepare_write_message_footer()
195 static void prepare_write_message(struct ceph_connection *con) in prepare_write_message()
267 static void prepare_write_ack(struct ceph_connection *con) in prepare_write_ack()
288 static void prepare_write_seq(struct ceph_connection *con) in prepare_write_seq()
306 static void prepare_write_keepalive(struct ceph_connection *con) in prepare_write_keepalive()
328 static int get_connect_authorizer(struct ceph_connection *con) in get_connect_authorizer()
[all …]
Dmessenger_v2.c106 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()
209 static void add_in_kvec(struct ceph_connection *con, void *buf, int len) in add_in_kvec()
222 static void reset_in_kvecs(struct ceph_connection *con) in reset_in_kvecs()
230 static void set_in_bvec(struct ceph_connection *con, const struct bio_vec *bv) in set_in_bvec()
238 static void set_in_skip(struct ceph_connection *con, int len) in set_in_skip()
246 static void add_out_kvec(struct ceph_connection *con, void *buf, int len) in add_out_kvec()
260 static void reset_out_kvecs(struct ceph_connection *con) in reset_out_kvecs()
271 static void set_out_bvec(struct ceph_connection *con, const struct bio_vec *bv, in set_out_bvec()
283 static void set_out_bvec_zero(struct ceph_connection *con) in set_out_bvec_zero()
[all …]
Dmessenger.c99 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()
[all …]
Dmon_client.c706 static struct ceph_msg *get_generic_reply(struct ceph_connection *con, in get_generic_reply()
1351 static int mon_get_auth_request(struct ceph_connection *con, in mon_get_auth_request()
1370 static int mon_handle_auth_reply_more(struct ceph_connection *con, in mon_handle_auth_reply_more()
1391 static int mon_handle_auth_done(struct ceph_connection *con, in mon_handle_auth_done()
1414 static int mon_handle_auth_bad_method(struct ceph_connection *con, in mon_handle_auth_bad_method()
1436 static void mon_dispatch(struct ceph_connection *con, struct ceph_msg *msg) in mon_dispatch()
1485 static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con, in mon_alloc_msg()
1545 static void mon_fault(struct ceph_connection *con) in mon_fault()
1568 static struct ceph_connection *mon_get_con(struct ceph_connection *con) in mon_get_con()
1573 static void mon_put_con(struct ceph_connection *con) in mon_put_con()
Dosd_client.c4206 static void osd_fault(struct ceph_connection *con) in osd_fault()
5359 static void osd_dispatch(struct ceph_connection *con, struct ceph_msg *msg) in osd_dispatch()
5392 static struct ceph_msg *get_reply(struct ceph_connection *con, in get_reply()
5481 static struct ceph_msg *osd_alloc_msg(struct ceph_connection *con, in osd_alloc_msg()
5507 static struct ceph_connection *osd_get_con(struct ceph_connection *con) in osd_get_con()
5515 static void osd_put_con(struct ceph_connection *con) in osd_put_con()
5530 osd_get_authorizer(struct ceph_connection *con, int *proto, int force_new) in osd_get_authorizer()
5546 static int osd_add_authorizer_challenge(struct ceph_connection *con, in osd_add_authorizer_challenge()
5557 static int osd_verify_authorizer_reply(struct ceph_connection *con) in osd_verify_authorizer_reply()
5569 static int osd_invalidate_authorizer(struct ceph_connection *con) in osd_invalidate_authorizer()
[all …]
/net/tipc/
Dtopsrv.c118 static bool connected(struct tipc_conn *con) in connected()
125 struct tipc_conn *con = container_of(kref, struct tipc_conn, kref); in tipc_conn_kref_release() local
145 static void conn_put(struct tipc_conn *con) in conn_put()
150 static void conn_get(struct tipc_conn *con) in conn_get()
155 static void tipc_conn_close(struct tipc_conn *con) in tipc_conn_close()
181 struct tipc_conn *con; in tipc_conn_alloc() local
217 struct tipc_conn *con; in tipc_conn_lookup() local
230 static void tipc_conn_delete_sub(struct tipc_conn *con, struct tipc_subscr *s) in tipc_conn_delete_sub()
248 static void tipc_conn_send_to_sock(struct tipc_conn *con) in tipc_conn_send_to_sock()
302 struct tipc_conn *con = container_of(work, struct tipc_conn, swork); in tipc_conn_send_work() local
[all …]
Dnetlink_compat.c1063 struct nlattr *con[TIPC_NLA_CON_MAX + 1]; in tipc_nl_compat_sk_dump() local