Home
last modified time | relevance | path

Searched refs:req (Results 1 – 25 of 121) sorted by relevance

12345

/net/tipc/
Ddiscover.c187 static void disc_update(struct tipc_link_req *req) in disc_update() argument
189 if (!req->num_nodes) { in disc_update()
190 if ((req->timer_intv == TIPC_LINK_REQ_INACTIVE) || in disc_update()
191 (req->timer_intv > TIPC_LINK_REQ_FAST)) { in disc_update()
192 req->timer_intv = TIPC_LINK_REQ_INIT; in disc_update()
193 mod_timer(&req->timer, jiffies + req->timer_intv); in disc_update()
202 void tipc_disc_add_dest(struct tipc_link_req *req) in tipc_disc_add_dest() argument
204 spin_lock_bh(&req->lock); in tipc_disc_add_dest()
205 req->num_nodes++; in tipc_disc_add_dest()
206 spin_unlock_bh(&req->lock); in tipc_disc_add_dest()
[all …]
/net/sunrpc/
Dbackchannel_rqst.c59 static void xprt_free_allocation(struct rpc_rqst *req) in xprt_free_allocation() argument
63 dprintk("RPC: free allocations for req= %p\n", req); in xprt_free_allocation()
64 WARN_ON_ONCE(test_bit(RPC_BC_PA_IN_USE, &req->rq_bc_pa_state)); in xprt_free_allocation()
65 xbufp = &req->rq_rcv_buf; in xprt_free_allocation()
67 xbufp = &req->rq_snd_buf; in xprt_free_allocation()
69 kfree(req); in xprt_free_allocation()
86 struct rpc_rqst *req; in xprt_alloc_bc_req() local
89 req = kzalloc(sizeof(*req), gfp_flags); in xprt_alloc_bc_req()
90 if (req == NULL) in xprt_alloc_bc_req()
93 req->rq_xprt = xprt; in xprt_alloc_bc_req()
[all …]
Dxprt.c185 struct rpc_rqst *req = task->tk_rqstp; in xprt_reserve_xprt() local
194 if (req != NULL) in xprt_reserve_xprt()
195 req->rq_ntrans++; in xprt_reserve_xprt()
204 if (req == NULL) in xprt_reserve_xprt()
206 else if (!req->rq_ntrans) in xprt_reserve_xprt()
236 struct rpc_rqst *req = task->tk_rqstp; in xprt_reserve_xprt_cong() local
244 if (req == NULL) { in xprt_reserve_xprt_cong()
250 req->rq_ntrans++; in xprt_reserve_xprt_cong()
255 if (req) in xprt_reserve_xprt_cong()
256 __xprt_put_cong(xprt, req); in xprt_reserve_xprt_cong()
[all …]
/net/9p/
Dclient.c239 struct p9_req_t *req; in p9_tag_alloc() local
270 req = &c->reqs[row][col]; in p9_tag_alloc()
271 if (!req->wq) { in p9_tag_alloc()
272 req->wq = kmalloc(sizeof(wait_queue_head_t), GFP_NOFS); in p9_tag_alloc()
273 if (!req->wq) in p9_tag_alloc()
275 init_waitqueue_head(req->wq); in p9_tag_alloc()
278 if (!req->tc) in p9_tag_alloc()
279 req->tc = p9_fcall_alloc(alloc_msize); in p9_tag_alloc()
280 if (!req->rc) in p9_tag_alloc()
281 req->rc = p9_fcall_alloc(alloc_msize); in p9_tag_alloc()
[all …]
Dtrans_fd.c130 struct p9_req_t *req; member
195 struct p9_req_t *req, *rtmp; in p9_conn_cancel() local
210 list_for_each_entry_safe(req, rtmp, &m->req_list, req_list) { in p9_conn_cancel()
211 list_move(&req->req_list, &cancel_list); in p9_conn_cancel()
213 list_for_each_entry_safe(req, rtmp, &m->unsent_req_list, req_list) { in p9_conn_cancel()
214 list_move(&req->req_list, &cancel_list); in p9_conn_cancel()
218 list_for_each_entry_safe(req, rtmp, &cancel_list, req_list) { in p9_conn_cancel()
219 p9_debug(P9_DEBUG_ERROR, "call back req %p\n", req); in p9_conn_cancel()
220 list_del(&req->req_list); in p9_conn_cancel()
221 if (!req->t_err) in p9_conn_cancel()
[all …]
/net/ceph/
Dosd_client.c46 static void link_request(struct ceph_osd *osd, struct ceph_osd_request *req);
47 static void unlink_request(struct ceph_osd *osd, struct ceph_osd_request *req);
401 static void request_release_checks(struct ceph_osd_request *req) in request_release_checks() argument
403 WARN_ON(!RB_EMPTY_NODE(&req->r_node)); in request_release_checks()
404 WARN_ON(!RB_EMPTY_NODE(&req->r_mc_node)); in request_release_checks()
405 WARN_ON(!list_empty(&req->r_unsafe_item)); in request_release_checks()
406 WARN_ON(req->r_osd); in request_release_checks()
411 struct ceph_osd_request *req = container_of(kref, in ceph_osdc_release_request() local
415 dout("%s %p (r_request %p r_reply %p)\n", __func__, req, in ceph_osdc_release_request()
416 req->r_request, req->r_reply); in ceph_osdc_release_request()
[all …]
Dmon_client.c486 struct ceph_mon_generic_request *req = in DEFINE_RB_FUNCS() local
489 dout("%s greq %p request %p reply %p\n", __func__, req, req->request, in DEFINE_RB_FUNCS()
490 req->reply); in DEFINE_RB_FUNCS()
491 WARN_ON(!RB_EMPTY_NODE(&req->node)); in DEFINE_RB_FUNCS()
493 if (req->reply) in DEFINE_RB_FUNCS()
494 ceph_msg_put(req->reply); in DEFINE_RB_FUNCS()
495 if (req->request) in DEFINE_RB_FUNCS()
496 ceph_msg_put(req->request); in DEFINE_RB_FUNCS()
498 kfree(req); in DEFINE_RB_FUNCS()
501 static void put_generic_request(struct ceph_mon_generic_request *req) in put_generic_request() argument
[all …]
/net/bluetooth/
Dhci_request.c35 void hci_req_init(struct hci_request *req, struct hci_dev *hdev) in hci_req_init() argument
37 skb_queue_head_init(&req->cmd_q); in hci_req_init()
38 req->hdev = hdev; in hci_req_init()
39 req->err = 0; in hci_req_init()
42 static int req_run(struct hci_request *req, hci_req_complete_t complete, in req_run() argument
45 struct hci_dev *hdev = req->hdev; in req_run()
49 BT_DBG("length %u", skb_queue_len(&req->cmd_q)); in req_run()
54 if (req->err) { in req_run()
55 skb_queue_purge(&req->cmd_q); in req_run()
56 return req->err; in req_run()
[all …]
Dhci_request.h38 void hci_req_init(struct hci_request *req, struct hci_dev *hdev);
39 int hci_req_run(struct hci_request *req, hci_req_complete_t complete);
40 int hci_req_run_skb(struct hci_request *req, hci_req_complete_skb_t complete);
41 void hci_req_add(struct hci_request *req, u16 opcode, u32 plen,
43 void hci_req_add_ev(struct hci_request *req, u16 opcode, u32 plen,
49 int hci_req_sync(struct hci_dev *hdev, int (*req)(struct hci_request *req,
52 int __hci_req_sync(struct hci_dev *hdev, int (*func)(struct hci_request *req,
62 void __hci_req_write_fast_connectable(struct hci_request *req, bool enable);
63 void __hci_req_update_name(struct hci_request *req);
64 void __hci_req_update_eir(struct hci_request *req);
[all …]
Da2mp.c140 struct a2mp_discov_req *req = (void *) skb->data; in a2mp_discover_req() local
147 if (len < sizeof(*req)) in a2mp_discover_req()
150 skb_pull(skb, sizeof(*req)); in a2mp_discover_req()
152 ext_feat = le16_to_cpu(req->ext_feat); in a2mp_discover_req()
154 BT_DBG("mtu %d efm 0x%4.4x", le16_to_cpu(req->mtu), ext_feat); in a2mp_discover_req()
233 struct a2mp_info_req req; in a2mp_discover_rsp() local
236 req.id = cl->id; in a2mp_discover_rsp()
238 sizeof(req), &req); in a2mp_discover_rsp()
301 struct a2mp_info_req *req = (void *) skb->data; in a2mp_getinfo_req() local
306 if (le16_to_cpu(hdr->len) < sizeof(*req)) in a2mp_getinfo_req()
[all …]
/net/ipv4/
Dudp_diag.c22 const struct inet_diag_req_v2 *req, in sk_diag_dump() argument
28 return inet_sk_diag_fill(sk, NULL, skb, req, in sk_diag_dump()
36 const struct inet_diag_req_v2 *req) in udp_dump_one() argument
44 if (req->sdiag_family == AF_INET) in udp_dump_one()
46 req->id.idiag_src[0], req->id.idiag_sport, in udp_dump_one()
47 req->id.idiag_dst[0], req->id.idiag_dport, in udp_dump_one()
48 req->id.idiag_if, tbl, NULL); in udp_dump_one()
50 else if (req->sdiag_family == AF_INET6) in udp_dump_one()
52 (struct in6_addr *)req->id.idiag_src, in udp_dump_one()
53 req->id.idiag_sport, in udp_dump_one()
[all …]
Dinet_connection_sock.c302 struct request_sock *req; in inet_csk_accept() local
328 req = reqsk_queue_remove(queue, sk); in inet_csk_accept()
329 newsk = req->sk; in inet_csk_accept()
332 tcp_rsk(req)->tfo_listener) { in inet_csk_accept()
334 if (tcp_rsk(req)->tfo_listener) { in inet_csk_accept()
341 req->sk = NULL; in inet_csk_accept()
342 req = NULL; in inet_csk_accept()
348 if (req) in inet_csk_accept()
349 reqsk_put(req); in inet_csk_accept()
353 req = NULL; in inet_csk_accept()
[all …]
Dtcp_minisocks.c367 void tcp_openreq_init_rwin(struct request_sock *req, in tcp_openreq_init_rwin() argument
371 struct inet_request_sock *ireq = inet_rsk(req); in tcp_openreq_init_rwin()
384 req->rsk_window_clamp = window_clamp ? : dst_metric(dst, RTAX_WINDOW); in tcp_openreq_init_rwin()
388 (req->rsk_window_clamp > full_space || req->rsk_window_clamp == 0)) in tcp_openreq_init_rwin()
389 req->rsk_window_clamp = full_space; in tcp_openreq_init_rwin()
394 &req->rsk_rcv_wnd, in tcp_openreq_init_rwin()
395 &req->rsk_window_clamp, in tcp_openreq_init_rwin()
404 const struct request_sock *req) in tcp_ecn_openreq_child() argument
406 tp->ecn_flags = inet_rsk(req)->ecn_ok ? TCP_ECN_OK : 0; in tcp_ecn_openreq_child()
445 struct request_sock *req, in tcp_create_openreq_child() argument
[all …]
Dsyncookies.c79 __u32 cookie_init_timestamp(struct request_sock *req) in cookie_init_timestamp() argument
85 ireq = inet_rsk(req); in cookie_init_timestamp()
216 struct request_sock *req, in tcp_get_cookie_sock() argument
223 child = icsk->icsk_af_ops->syn_recv_sock(sk, skb, req, dst, in tcp_get_cookie_sock()
226 atomic_set(&req->rsk_refcnt, 1); in tcp_get_cookie_sock()
228 inet_csk_reqsk_queue_add(sk, req, child); in tcp_get_cookie_sock()
230 reqsk_free(req); in tcp_get_cookie_sock()
301 struct request_sock *req; in cookie_v4_check() local
329 req = inet_reqsk_alloc(&tcp_request_sock_ops, sk, false); /* for safety */ in cookie_v4_check()
330 if (!req) in cookie_v4_check()
[all …]
/net/sunrpc/auth_gss/
Dgss_krb5_crypto.c65 SKCIPHER_REQUEST_ON_STACK(req, tfm); in krb5_encrypt()
82 skcipher_request_set_tfm(req, tfm); in krb5_encrypt()
83 skcipher_request_set_callback(req, 0, NULL, NULL); in krb5_encrypt()
84 skcipher_request_set_crypt(req, sg, sg, length, local_iv); in krb5_encrypt()
86 ret = crypto_skcipher_encrypt(req); in krb5_encrypt()
87 skcipher_request_zero(req); in krb5_encrypt()
104 SKCIPHER_REQUEST_ON_STACK(req, tfm); in krb5_decrypt()
120 skcipher_request_set_tfm(req, tfm); in krb5_decrypt()
121 skcipher_request_set_callback(req, 0, NULL, NULL); in krb5_decrypt()
122 skcipher_request_set_crypt(req, sg, sg, length, local_iv); in krb5_decrypt()
[all …]
/net/mac80211/
Dscan.c271 struct cfg80211_scan_request *req; in ieee80211_prep_hw_scan() local
276 req = rcu_dereference_protected(local->scan_req, in ieee80211_prep_hw_scan()
283 for (i = 0; i < req->n_channels; i++) { in ieee80211_prep_hw_scan()
284 local->hw_scan_req->req.channels[i] = req->channels[i]; in ieee80211_prep_hw_scan()
285 bands_used |= BIT(req->channels[i]->band); in ieee80211_prep_hw_scan()
288 n_chans = req->n_channels; in ieee80211_prep_hw_scan()
296 for (i = 0; i < req->n_channels; i++) { in ieee80211_prep_hw_scan()
297 if (req->channels[i]->band != in ieee80211_prep_hw_scan()
300 local->hw_scan_req->req.channels[n_chans] = in ieee80211_prep_hw_scan()
301 req->channels[i]; in ieee80211_prep_hw_scan()
[all …]
/net/unix/
Ddiag.c74 struct sock *req, *peer; in sk_diag_dump_icons() local
76 req = skb->sk; in sk_diag_dump_icons()
82 unix_state_lock_nested(req); in sk_diag_dump_icons()
83 peer = unix_sk(req)->peer; in sk_diag_dump_icons()
85 unix_state_unlock(req); in sk_diag_dump_icons()
112 static int sk_diag_fill(struct sock *sk, struct sk_buff *skb, struct unix_diag_req *req, in sk_diag_fill() argument
131 if ((req->udiag_show & UDIAG_SHOW_NAME) && in sk_diag_fill()
135 if ((req->udiag_show & UDIAG_SHOW_VFS) && in sk_diag_fill()
139 if ((req->udiag_show & UDIAG_SHOW_PEER) && in sk_diag_fill()
143 if ((req->udiag_show & UDIAG_SHOW_ICONS) && in sk_diag_fill()
[all …]
/net/sunrpc/xprtrdma/
Dtransport.c484 rpcrdma_get_rdmabuf(struct rpcrdma_xprt *r_xprt, struct rpcrdma_req *req, in rpcrdma_get_rdmabuf() argument
490 if (req->rl_rdmabuf) in rpcrdma_get_rdmabuf()
498 req->rl_rdmabuf = rb; in rpcrdma_get_rdmabuf()
503 rpcrdma_get_sendbuf(struct rpcrdma_xprt *r_xprt, struct rpcrdma_req *req, in rpcrdma_get_sendbuf() argument
508 if (req->rl_sendbuf && rdmab_length(req->rl_sendbuf) >= size) in rpcrdma_get_sendbuf()
515 rpcrdma_free_regbuf(req->rl_sendbuf); in rpcrdma_get_sendbuf()
517 req->rl_sendbuf = rb; in rpcrdma_get_sendbuf()
533 rpcrdma_get_recvbuf(struct rpcrdma_xprt *r_xprt, struct rpcrdma_req *req, in rpcrdma_get_recvbuf() argument
538 if (req->rl_recvbuf && rdmab_length(req->rl_recvbuf) >= size) in rpcrdma_get_recvbuf()
545 rpcrdma_free_regbuf(req->rl_recvbuf); in rpcrdma_get_recvbuf()
[all …]
Dbackchannel.c24 struct rpcrdma_req *req = rpcr_to_rdmar(rqst); in rpcrdma_bc_free_rqst() local
27 list_del(&req->rl_all); in rpcrdma_bc_free_rqst()
30 rpcrdma_destroy_req(req); in rpcrdma_bc_free_rqst()
39 struct rpcrdma_req *req; in rpcrdma_bc_setup_rqst() local
42 req = rpcrdma_create_req(r_xprt); in rpcrdma_bc_setup_rqst()
43 if (IS_ERR(req)) in rpcrdma_bc_setup_rqst()
44 return PTR_ERR(req); in rpcrdma_bc_setup_rqst()
45 req->rl_backchannel = true; in rpcrdma_bc_setup_rqst()
51 req->rl_rdmabuf = rb; in rpcrdma_bc_setup_rqst()
57 req->rl_sendbuf = rb; in rpcrdma_bc_setup_rqst()
[all …]
Drpc_rdma.c298 struct rpcrdma_req *req, struct rpc_rqst *rqst, in rpcrdma_encode_read_list() argument
314 seg = req->rl_segments; in rpcrdma_encode_read_list()
325 list_add(&mw->mw_list, &req->rl_registered); in rpcrdma_encode_read_list()
363 rpcrdma_encode_write_list(struct rpcrdma_xprt *r_xprt, struct rpcrdma_req *req, in rpcrdma_encode_write_list() argument
377 seg = req->rl_segments; in rpcrdma_encode_write_list()
393 list_add(&mw->mw_list, &req->rl_registered); in rpcrdma_encode_write_list()
431 struct rpcrdma_req *req, struct rpc_rqst *rqst, in rpcrdma_encode_reply_chunk() argument
444 seg = req->rl_segments; in rpcrdma_encode_reply_chunk()
458 list_add(&mw->mw_list, &req->rl_registered); in rpcrdma_encode_reply_chunk()
483 rpcrdma_prepare_hdr_sge(struct rpcrdma_ia *ia, struct rpcrdma_req *req, in rpcrdma_prepare_hdr_sge() argument
[all …]
Dverbs.c874 struct rpcrdma_req *req; in rpcrdma_create_req() local
876 req = kzalloc(sizeof(*req), GFP_KERNEL); in rpcrdma_create_req()
877 if (req == NULL) in rpcrdma_create_req()
880 INIT_LIST_HEAD(&req->rl_free); in rpcrdma_create_req()
882 list_add(&req->rl_all, &buffer->rb_allreqs); in rpcrdma_create_req()
884 req->rl_cqe.done = rpcrdma_wc_send; in rpcrdma_create_req()
885 req->rl_buffer = &r_xprt->rx_buf; in rpcrdma_create_req()
886 INIT_LIST_HEAD(&req->rl_registered); in rpcrdma_create_req()
887 req->rl_send_wr.next = NULL; in rpcrdma_create_req()
888 req->rl_send_wr.wr_cqe = &req->rl_cqe; in rpcrdma_create_req()
[all …]
/net/rxrpc/
Drxkad.c107 SKCIPHER_REQUEST_ON_STACK(req, conn->cipher); in rxkad_prime_packet_security()
131 skcipher_request_set_tfm(req, conn->cipher); in rxkad_prime_packet_security()
132 skcipher_request_set_callback(req, 0, NULL, NULL); in rxkad_prime_packet_security()
133 skcipher_request_set_crypt(req, &sg, &sg, tmpsize, iv.x); in rxkad_prime_packet_security()
134 crypto_skcipher_encrypt(req); in rxkad_prime_packet_security()
135 skcipher_request_zero(req); in rxkad_prime_packet_security()
152 SKCIPHER_REQUEST_ON_STACK(req, call->conn->cipher); in rxkad_secure_packet_auth()
172 skcipher_request_set_tfm(req, call->conn->cipher); in rxkad_secure_packet_auth()
173 skcipher_request_set_callback(req, 0, NULL, NULL); in rxkad_secure_packet_auth()
174 skcipher_request_set_crypt(req, &sg, &sg, 8, iv.x); in rxkad_secure_packet_auth()
[all …]
/net/core/
Drequest_sock.c97 void reqsk_fastopen_remove(struct sock *sk, struct request_sock *req, in reqsk_fastopen_remove() argument
100 struct sock *lsk = req->rsk_listener; in reqsk_fastopen_remove()
108 tcp_rsk(req)->tfo_listener = false; in reqsk_fastopen_remove()
109 if (req->sk) /* the child socket hasn't been accepted yet */ in reqsk_fastopen_remove()
117 reqsk_put(req); in reqsk_fastopen_remove()
127 req->rsk_timer.expires = jiffies + 60*HZ; in reqsk_fastopen_remove()
129 fastopenq->rskq_rst_head = req; in reqsk_fastopen_remove()
131 fastopenq->rskq_rst_tail->dl_next = req; in reqsk_fastopen_remove()
133 req->dl_next = NULL; in reqsk_fastopen_remove()
134 fastopenq->rskq_rst_tail = req; in reqsk_fastopen_remove()
/net/dccp/
Dminisocks.c82 const struct request_sock *req, in dccp_create_openreq_child() argument
91 struct sock *newsk = inet_csk_clone_lock(sk, req, GFP_ATOMIC); in dccp_create_openreq_child()
94 struct dccp_request_sock *dreq = dccp_rsk(req); in dccp_create_openreq_child()
149 struct request_sock *req) in dccp_check_req() argument
152 struct dccp_request_sock *dreq = dccp_rsk(req); in dccp_check_req()
173 inet_rtx_syn_ack(sk, req); in dccp_check_req()
200 child = inet_csk(sk)->icsk_af_ops->syn_recv_sock(sk, skb, req, NULL, in dccp_check_req()
201 req, &own_req); in dccp_check_req()
203 child = inet_csk_complete_hashdance(sk, child, req, own_req); in dccp_check_req()
210 req->rsk_ops->send_reset(sk, skb); in dccp_check_req()
[all …]
/net/ipv6/
Dsyncookies.c145 struct request_sock *req; in cookie_v6_check() local
172 req = inet_reqsk_alloc(&tcp6_request_sock_ops, sk, false); in cookie_v6_check()
173 if (!req) in cookie_v6_check()
176 ireq = inet_rsk(req); in cookie_v6_check()
177 treq = tcp_rsk(req); in cookie_v6_check()
180 if (security_inet_conn_request(sk, skb, req)) in cookie_v6_check()
183 req->mss = mss; in cookie_v6_check()
203 req->num_retrans = 0; in cookie_v6_check()
208 req->ts_recent = tcp_opt.saw_tstamp ? tcp_opt.rcv_tsval : 0; in cookie_v6_check()
232 security_req_classify_flow(req, flowi6_to_flowi(&fl6)); in cookie_v6_check()
[all …]

12345