/net/tipc/ |
H A D | discover.c | 256 * @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 D | discover.h | 44 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 D | backchannel_rqst.c | 57 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 D | xprt.c | 199 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 D | bc_svc.c | 46 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 D | osd_client.c | 32 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 D | mon_client.c | 391 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 D | debugfs.c | 90 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 D | client.c | 227 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 D | trans_fd.c | 119 * @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 D | request_sock.c | 117 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 D | udp_diag.c | 21 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 D | syncookies.c | 67 __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 D | inet_connection_sock.c | 309 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 D | tcp_minisocks.c | 370 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 D | diag.c | 74 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 D | syncookies.c | 48 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 D | inet6_connection_sock.c | 71 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 D | transport.c | 479 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 D | minisocks.c | 94 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 D | a2mp.c | 127 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 D | diag.c | 57 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 D | ieee802154.h | 43 struct sk_buff *ieee802154_nl_create(int flags, u8 req); 46 int flags, u8 req);
|
H A D | netlink.c | 44 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 D | cmtp.h | 61 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);
|