| /net/ceph/ |
| D | messenger_v1.c | 111 static void con_out_kvec_reset(struct ceph_connection *con) in con_out_kvec_reset() argument
113 BUG_ON(con->v1.out_skip); in con_out_kvec_reset()
115 con->v1.out_kvec_left = 0; in con_out_kvec_reset()
116 con->v1.out_kvec_bytes = 0; in con_out_kvec_reset()
117 con->v1.out_kvec_cur = &con->v1.out_kvec[0]; in con_out_kvec_reset()
120 static void con_out_kvec_add(struct ceph_connection *con, in con_out_kvec_add() argument
123 int index = con->v1.out_kvec_left; in con_out_kvec_add()
125 BUG_ON(con->v1.out_skip); in con_out_kvec_add()
126 BUG_ON(index >= ARRAY_SIZE(con->v1.out_kvec)); in con_out_kvec_add()
128 con->v1.out_kvec[index].iov_len = size; in con_out_kvec_add()
[all …]
|
| D | messenger_v2.c | 106 static int ceph_tcp_recv(struct ceph_connection *con) in ceph_tcp_recv() argument
110 dout("%s con %p %s %zu\n", __func__, con, in ceph_tcp_recv()
111 iov_iter_is_discard(&con->v2.in_iter) ? "discard" : "need", in ceph_tcp_recv()
112 iov_iter_count(&con->v2.in_iter)); in ceph_tcp_recv()
113 ret = do_recvmsg(con->sock, &con->v2.in_iter); in ceph_tcp_recv()
114 dout("%s con %p ret %d left %zu\n", __func__, con, ret, in ceph_tcp_recv()
115 iov_iter_count(&con->v2.in_iter)); in ceph_tcp_recv()
194 static int ceph_tcp_send(struct ceph_connection *con) in ceph_tcp_send() argument
198 dout("%s con %p have %zu try_sendpage %d\n", __func__, con, in ceph_tcp_send()
199 iov_iter_count(&con->v2.out_iter), con->v2.out_iter_sendpage); in ceph_tcp_send()
[all …]
|
| D | messenger.c | 99 void ceph_con_flag_clear(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_clear() argument
103 clear_bit(con_flag, &con->flags); in ceph_con_flag_clear()
106 void ceph_con_flag_set(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_set() argument
110 set_bit(con_flag, &con->flags); in ceph_con_flag_set()
113 bool ceph_con_flag_test(struct ceph_connection *con, unsigned long con_flag) in ceph_con_flag_test() argument
117 return test_bit(con_flag, &con->flags); in ceph_con_flag_test()
120 bool ceph_con_flag_test_and_clear(struct ceph_connection *con, in ceph_con_flag_test_and_clear() argument
125 return test_and_clear_bit(con_flag, &con->flags); 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() argument
133 return test_and_set_bit(con_flag, &con->flags); in ceph_con_flag_test_and_set()
[all …]
|
| D | mon_client.c | 182 ceph_con_send(&monc->con, monc->m_auth); in __send_prepared_auth_request()
195 ceph_con_close(&monc->con); in __close_session()
256 ceph_con_open(&monc->con, CEPH_ENTITY_TYPE_MON, monc->cur_mon, in __open_session()
265 ceph_con_keepalive(&monc->con); in __open_session()
283 monc->cur_mon, ceph_pr_addr(&monc->con.peer_addr)); in reopen_session()
379 ceph_con_send(&monc->con, ceph_msg_get(msg)); in __send_subscribe()
645 ceph_con_send(&monc->con, ceph_msg_get(req->request)); in send_generic_request()
706 static struct ceph_msg *get_generic_reply(struct ceph_connection *con, in get_generic_reply() argument
710 struct ceph_mon_client *monc = con->private; in get_generic_reply()
1074 ceph_con_send(&monc->con, ceph_msg_get(req->request)); in __resend_generic_request()
[all …]
|
| D | osd_client.c | 2163 if (CEPH_HAVE_FEATURE(msg->con->peer_features, RESEND_ON_SPLIT)) { in encode_request_finish()
2166 ceph_encode_64(&p, msg->con->peer_features); in encode_request_finish()
4206 static void osd_fault(struct ceph_connection *con) in osd_fault() argument
4208 struct ceph_osd *osd = con->private; in osd_fault()
5359 static void osd_dispatch(struct ceph_connection *con, struct ceph_msg *msg) in osd_dispatch() argument
5361 struct ceph_osd *osd = con->private; in osd_dispatch()
5392 static struct ceph_msg *get_reply(struct ceph_connection *con, in get_reply() argument
5396 struct ceph_osd *osd = con->private; in get_reply()
5481 static struct ceph_msg *osd_alloc_msg(struct ceph_connection *con, in osd_alloc_msg() argument
5485 struct ceph_osd *osd = con->private; in osd_alloc_msg()
[all …]
|
| D | auth_x.c | 968 if (!CEPH_HAVE_FEATURE(msg->con->peer_features, CEPHX_V2)) { in calc_signature()
1033 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) in ceph_x_sign_message()
1052 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) in ceph_x_check_message_signature()
|
| /net/tipc/ |
| D | topsrv.c | 116 static void tipc_conn_delete_sub(struct tipc_conn *con, struct tipc_subscr *s);
118 static bool connected(struct tipc_conn *con) in connected() argument
120 return con && test_bit(CF_CONNECTED, &con->flags); in connected()
125 struct tipc_conn *con = container_of(kref, struct tipc_conn, kref); in tipc_conn_kref_release() local
126 struct tipc_topsrv *s = con->server; in tipc_conn_kref_release()
130 idr_remove(&s->conn_idr, con->conid); in tipc_conn_kref_release()
133 if (con->sock) in tipc_conn_kref_release()
134 sock_release(con->sock); in tipc_conn_kref_release()
136 spin_lock_bh(&con->outqueue_lock); in tipc_conn_kref_release()
137 list_for_each_entry_safe(e, safe, &con->outqueue, list) { in tipc_conn_kref_release()
[all …]
|
| D | netlink_compat.c | 1063 struct nlattr *con[TIPC_NLA_CON_MAX + 1]; in tipc_nl_compat_sk_dump() local
1065 err = nla_parse_nested_deprecated(con, TIPC_NLA_CON_MAX, in tipc_nl_compat_sk_dump()
1072 node = nla_get_u32(con[TIPC_NLA_CON_NODE]); in tipc_nl_compat_sk_dump()
1077 nla_get_u32(con[TIPC_NLA_CON_SOCK])); in tipc_nl_compat_sk_dump()
1079 if (con[TIPC_NLA_CON_FLAG]) in tipc_nl_compat_sk_dump()
1081 nla_get_u32(con[TIPC_NLA_CON_TYPE]), in tipc_nl_compat_sk_dump()
1082 nla_get_u32(con[TIPC_NLA_CON_INST])); in tipc_nl_compat_sk_dump()
|