Searched refs:req (Results 1 - 25 of 100) sorted by relevance

1234

/net/tipc/
H A Ddiscover.c256 * @req: ptr to link request structure
261 static void disc_update(struct tipc_link_req *req) argument
263 if (!req->num_nodes) {
264 if ((req->timer_intv == TIPC_LINK_REQ_INACTIVE) ||
265 (req->timer_intv > TIPC_LINK_REQ_FAST)) {
266 req->timer_intv = TIPC_LINK_REQ_INIT;
267 k_start_timer(&req->timer, req->timer_intv);
274 * @req: ptr to link request structure
276 void tipc_disc_add_dest(struct tipc_link_req *req) argument
285 tipc_disc_remove_dest(struct tipc_link_req *req) argument
295 disc_send_msg(struct tipc_link_req *req) argument
307 disc_timeout(struct tipc_link_req *req) argument
352 struct tipc_link_req *req; local
380 tipc_disc_delete(struct tipc_link_req *req) argument
[all...]
H A Ddiscover.h44 void tipc_disc_delete(struct tipc_link_req *req);
45 void tipc_disc_add_dest(struct tipc_link_req *req);
46 void tipc_disc_remove_dest(struct tipc_link_req *req);
/net/sunrpc/
H A Dbackchannel_rqst.c57 static void xprt_free_allocation(struct rpc_rqst *req) argument
61 dprintk("RPC: free allocations for req= %p\n", req);
62 WARN_ON_ONCE(test_bit(RPC_BC_PA_IN_USE, &req->rq_bc_pa_state));
63 xbufp = &req->rq_private_buf;
65 xbufp = &req->rq_snd_buf;
67 list_del(&req->rq_bc_pa_list);
68 kfree(req);
93 struct rpc_rqst *req, *tmp; local
110 req
190 struct rpc_rqst *req = NULL, *tmp = NULL; local
226 struct rpc_rqst *req; local
254 xprt_free_bc_request(struct rpc_rqst *req) argument
[all...]
H A Dxprt.c199 struct rpc_rqst *req = task->tk_rqstp; local
208 if (req != NULL) {
209 req->rq_bytes_sent = 0;
210 req->rq_ntrans++;
220 if (req == NULL)
222 else if (!req->rq_ntrans)
252 struct rpc_rqst *req = task->tk_rqstp; local
260 if (req == NULL) {
266 req->rq_bytes_sent = 0;
267 req
299 struct rpc_rqst *req; local
323 struct rpc_rqst *req; local
398 struct rpc_rqst *req = task->tk_rqstp; local
416 __xprt_put_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) argument
433 struct rpc_rqst *req = task->tk_rqstp; local
449 struct rpc_rqst *req = task->tk_rqstp; local
497 struct rpc_rqst *req = task->tk_rqstp; local
548 struct rpc_rqst *req = task->tk_rqstp; local
558 xprt_reset_majortimeo(struct rpc_rqst *req) argument
577 xprt_adjust_timeout(struct rpc_rqst *req) argument
787 struct rpc_rqst *req = task->tk_rqstp; local
808 struct rpc_rqst *req = task->tk_rqstp; local
831 struct rpc_rqst *req = task->tk_rqstp; local
859 struct rpc_rqst *req = task->tk_rqstp; local
890 struct rpc_rqst *req = task->tk_rqstp; local
981 struct rpc_rqst *req = ERR_PTR(-EAGAIN); local
994 xprt_dynamic_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) argument
1005 struct rpc_rqst *req; local
1052 xprt_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) argument
1065 struct rpc_rqst *req; local
1078 struct rpc_rqst *req; local
1181 struct rpc_rqst *req = task->tk_rqstp; local
1203 struct rpc_rqst *req = task->tk_rqstp; local
[all...]
H A Dbc_svc.c46 int bc_send(struct rpc_rqst *req) argument
51 dprintk("RPC: bc_send req= %p\n", req);
52 task = rpc_run_bc_task(req, &nfs41_callback_ops);
/net/ceph/
H A Dosd_client.c32 struct ceph_osd_request *req);
34 struct ceph_osd_request *req);
36 struct ceph_osd_request *req);
302 struct ceph_osd_request *req; local
305 req = container_of(kref, struct ceph_osd_request, r_kref);
306 if (req->r_request)
307 ceph_msg_put(req->r_request);
308 if (req->r_reply) {
309 ceph_msg_revoke_incoming(req->r_reply);
310 ceph_msg_put(req
331 struct ceph_osd_request *req; local
611 osd_req_encode_op(struct ceph_osd_request *req, struct ceph_osd_op *dst, unsigned int which) argument
710 struct ceph_osd_request *req; local
773 struct ceph_osd_request *req = NULL; local
793 struct ceph_osd_request *req; local
812 struct ceph_osd_request *req; local
836 struct ceph_osd_request *req, *nreq; local
1036 struct ceph_osd_request *req; local
1108 __register_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1126 __unregister_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1165 __cancel_request(struct ceph_osd_request *req) argument
1173 __register_linger_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1183 __unregister_linger_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1201 ceph_osdc_unregister_linger_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1214 ceph_osdc_set_request_linger(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1239 __map_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req, int force_resend) argument
1317 __send_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
1356 struct ceph_osd_request *req, *tmp; local
1376 struct ceph_osd_request *req; local
1434 complete_request(struct ceph_osd_request *req) argument
1449 struct ceph_osd_request *req; local
1613 struct ceph_osd_request *req, *nreq; local
2018 ceph_osdc_build_request(struct ceph_osd_request *req, u64 off, struct ceph_snap_context *snapc, u64 snap_id, struct timespec *mtime) argument
2115 ceph_osdc_start_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req, bool nofail) argument
2153 ceph_osdc_wait_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument
2179 struct ceph_osd_request *req; local
2299 struct ceph_osd_request *req; local
2342 struct ceph_osd_request *req; local
2437 struct ceph_osd_request *req; local
[all...]
H A Dmon_client.c391 struct ceph_mon_generic_request *req; local
395 req = rb_entry(n, struct ceph_mon_generic_request, node);
396 if (tid < req->tid)
398 else if (tid > req->tid)
401 return req;
411 struct ceph_mon_generic_request *req = NULL; local
415 req = rb_entry(parent, struct ceph_mon_generic_request, node);
416 if (new->tid < req->tid)
418 else if (new->tid > req->tid)
430 struct ceph_mon_generic_request *req local
441 put_generic_request(struct ceph_mon_generic_request *req) argument
446 get_generic_request(struct ceph_mon_generic_request *req) argument
456 struct ceph_mon_generic_request *req; local
480 do_generic_request(struct ceph_mon_client *monc, struct ceph_mon_generic_request *req) argument
512 struct ceph_mon_generic_request *req; local
544 struct ceph_mon_generic_request *req; local
604 struct ceph_mon_generic_request *req; local
644 struct ceph_mon_generic_request *req; local
709 struct ceph_mon_generic_request *req; local
[all...]
H A Ddebugfs.c90 struct ceph_mon_generic_request *req; local
105 req = rb_entry(rp, struct ceph_mon_generic_request, node);
106 op = le16_to_cpu(req->request->hdr.type);
108 seq_printf(s, "%lld statfs\n", req->tid);
110 seq_printf(s, "%lld unknown\n", req->tid);
125 struct ceph_osd_request *req; local
129 req = rb_entry(p, struct ceph_osd_request, r_node);
131 seq_printf(s, "%lld\tosd%d\t%lld.%x\t", req->r_tid,
132 req->r_osd ? req
[all...]
/net/9p/
H A Dclient.c227 struct p9_req_t *req; local
258 req = &c->reqs[row][col];
259 if (!req->tc) {
260 req->wq = kmalloc(sizeof(wait_queue_head_t), GFP_NOFS);
261 if (!req->wq) {
265 init_waitqueue_head(req->wq);
266 req->tc = kmalloc(sizeof(struct p9_fcall) + alloc_msize,
268 req->rc = kmalloc(sizeof(struct p9_fcall) + alloc_msize,
270 if ((!req->tc) || (!req
410 p9_client_cb(struct p9_client *c, struct p9_req_t *req) argument
478 p9_check_errors(struct p9_client *c, struct p9_req_t *req) argument
541 p9_check_zc_errors(struct p9_client *c, struct p9_req_t *req, char *uidata, int in_hdrlen, int kern_buf) argument
636 struct p9_req_t *req; local
667 struct p9_req_t *req; local
718 struct p9_req_t *req; local
804 struct p9_req_t *req; local
918 struct p9_req_t *req; local
1087 struct p9_req_t *req; local
1137 struct p9_req_t *req; local
1212 struct p9_req_t *req; local
1258 struct p9_req_t *req; local
1303 struct p9_req_t *req; local
1348 struct p9_req_t *req; local
1380 struct p9_req_t *req; local
1400 struct p9_req_t *req; local
1426 struct p9_req_t *req; local
1470 struct p9_req_t *req; local
1497 struct p9_req_t *req; local
1523 struct p9_req_t *req; local
1601 struct p9_req_t *req; local
1662 struct p9_req_t *req; local
1715 struct p9_req_t *req; local
1801 struct p9_req_t *req; local
1838 struct p9_req_t *req; local
1870 struct p9_req_t *req; local
1910 struct p9_req_t *req; local
1938 struct p9_req_t *req; local
1971 struct p9_req_t *req; local
2018 struct p9_req_t *req; local
2043 struct p9_req_t *req; local
2103 struct p9_req_t *req; local
2134 struct p9_req_t *req; local
2164 struct p9_req_t *req; local
2197 struct p9_req_t *req; local
2231 struct p9_req_t *req; local
[all...]
H A Dtrans_fd.c119 * @req: current request being processed (if any)
142 struct p9_req_t *req; member in struct:p9_conn
192 struct p9_req_t *req, *rtmp; local
207 list_for_each_entry_safe(req, rtmp, &m->req_list, req_list) {
208 req->status = REQ_STATUS_ERROR;
209 if (!req->t_err)
210 req->t_err = err;
211 list_move(&req->req_list, &cancel_list);
213 list_for_each_entry_safe(req, rtmp, &m->unsent_req_list, req_list) {
214 req
446 struct p9_req_t *req; local
661 p9_fd_request(struct p9_client *client, struct p9_req_t *req) argument
688 p9_fd_cancel(struct p9_client *client, struct p9_req_t *req) argument
[all...]
/net/core/
H A Drequest_sock.c117 struct request_sock *req; local
119 while ((req = lopt->syn_table[i]) != NULL) {
120 lopt->syn_table[i] = req->dl_next;
122 reqsk_free(req);
144 * until 3WHS is either completed or aborted. Afterwards the req will stay
150 * When a child socket is accepted, its corresponding req->sk is set to
151 * NULL since it's no longer needed. More importantly, "req->sk == NULL"
157 * with its socket lock held. But a request_sock (req) can be accessed by
175 * When a TFO req is created, it needs to sock_hold its listener to prevent
182 void reqsk_fastopen_remove(struct sock *sk, struct request_sock *req, argument
[all...]
/net/ipv4/
H A Dudp_diag.c21 struct netlink_callback *cb, struct inet_diag_req_v2 *req,
27 return inet_sk_diag_fill(sk, NULL, skb, req,
34 const struct nlmsghdr *nlh, struct inet_diag_req_v2 *req)
41 if (req->sdiag_family == AF_INET)
43 req->id.idiag_src[0], req->id.idiag_sport,
44 req->id.idiag_dst[0], req->id.idiag_dport,
45 req->id.idiag_if, tbl);
47 else if (req
20 sk_diag_dump(struct sock *sk, struct sk_buff *skb, struct netlink_callback *cb, struct inet_diag_req_v2 *req, struct nlattr *bc) argument
33 udp_dump_one(struct udp_table *tbl, struct sk_buff *in_skb, const struct nlmsghdr *nlh, struct inet_diag_req_v2 *req) argument
150 udp_diag_dump_one(struct sk_buff *in_skb, const struct nlmsghdr *nlh, struct inet_diag_req_v2 *req) argument
176 udplite_diag_dump_one(struct sk_buff *in_skb, const struct nlmsghdr *nlh, struct inet_diag_req_v2 *req) argument
[all...]
H A Dsyncookies.c67 __u32 cookie_init_timestamp(struct request_sock *req) argument
73 ireq = inet_rsk(req);
209 struct request_sock *req,
215 child = icsk->icsk_af_ops->syn_recv_sock(sk, skb, req, dst);
217 inet_csk_reqsk_queue_add(sk, req, child);
219 reqsk_free(req);
276 struct request_sock *req; local
302 req = inet_reqsk_alloc(&tcp_request_sock_ops); /* for safety */
303 if (!req)
306 ireq = inet_rsk(req);
208 get_cookie_sock(struct sock *sk, struct sk_buff *skb, struct request_sock *req, struct dst_entry *dst) argument
[all...]
H A Dinet_connection_sock.c309 struct request_sock *req; local
334 req = reqsk_queue_remove(queue);
335 newsk = req->sk;
340 if (tcp_rsk(req)->listener) {
342 * so can't free req now. Instead, we set req->sk to
344 * so reqsk_fastopen_remove() will free the req
347 req->sk = NULL;
348 req = NULL;
354 if (req)
410 inet_csk_route_req(struct sock *sk, struct flowi4 *fl4, const struct request_sock *req) argument
443 inet_csk_route_child_sock(struct sock *sk, struct sock *newsk, const struct request_sock *req) argument
501 struct request_sock *req, **prev; local
523 inet_csk_reqsk_queue_hash_add(struct sock *sk, struct request_sock *req, unsigned long timeout) argument
541 syn_ack_recalc(struct request_sock *req, const int thresh, const int max_retries, const u8 rskq_defer_accept, int *expire, int *resend) argument
562 inet_rtx_syn_ack(struct sock *parent, struct request_sock *req) argument
583 struct request_sock **reqp, *req; local
676 inet_csk_clone_lock(const struct sock *sk, const struct request_sock *req, const gfp_t priority) argument
798 struct request_sock *req; local
[all...]
H A Dtcp_minisocks.c370 struct request_sock *req)
372 tp->ecn_flags = inet_rsk(req)->ecn_ok ? TCP_ECN_OK : 0;
381 struct sock *tcp_create_openreq_child(struct sock *sk, struct request_sock *req, struct sk_buff *skb) argument
383 struct sock *newsk = inet_csk_clone_lock(sk, req, GFP_ATOMIC);
386 const struct inet_request_sock *ireq = inet_rsk(req);
387 struct tcp_request_sock *treq = tcp_rsk(req);
450 newtp->window_clamp = req->window_clamp;
451 newtp->rcv_ssthresh = req->rcv_wnd;
452 newtp->rcv_wnd = req->rcv_wnd;
466 newtp->rx_opt.ts_recent = req
369 TCP_ECN_openreq_child(struct tcp_sock *tp, struct request_sock *req) argument
503 tcp_check_req(struct sock *sk, struct sk_buff *skb, struct request_sock *req, struct request_sock **prev, bool fastopen) argument
[all...]
/net/unix/
H A Ddiag.c74 struct sock *req, *peer; local
76 req = skb->sk;
82 unix_state_lock_nested(req);
83 peer = unix_sk(req)->peer;
85 unix_state_unlock(req);
112 static int sk_diag_fill(struct sock *sk, struct sk_buff *skb, struct unix_diag_req *req, argument
130 if ((req->udiag_show & UDIAG_SHOW_NAME) &&
134 if ((req->udiag_show & UDIAG_SHOW_VFS) &&
138 if ((req->udiag_show & UDIAG_SHOW_PEER) &&
142 if ((req
164 sk_diag_dump(struct sock *sk, struct sk_buff *skb, struct unix_diag_req *req, u32 portid, u32 seq, u32 flags) argument
181 struct unix_diag_req *req; local
241 unix_diag_get_exact(struct sk_buff *in_skb, const struct nlmsghdr *nlh, struct unix_diag_req *req) argument
[all...]
/net/ipv6/
H A Dsyncookies.c48 struct request_sock *req,
54 child = icsk->icsk_af_ops->syn_recv_sock(sk, skb, req, dst);
56 inet_csk_reqsk_queue_add(sk, req, child);
58 reqsk_free(req);
160 struct request_sock *req; local
185 req = inet6_reqsk_alloc(&tcp6_request_sock_ops);
186 if (!req)
189 ireq = inet_rsk(req);
190 ireq6 = inet6_rsk(req);
191 treq = tcp_rsk(req);
47 get_cookie_sock(struct sock *sk, struct sk_buff *skb, struct request_sock *req, struct dst_entry *dst) argument
[all...]
H A Dinet6_connection_sock.c71 const struct request_sock *req)
73 struct inet6_request_sock *treq = inet6_rsk(req);
84 fl6->flowi6_mark = inet_rsk(req)->ir_mark;
85 fl6->fl6_dport = inet_rsk(req)->rmt_port;
86 fl6->fl6_sport = inet_rsk(req)->loc_port;
88 security_req_classify_flow(req, flowi6_to_flowi(fl6));
126 struct request_sock *req, **prev; local
131 (req = *prev) != NULL;
132 prev = &req->dl_next) {
133 const struct inet6_request_sock *treq = inet6_rsk(req);
69 inet6_csk_route_req(struct sock *sk, struct flowi6 *fl6, const struct request_sock *req) argument
151 inet6_csk_reqsk_queue_hash_add(struct sock *sk, struct request_sock *req, const unsigned long timeout) argument
[all...]
/net/sunrpc/xprtrdma/
H A Dtransport.c479 struct rpcrdma_req *req, *nreq; local
481 req = rpcrdma_buffer_get(&rpcx_to_rdmax(xprt)->rx_buf);
482 BUG_ON(NULL == req);
484 if (size > req->rl_size) {
487 __func__, size, req->rl_size,
513 size = req->rl_size;
519 nreq = kmalloc(sizeof *req + size, GFP_ATOMIC);
521 nreq = kmalloc(sizeof *req + size, GFP_NOFS);
536 nreq->rl_buffer = (struct rpcrdma_buffer *)req;
537 nreq->rl_reply = req
562 struct rpcrdma_req *req; local
631 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); local
[all...]
/net/dccp/
H A Dminisocks.c94 const struct request_sock *req,
103 struct sock *newsk = inet_csk_clone_lock(sk, req, GFP_ATOMIC);
106 struct dccp_request_sock *dreq = dccp_rsk(req);
160 struct request_sock *req,
164 struct dccp_request_sock *dreq = dccp_rsk(req);
177 inet_rtx_syn_ack(sk, req);
204 child = inet_csk(sk)->icsk_af_ops->syn_recv_sock(sk, skb, req, NULL);
208 inet_csk_reqsk_queue_unlink(sk, req, prev);
209 inet_csk_reqsk_queue_removed(sk, req);
210 inet_csk_reqsk_queue_add(sk, req, chil
93 dccp_create_openreq_child(struct sock *sk, const struct request_sock *req, const struct sk_buff *skb) argument
159 dccp_check_req(struct sock *sk, struct sk_buff *skb, struct request_sock *req, struct request_sock **prev) argument
267 dccp_reqsk_init(struct request_sock *req, struct dccp_sock const *dp, struct sk_buff const *skb) argument
[all...]
/net/bluetooth/
H A Da2mp.c127 struct a2mp_discov_req *req = (void *) skb->data; local
133 if (len < sizeof(*req))
136 skb_pull(skb, sizeof(*req));
138 ext_feat = le16_to_cpu(req->ext_feat);
140 BT_DBG("mtu %d efm 0x%4.4x", le16_to_cpu(req->mtu), ext_feat);
212 struct a2mp_info_req req; local
215 req.id = cl->id;
217 sizeof(req), &req);
272 struct a2mp_info_req *req local
308 struct a2mp_amp_assoc_req req; local
334 struct a2mp_amp_assoc_req *req = (void *) skb->data; local
438 struct a2mp_physlink_req *req = (void *) skb->data; local
518 struct a2mp_physlink_req *req = (void *) skb->data; local
925 struct a2mp_physlink_req *req; local
988 struct a2mp_discov_req req; local
[all...]
/net/netlink/
H A Ddiag.c57 struct netlink_diag_req *req,
81 if ((req->ndiag_show & NDIAG_SHOW_GROUPS) &&
85 if ((req->ndiag_show & NDIAG_SHOW_MEMINFO) &&
89 if ((req->ndiag_show & NDIAG_SHOW_RING_CFG) &&
106 struct netlink_diag_req *req; local
110 req = nlmsg_data(cb->nlh);
121 if (sk_diag_fill(sk, skb, req,
144 if (sk_diag_fill(sk, skb, req,
163 struct netlink_diag_req *req; local
166 req
56 sk_diag_fill(struct sock *sk, struct sk_buff *skb, struct netlink_diag_req *req, u32 portid, u32 seq, u32 flags, int sk_ino) argument
[all...]
/net/ieee802154/
H A Dieee802154.h43 struct sk_buff *ieee802154_nl_create(int flags, u8 req);
46 int flags, u8 req);
H A Dnetlink.c44 struct sk_buff *ieee802154_nl_create(int flags, u8 req) argument
55 &nl802154_family, flags, req);
80 int flags, u8 req)
89 &nl802154_family, flags, req);
79 ieee802154_nl_new_reply(struct genl_info *info, int flags, u8 req) argument
/net/bluetooth/cmtp/
H A Dcmtp.h61 int cmtp_add_connection(struct cmtp_connadd_req *req, struct socket *sock);
62 int cmtp_del_connection(struct cmtp_conndel_req *req);
63 int cmtp_get_connlist(struct cmtp_connlist_req *req);

Completed in 388 milliseconds

1234