| /net/sctp/ |
| D | endpointola.c | 41 static struct sctp_endpoint *sctp_endpoint_init(struct sctp_endpoint *ep, in sctp_endpoint_init() argument
48 ep->digest = kzalloc(SCTP_SIGNATURE_SIZE, gfp); in sctp_endpoint_init()
49 if (!ep->digest) in sctp_endpoint_init()
52 ep->asconf_enable = net->sctp.addip_enable; in sctp_endpoint_init()
53 ep->auth_enable = net->sctp.auth_enable; in sctp_endpoint_init()
54 if (ep->auth_enable) { in sctp_endpoint_init()
55 if (sctp_auth_init(ep, gfp)) in sctp_endpoint_init()
57 if (ep->asconf_enable) { in sctp_endpoint_init()
58 sctp_auth_ep_add_chunkid(ep, SCTP_CID_ASCONF); in sctp_endpoint_init()
59 sctp_auth_ep_add_chunkid(ep, SCTP_CID_ASCONF_ACK); in sctp_endpoint_init()
[all …]
|
| D | sm_statefuns.c | 52 const struct sctp_endpoint *ep,
64 const struct sctp_endpoint *ep,
71 const struct sctp_endpoint *ep,
78 const struct sctp_endpoint *ep,
85 const struct sctp_endpoint *ep,
92 const struct sctp_endpoint *ep,
108 const struct sctp_endpoint *ep,
117 const struct sctp_endpoint *ep,
125 const struct sctp_endpoint *ep,
133 const struct sctp_endpoint *ep,
[all …]
|
| D | auth.c | 353 int sctp_auth_asoc_copy_shkeys(const struct sctp_endpoint *ep, in sctp_auth_asoc_copy_shkeys() argument
362 key_for_each(sh_key, &ep->endpoint_shared_keys) { in sctp_auth_asoc_copy_shkeys()
454 int sctp_auth_init_hmacs(struct sctp_endpoint *ep, gfp_t gfp) in sctp_auth_init_hmacs() argument
460 if (ep->auth_hmacs) in sctp_auth_init_hmacs()
464 ep->auth_hmacs = kcalloc(SCTP_AUTH_NUM_HMACS, in sctp_auth_init_hmacs()
467 if (!ep->auth_hmacs) in sctp_auth_init_hmacs()
481 if (ep->auth_hmacs[id]) in sctp_auth_init_hmacs()
489 ep->auth_hmacs[id] = tfm; in sctp_auth_init_hmacs()
496 sctp_auth_destroy_hmacs(ep->auth_hmacs); in sctp_auth_init_hmacs()
497 ep->auth_hmacs = NULL; in sctp_auth_init_hmacs()
[all …]
|
| D | input.c | 92 struct sctp_endpoint *ep = NULL; in sctp_rcv() local
168 ep = __sctp_rcv_lookup_endpoint(net, skb, &dest, &src, dif, sdif); in sctp_rcv()
171 rcvr = asoc ? &asoc->base : &ep->base; in sctp_rcv()
252 sctp_endpoint_put(ep); in sctp_rcv()
266 sctp_endpoint_put(ep); in sctp_rcv()
454 asoc->state, asoc->ep, asoc, t, in sctp_icmp_proto_unreachable()
733 static int __sctp_hash_endpoint(struct sctp_endpoint *ep) in __sctp_hash_endpoint() argument
735 struct sock *sk = ep->base.sk; in __sctp_hash_endpoint()
740 ep->hashent = sctp_ep_hashfn(net, ep->base.bind_addr.port); in __sctp_hash_endpoint()
741 head = &sctp_ep_hashtable[ep->hashent]; in __sctp_hash_endpoint()
[all …]
|
| D | socket.c | 111 return asoc->ep->sndbuf_policy ? sk->sk_sndbuf - asoc->sndbuf_used in sctp_wspace()
246 if (!list_empty(&sctp_sk(sk)->ep->asocs)) in sctp_id2assoc()
247 asoc = list_entry(sctp_sk(sk)->ep->asocs.next, in sctp_id2assoc()
281 addr_asoc = sctp_endpoint_lookup_assoc(sctp_sk(sk)->ep, in sctp_addr_id2transport()
318 if (!sctp_sk(sk)->ep->base.bind_addr.port) in sctp_bind()
379 struct sctp_endpoint *ep = sp->ep; in sctp_do_bind() local
380 struct sctp_bind_addr *bp = &ep->base.bind_addr; in sctp_do_bind()
559 struct sctp_endpoint *ep; in sctp_send_asconf_add_ip() local
573 ep = sp->ep; in sctp_send_asconf_add_ip()
575 if (!ep->asconf_enable) in sctp_send_asconf_add_ip()
[all …]
|
| D | diag.c | 127 struct sctp_endpoint *ep = sctp_sk(sk)->ep; in inet_sctp_diag_fill() local
160 if (asoc && asoc->ep->sndbuf_policy) in inet_sctp_diag_fill()
165 if (asoc && asoc->ep->rcvbuf_policy) in inet_sctp_diag_fill()
198 : &ep->base.bind_addr.address_list; in inet_sctp_diag_fill()
245 static int sctp_sock_dump_one(struct sctp_endpoint *ep, struct sctp_transport *tsp, void *p) in sctp_sock_dump_one() argument
249 struct sock *sk = ep->base.sk; in sctp_sock_dump_one()
264 if (ep != assoc->ep) { in sctp_sock_dump_one()
286 static int sctp_sock_dump(struct sctp_endpoint *ep, struct sctp_transport *tsp, void *p) in sctp_sock_dump() argument
289 struct sock *sk = ep->base.sk; in sctp_sock_dump()
297 if (ep != tsp->asoc->ep) in sctp_sock_dump()
[all …]
|
| D | associola.c | 53 const struct sctp_endpoint *ep, in sctp_association_init() argument
65 asoc->ep = (struct sctp_endpoint *)ep; in sctp_association_init()
69 sctp_endpoint_hold(asoc->ep); in sctp_association_init()
79 sctp_bind_addr_init(&asoc->base.bind_addr, ep->base.bind_addr.port); in sctp_association_init()
177 asoc->c.my_vtag = sctp_generate_tag(ep); in sctp_association_init()
178 asoc->c.my_port = ep->base.bind_addr.port; in sctp_association_init()
180 asoc->c.initial_tsn = sctp_generate_tsn(ep); in sctp_association_init()
255 if (sctp_auth_asoc_copy_shkeys(ep, asoc, gfp)) in sctp_association_init()
258 asoc->active_key_id = ep->active_key_id; in sctp_association_init()
259 asoc->strreset_enable = ep->strreset_enable; in sctp_association_init()
[all …]
|
| D | sm_make_chunk.c | 58 const struct sctp_endpoint *ep,
215 struct sctp_endpoint *ep = asoc->ep; in sctp_make_init() local
248 if (asoc->ep->ecn_enable) in sctp_make_init()
251 if (asoc->ep->prsctp_enable) in sctp_make_init()
259 if (asoc->ep->asconf_enable) { in sctp_make_init()
265 if (asoc->ep->reconf_enable) { in sctp_make_init()
273 if (asoc->ep->intl_enable) { in sctp_make_init()
281 if (ep->auth_enable) { in sctp_make_init()
340 if (asoc->ep->ecn_enable) in sctp_make_init()
353 if (asoc->ep->prsctp_enable) in sctp_make_init()
[all …]
|
| D | primitive.c | 43 struct sctp_endpoint *ep; \
48 ep = asoc ? asoc->ep : NULL; \
50 error = sctp_do_sm(net, event_type, subtype, state, ep, asoc, \
|
| D | sm_sideeffect.c | 43 struct sctp_endpoint *ep,
52 struct sctp_endpoint *ep,
256 asoc->ep, asoc, in sctp_generate_t3_rtx_event()
297 asoc->state, asoc->ep, asoc, in sctp_generate_timeout_event()
393 asoc->state, asoc->ep, asoc, in sctp_generate_heartbeat_event()
434 asoc->state, asoc->ep, asoc, transport, GFP_ATOMIC); in sctp_generate_proto_unreach_event()
467 asoc->state, asoc->ep, asoc, in sctp_generate_reconf_event()
499 asoc->state, asoc->ep, asoc, in sctp_generate_probe_event()
838 asoc->state, asoc->ep, asoc, NULL, in sctp_cmd_process_sack()
1125 ep, sctp_evttype_tbl[event_type], (*debug_fn)(subtype), \
[all …]
|
| D | proc.c | 164 struct sctp_endpoint *ep; in sctp_eps_seq_show() local
173 sctp_for_each_hentry(ep, &head->chain) { in sctp_eps_seq_show()
174 sk = ep->base.sk; in sctp_eps_seq_show()
177 seq_printf(seq, "%8pK %8pK %-3d %-3d %-4d %-5d %5u %5lu ", ep, sk, in sctp_eps_seq_show()
179 ep->base.bind_addr.port, in sctp_eps_seq_show()
183 sctp_seq_dump_local_addrs(seq, &ep->base); in sctp_eps_seq_show()
|
| D | objcnt.c | 32 SCTP_DBG_OBJCNT(ep);
47 SCTP_DBG_OBJCNT_ENTRY(ep),
|
| D | bind_addr.c | 337 struct sctp_bind_addr *bp2 = &sp2->ep->base.bind_addr; in sctp_bind_addrs_check()
338 struct sctp_bind_addr *bp = &sp->ep->base.bind_addr; in sctp_bind_addrs_check()
551 bp = &sctp_sk(sk)->ep->base.bind_addr; in sctp_is_ep_boundall()
|
| /net/sunrpc/xprtrdma/ |
| D | verbs.c | 76 static void rpcrdma_ep_get(struct rpcrdma_ep *ep);
77 static int rpcrdma_ep_put(struct rpcrdma_ep *ep);
89 struct rpcrdma_ep *ep = r_xprt->rx_ep; in rpcrdma_xprt_drain() local
90 struct rdma_cm_id *id = ep->re_id; in rpcrdma_xprt_drain()
95 if (atomic_inc_return(&ep->re_receiving) > 1) in rpcrdma_xprt_drain()
96 wait_for_completion(&ep->re_done); in rpcrdma_xprt_drain()
108 rpcrdma_ep_put(ep); in rpcrdma_xprt_drain()
115 void rpcrdma_force_disconnect(struct rpcrdma_ep *ep) in rpcrdma_force_disconnect() argument
117 if (atomic_add_unless(&ep->re_force_disconnect, 1, 1)) in rpcrdma_force_disconnect()
118 xprt_force_disconnect(ep->re_xprt); in rpcrdma_force_disconnect()
[all …]
|
| D | frwr_ops.c | 48 static void frwr_cid_init(struct rpcrdma_ep *ep, in frwr_cid_init() argument
53 cid->ci_queue_id = ep->re_attr.send_cq->res.id; in frwr_cid_init()
124 struct rpcrdma_ep *ep = r_xprt->rx_ep; in frwr_mr_init() local
125 unsigned int depth = ep->re_max_fr_depth; in frwr_mr_init()
130 ibdev_to_node(ep->re_id->device)); in frwr_mr_init()
134 frmr = ib_alloc_mr(ep->re_pd, ep->re_mrtype, depth); in frwr_mr_init()
143 frwr_cid_init(ep, mr); in frwr_mr_init()
172 int frwr_query_device(struct rpcrdma_ep *ep, const struct ib_device *device) in frwr_query_device() argument
191 ep->re_attr.cap.max_send_sge = max_sge; in frwr_query_device()
192 ep->re_attr.cap.max_recv_sge = 1; in frwr_query_device()
[all …]
|
| D | rpc_rdma.c | 108 void rpcrdma_set_max_header_sizes(struct rpcrdma_ep *ep) in rpcrdma_set_max_header_sizes() argument
110 unsigned int maxsegs = ep->re_max_rdma_segs; in rpcrdma_set_max_header_sizes()
112 ep->re_max_inline_send = in rpcrdma_set_max_header_sizes()
113 ep->re_inline_send - rpcrdma_max_call_header_size(maxsegs); in rpcrdma_set_max_header_sizes()
114 ep->re_max_inline_recv = in rpcrdma_set_max_header_sizes()
115 ep->re_inline_recv - rpcrdma_max_reply_header_size(maxsegs); in rpcrdma_set_max_header_sizes()
130 struct rpcrdma_ep *ep = r_xprt->rx_ep; in rpcrdma_args_inline() local
133 if (xdr->len > ep->re_max_inline_send) in rpcrdma_args_inline()
144 if (++count > ep->re_attr.cap.max_send_sge) in rpcrdma_args_inline()
396 struct rpcrdma_ep *ep = r_xprt->rx_ep; in rpcrdma_encode_write_list() local
[all …]
|
| D | backchannel.c | 43 struct rpcrdma_ep *ep = r_xprt->rx_ep; in xprt_rdma_bc_maxpayload() local
46 maxmsg = min_t(unsigned int, ep->re_inline_send, ep->re_inline_recv); in xprt_rdma_bc_maxpayload()
|
| D | xprt_rdma.h | 464 void rpcrdma_force_disconnect(struct rpcrdma_ep *ep);
534 int frwr_query_device(struct rpcrdma_ep *ep, const struct ib_device *device);
567 void rpcrdma_set_max_header_sizes(struct rpcrdma_ep *ep);
|
| D | transport.c | 477 struct rpcrdma_ep *ep = r_xprt->rx_ep; in xprt_rdma_connect() local
483 if (ep && ep->re_connect_status != 0) { in xprt_rdma_connect()
|
| /net/qrtr/ |
| D | mhi.c | 15 struct qrtr_endpoint ep; member
30 rc = qrtr_endpoint_post(&qdev->ep, mhi_res->buf_addr, in qcom_mhi_qrtr_dl_callback()
48 static int qcom_mhi_qrtr_send(struct qrtr_endpoint *ep, struct sk_buff *skb) in qcom_mhi_qrtr_send() argument
50 struct qrtr_mhi_dev *qdev = container_of(ep, struct qrtr_mhi_dev, ep); in qcom_mhi_qrtr_send()
87 qdev->ep.xmit = qcom_mhi_qrtr_send; in qcom_mhi_qrtr_probe()
90 rc = qrtr_endpoint_register(&qdev->ep, QRTR_EP_NID_AUTO); in qcom_mhi_qrtr_probe()
97 qrtr_endpoint_unregister(&qdev->ep); in qcom_mhi_qrtr_probe()
110 qrtr_endpoint_unregister(&qdev->ep); in qcom_mhi_qrtr_remove()
|
| D | smd.c | 14 struct qrtr_endpoint ep; member
29 rc = qrtr_endpoint_post(&qdev->ep, data, len); in qcom_smd_qrtr_callback()
40 static int qcom_smd_qrtr_send(struct qrtr_endpoint *ep, struct sk_buff *skb) in qcom_smd_qrtr_send() argument
42 struct qrtr_smd_dev *qdev = container_of(ep, struct qrtr_smd_dev, ep); in qcom_smd_qrtr_send()
70 qdev->ep.xmit = qcom_smd_qrtr_send; in qcom_smd_qrtr_probe()
72 rc = qrtr_endpoint_register(&qdev->ep, QRTR_EP_NID_AUTO); in qcom_smd_qrtr_probe()
87 qrtr_endpoint_unregister(&qdev->ep); in qcom_smd_qrtr_remove()
|
| D | tun.c | 13 struct qrtr_endpoint ep; member
19 static int qrtr_tun_send(struct qrtr_endpoint *ep, struct sk_buff *skb) in qrtr_tun_send() argument
21 struct qrtr_tun *tun = container_of(ep, struct qrtr_tun, ep); in qrtr_tun_send()
43 tun->ep.xmit = qrtr_tun_send; in qrtr_tun_open()
47 ret = qrtr_endpoint_register(&tun->ep, QRTR_EP_NID_AUTO); in qrtr_tun_open()
108 ret = qrtr_endpoint_post(&tun->ep, kbuf, len); in qrtr_tun_write_iter()
131 qrtr_endpoint_unregister(&tun->ep); in qrtr_tun_release()
|
| D | qrtr.h | 21 int (*xmit)(struct qrtr_endpoint *ep, struct sk_buff *skb);
26 int qrtr_endpoint_register(struct qrtr_endpoint *ep, unsigned int nid);
28 void qrtr_endpoint_unregister(struct qrtr_endpoint *ep);
30 int qrtr_endpoint_post(struct qrtr_endpoint *ep, const void *data, size_t len);
|
| D | af_qrtr.c | 128 struct qrtr_endpoint *ep; member
293 !node->ep); in qrtr_tx_wait()
296 } else if (!node->ep) { in qrtr_tx_wait()
375 if (node->ep) in qrtr_node_enqueue()
376 rc = node->ep->xmit(node->ep, skb); in qrtr_node_enqueue()
435 int qrtr_endpoint_post(struct qrtr_endpoint *ep, const void *data, size_t len) in qrtr_endpoint_post() argument
437 struct qrtr_node *node = ep->node; in qrtr_endpoint_post()
585 int qrtr_endpoint_register(struct qrtr_endpoint *ep, unsigned int nid) in qrtr_endpoint_register() argument
589 if (!ep || !ep->xmit) in qrtr_endpoint_register()
600 node->ep = ep; in qrtr_endpoint_register()
[all …]
|
| /net/netfilter/ipvs/ |
| D | ip_vs_ftp.c | 187 const char *ep; in ip_vs_ftp_get_addrport() local
204 &ep) <= 0) in ip_vs_ftp_get_addrport()
208 &ep) <= 0) in ip_vs_ftp_get_addrport()
211 s = (char *) ep; in ip_vs_ftp_get_addrport()
|