| /net/sctp/ |
| D | endpointola.c | 64 static struct sctp_endpoint *sctp_endpoint_init(struct sctp_endpoint *ep, in sctp_endpoint_init() argument
73 memset(ep, 0, sizeof(struct sctp_endpoint)); in sctp_endpoint_init()
75 ep->digest = kzalloc(SCTP_SIGNATURE_SIZE, gfp); in sctp_endpoint_init()
76 if (!ep->digest) in sctp_endpoint_init()
121 ep->base.type = SCTP_EP_TYPE_SOCKET; in sctp_endpoint_init()
124 atomic_set(&ep->base.refcnt, 1); in sctp_endpoint_init()
125 ep->base.dead = 0; in sctp_endpoint_init()
126 ep->base.malloced = 1; in sctp_endpoint_init()
129 sctp_inq_init(&ep->base.inqueue); in sctp_endpoint_init()
132 sctp_inq_set_th_handler(&ep->base.inqueue, sctp_endpoint_bh_rcv); in sctp_endpoint_init()
[all …]
|
| D | sm_statefuns.c | 66 static struct sctp_packet *sctp_abort_pkt_new(const struct sctp_endpoint *ep,
76 static void sctp_send_stale_cookie_err(const struct sctp_endpoint *ep,
81 static sctp_disposition_t sctp_sf_do_5_2_6_stale(const struct sctp_endpoint *ep,
86 static sctp_disposition_t sctp_sf_shut_8_4_5(const struct sctp_endpoint *ep,
91 static sctp_disposition_t sctp_sf_tabort_8_4_8(const struct sctp_endpoint *ep,
104 const struct sctp_endpoint *ep,
112 const struct sctp_endpoint *ep,
119 const struct sctp_endpoint *ep,
126 const struct sctp_endpoint *ep,
133 const struct sctp_endpoint *ep,
[all …]
|
| D | auth.c | 362 int sctp_auth_asoc_copy_shkeys(const struct sctp_endpoint *ep, in sctp_auth_asoc_copy_shkeys() argument
371 key_for_each(sh_key, &ep->endpoint_shared_keys) { in sctp_auth_asoc_copy_shkeys()
445 int sctp_auth_init_hmacs(struct sctp_endpoint *ep, gfp_t gfp) in sctp_auth_init_hmacs() argument
452 ep->auth_hmacs = NULL; in sctp_auth_init_hmacs()
456 if (ep->auth_hmacs) in sctp_auth_init_hmacs()
460 ep->auth_hmacs = kzalloc( in sctp_auth_init_hmacs()
463 if (!ep->auth_hmacs) in sctp_auth_init_hmacs()
477 if (ep->auth_hmacs[id]) in sctp_auth_init_hmacs()
486 ep->auth_hmacs[id] = tfm; in sctp_auth_init_hmacs()
493 sctp_auth_destroy_hmacs(ep->auth_hmacs); in sctp_auth_init_hmacs()
[all …]
|
| D | input.c | 121 struct sctp_endpoint *ep = NULL; in sctp_rcv() local
181 ep = __sctp_rcv_lookup_endpoint(&dest); in sctp_rcv()
184 rcvr = asoc ? &asoc->base : &ep->base; in sctp_rcv()
197 sctp_endpoint_put(ep); in sctp_rcv()
198 ep = NULL; in sctp_rcv()
201 ep = sctp_sk(sk)->ep; in sctp_rcv()
202 sctp_endpoint_hold(ep); in sctp_rcv()
203 rcvr = &ep->base; in sctp_rcv()
279 sctp_endpoint_put(ep); in sctp_rcv()
293 sctp_endpoint_put(ep); in sctp_rcv()
[all …]
|
| D | associola.c | 71 const struct sctp_endpoint *ep, in sctp_association_init() argument
88 asoc->ep = (struct sctp_endpoint *)ep; in sctp_association_init()
89 sctp_endpoint_hold(asoc->ep); in sctp_association_init()
104 sctp_bind_addr_init(&asoc->base.bind_addr, ep->base.bind_addr.port); in sctp_association_init()
217 asoc->c.my_vtag = sctp_generate_tag(ep); in sctp_association_init()
222 asoc->c.my_port = ep->base.bind_addr.port; in sctp_association_init()
224 asoc->c.initial_tsn = sctp_generate_tsn(ep); in sctp_association_init()
310 err = sctp_auth_asoc_copy_shkeys(ep, asoc, gfp); in sctp_association_init()
314 asoc->active_key_id = ep->active_key_id; in sctp_association_init()
319 if (ep->auth_hmacs_list) in sctp_association_init()
[all …]
|
| D | primitive.c | 64 struct sctp_endpoint *ep; \
69 ep = asoc ? asoc->ep : NULL; \
71 error = sctp_do_sm(event_type, subtype, state, ep, asoc, \
|
| D | socket.c | 130 if (asoc->ep->sndbuf_policy) in sctp_wspace()
219 if (!list_empty(&sctp_sk(sk)->ep->asocs)) in sctp_id2assoc()
220 asoc = list_entry(sctp_sk(sk)->ep->asocs.next, in sctp_id2assoc()
251 addr_asoc = sctp_endpoint_lookup_assoc(sctp_sk(sk)->ep, in sctp_addr_id2transport()
288 if (!sctp_sk(sk)->ep->base.bind_addr.port) in sctp_bind()
335 struct sctp_endpoint *ep = sp->ep; in sctp_do_bind() local
336 struct sctp_bind_addr *bp = &ep->base.bind_addr; in sctp_do_bind()
515 struct sctp_endpoint *ep; in sctp_send_asconf_add_ip() local
532 ep = sp->ep; in sctp_send_asconf_add_ip()
537 list_for_each_entry(asoc, &ep->asocs, asocs) { in sctp_send_asconf_add_ip()
[all …]
|
| D | sm_sideeffect.c | 61 struct sctp_endpoint *ep,
69 struct sctp_endpoint *ep,
273 asoc->ep, asoc, in sctp_generate_t3_rtx_event()
313 asoc->state, asoc->ep, asoc, in sctp_generate_timeout_event()
389 asoc->state, asoc->ep, asoc, in sctp_generate_heartbeat_event()
673 asoc->state, asoc->ep, asoc, NULL, in sctp_cmd_process_sack()
940 ep, sctp_evttype_tbl[event_type], \
952 sctp_state_tbl[(asoc && sctp_id2assoc(ep->base.sk, \
963 struct sctp_endpoint *ep, in sctp_do_sm() argument
987 status = (*state_fn->fn)(ep, asoc, subtype, event_arg, &commands); in sctp_do_sm()
[all …]
|
| D | sm_make_chunk.c | 71 static sctp_cookie_param_t *sctp_pack_cookie(const struct sctp_endpoint *ep,
361 cookie = sctp_pack_cookie(asoc->ep, asoc, chunk, &cookie_len, in sctp_make_init_ack()
1438 struct sctp_association *sctp_make_temp_asoc(const struct sctp_endpoint *ep, in sctp_make_temp_asoc() argument
1449 asoc = sctp_association_new(ep, ep->base.sk, scope, gfp); in sctp_make_temp_asoc()
1470 static sctp_cookie_param_t *sctp_pack_cookie(const struct sctp_endpoint *ep, in sctp_pack_cookie() argument
1536 if (sctp_sk(ep->base.sk)->hmac) { in sctp_pack_cookie()
1542 key = (char *)ep->secret_key[ep->current_key]; in sctp_pack_cookie()
1543 desc.tfm = sctp_sk(ep->base.sk)->hmac; in sctp_pack_cookie()
1562 const struct sctp_endpoint *ep, in sctp_unpack_cookie() argument
1571 __u8 *digest = ep->digest; in sctp_unpack_cookie()
[all …]
|
| D | objcnt.c | 52 SCTP_DBG_OBJCNT(ep);
68 SCTP_DBG_OBJCNT_ENTRY(ep),
|
| D | proc.c | 202 struct sctp_endpoint *ep; in sctp_eps_seq_show() local
214 ep = sctp_ep(epb); in sctp_eps_seq_show()
216 seq_printf(seq, "%8p %8p %-3d %-3d %-4d %-5d %5d %5lu ", ep, sk, in sctp_eps_seq_show()
|
| D | ulpevent.c | 696 if (asoc->ep->rcvbuf_policy) in sctp_ulpevent_make_rcvmsg()
|
| /net/sunrpc/xprtrdma/ |
| D | verbs.c | 118 struct rpcrdma_ep *ep = context; in rpcrdma_qp_async_error_upcall() local
122 if (ep->rep_connected == 1) { in rpcrdma_qp_async_error_upcall()
123 ep->rep_connected = -EIO; in rpcrdma_qp_async_error_upcall()
124 ep->rep_func(ep); in rpcrdma_qp_async_error_upcall()
125 wake_up_all(&ep->rep_connect_wait); in rpcrdma_qp_async_error_upcall()
132 struct rpcrdma_ep *ep = context; in rpcrdma_cq_async_error_upcall() local
136 if (ep->rep_connected == 1) { in rpcrdma_cq_async_error_upcall()
137 ep->rep_connected = -EIO; in rpcrdma_cq_async_error_upcall()
138 ep->rep_func(ep); in rpcrdma_cq_async_error_upcall()
139 wake_up_all(&ep->rep_connect_wait); in rpcrdma_cq_async_error_upcall()
[all …]
|
| D | xprt_rdma.h | 91 #define INIT_CQCOUNT(ep) atomic_set(&(ep)->rep_cqcount, (ep)->rep_cqinit) argument
92 #define DECR_CQCOUNT(ep) atomic_sub_return(1, &(ep)->rep_cqcount) argument
|
| D | rpc_rdma.c | 538 struct rpcrdma_ep *ep = &r_xprt->rx_ep; in rpcrdma_marshal_req() local
540 req->rl_send_iov[2].addr = ep->rep_pad.addr; in rpcrdma_marshal_req()
542 req->rl_send_iov[2].lkey = ep->rep_pad.lkey; in rpcrdma_marshal_req()
690 rpcrdma_conn_func(struct rpcrdma_ep *ep) in rpcrdma_conn_func() argument
692 struct rpc_xprt *xprt = ep->rep_xprt; in rpcrdma_conn_func()
697 if (ep->rep_connected > 0) { in rpcrdma_conn_func()
|
| /net/netfilter/ipvs/ |
| D | ip_vs_lblcr.c | 130 struct ip_vs_dest_list *e, **ep; in ip_vs_dest_set_erase() local
132 for (ep=&set->list, e=*ep; e!=NULL; e=*ep) { in ip_vs_dest_set_erase()
135 *ep = e->next; in ip_vs_dest_set_erase()
142 ep = &e->next; in ip_vs_dest_set_erase()
148 struct ip_vs_dest_list *e, **ep; in ip_vs_dest_set_eraseall() local
151 for (ep=&set->list, e=*ep; e!=NULL; e=*ep) { in ip_vs_dest_set_eraseall()
152 *ep = e->next; in ip_vs_dest_set_eraseall()
|
| /net/sunrpc/auth_gss/ |
| D | svcauth_gss.c | 190 char *ep; in rsi_parse() local
229 rsii.major_status = simple_strtoul(buf, &ep, 10); in rsi_parse()
230 if (*ep) in rsi_parse()
235 rsii.minor_status = simple_strtoul(buf, &ep, 10); in rsi_parse()
236 if (*ep) in rsi_parse()
|
| /net/sunrpc/ |
| D | cache.c | 1295 char *ep; in write_flush() local
1302 flushtime = simple_strtoul(tbuf, &ep, 0); in write_flush()
1303 if (*ep && *ep != '\n') in write_flush()
|