/net/tipc/ |
D | discover.c | 187 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/ |
D | backchannel_rqst.c | 59 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 …]
|
D | xprt.c | 185 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/ |
D | client.c | 239 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 …]
|
D | trans_fd.c | 130 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/ |
D | osd_client.c | 46 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 …]
|
D | mon_client.c | 486 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/ |
D | hci_request.c | 35 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 …]
|
D | hci_request.h | 38 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 …]
|
D | a2mp.c | 140 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/ |
D | udp_diag.c | 22 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 …]
|
D | inet_connection_sock.c | 302 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 …]
|
D | tcp_minisocks.c | 367 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 …]
|
D | syncookies.c | 79 __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/ |
D | gss_krb5_crypto.c | 65 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/ |
D | scan.c | 271 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/ |
D | diag.c | 74 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/ |
D | transport.c | 484 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 …]
|
D | backchannel.c | 24 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 …]
|
D | rpc_rdma.c | 298 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 …]
|
D | verbs.c | 874 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/ |
D | rxkad.c | 107 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/ |
D | request_sock.c | 97 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/ |
D | minisocks.c | 82 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/ |
D | syncookies.c | 145 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 …]
|