Home
last modified time | relevance | path

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

1234567

/net/handshake/
A Drequest.c79 req->hr_proto->hp_destroy(req); in handshake_req_destroy()
82 kfree(req); in handshake_req_destroy()
91 if (!req) in handshake_sk_destruct()
123 if (!req) in handshake_req_alloc()
128 return req; in handshake_req_alloc()
184 req = NULL; in handshake_req_next()
190 req = pos; in handshake_req_next()
195 return req; in handshake_req_next()
239 req->hr_odestruct = req->hr_sk->sk_destruct; in handshake_req_submit()
273 trace_handshake_submit(net, req, req->hr_sk); in handshake_req_submit()
[all …]
A Dtlshd.c288 struct handshake_req *req; in tls_client_hello_anon() local
291 if (!req) in tls_client_hello_anon()
314 struct handshake_req *req; in tls_client_hello_x509() local
317 if (!req) in tls_client_hello_x509()
343 struct handshake_req *req; in tls_client_hello_psk() local
351 if (!req) in tls_client_hello_psk()
377 struct handshake_req *req; in tls_server_hello_x509() local
380 if (!req) in tls_server_hello_x509()
405 struct handshake_req *req; in tls_server_hello_psk() local
408 if (!req) in tls_server_hello_psk()
[all …]
A Dhandshake-test.c167 struct handshake_req *req; in handshake_req_submit_test2() local
172 KUNIT_ASSERT_NOT_NULL(test, req); in handshake_req_submit_test2()
185 struct handshake_req *req; in handshake_req_submit_test3() local
191 KUNIT_ASSERT_NOT_NULL(test, req); in handshake_req_submit_test3()
217 KUNIT_ASSERT_NOT_NULL(test, req); in handshake_req_submit_test4()
243 struct handshake_req *req; in handshake_req_submit_test5() local
252 KUNIT_ASSERT_NOT_NULL(test, req); in handshake_req_submit_test5()
314 struct handshake_req *req; in handshake_req_cancel_test1() local
322 KUNIT_ASSERT_NOT_NULL(test, req); in handshake_req_cancel_test1()
348 struct handshake_req *req, *next; in handshake_req_cancel_test2() local
[all …]
A Dnetlink.c94 struct handshake_req *req = NULL; in handshake_nl_accept_doit() local
108 req = handshake_req_next(hn, class); in handshake_nl_accept_doit()
109 if (!req) in handshake_nl_accept_doit()
112 sock = req->hr_sk->sk_socket; in handshake_nl_accept_doit()
119 err = req->hr_proto->hp_accept(req, info, fd); in handshake_nl_accept_doit()
127 trace_handshake_cmd_accept(net, req, req->hr_sk, fd); in handshake_nl_accept_doit()
131 handshake_complete(req, -EIO, NULL); in handshake_nl_accept_doit()
140 struct handshake_req *req; in handshake_nl_done_doit() local
153 if (!req) { in handshake_nl_done_doit()
198 struct handshake_req *req; in handshake_net_exit() local
[all …]
/net/sunrpc/
A Dbackchannel_rqst.c50 kfree(req); in xprt_free_allocation()
81 req = kzalloc(sizeof(*req), gfp_flags); in xprt_alloc_bc_req()
82 if (req == NULL) in xprt_alloc_bc_req()
85 req->rq_xprt = xprt; in xprt_alloc_bc_req()
99 return req; in xprt_alloc_bc_req()
254 memcpy(&req->rq_private_buf, &req->rq_rcv_buf, in xprt_get_bc_request()
260 return req; in xprt_get_bc_request()
297 req = NULL; in xprt_free_bc_rqst()
340 if (req != new) in xprt_lookup_bc_request()
343 } else if (req) in xprt_lookup_bc_request()
[all …]
A Dxprt.c522 __xprt_put_cong(req->rq_xprt, req); in xprt_release_rqst_cong()
671 req->rq_majortimeo += xprt_calc_majortimeo(req, to); in xprt_reset_majortimeo()
676 req->rq_minortimeo += req->rq_timeout; in xprt_reset_minortimeo()
692 req->rq_minortimeo = time_init + req->rq_timeout; in xprt_init_majortimeo()
1161 memcpy(&req->rq_private_buf, &req->rq_rcv_buf, in xprt_request_enqueue_receive()
1186 xprt_request_rb_remove(req->rq_xprt, req); in xprt_request_dequeue_receive_locked()
1671 memset(req, 0, sizeof(*req)); /* mark unused */ in __xprt_set_rq()
1712 req = kzalloc(sizeof(*req), rpc_task_gfp_mask()); in xprt_dynamic_alloc_slot()
1775 memset(req, 0, sizeof(*req)); /* mark unused */ in xprt_free_slot()
1988 req->rq_release_snd_buf(req); in xprt_release()
[all …]
/net/9p/
A Dclient.c295 if (!req) in p9_tag_alloc()
340 return req; in p9_tag_alloc()
365 if (req) { in p9_tag_lookup()
380 return req; in p9_tag_lookup()
529 if (req->rc.size > req->rc.capacity && !req->rc.zc) { in p9_check_errors()
531 req->rc.size, req->rc.capacity, req->rc.id); in p9_check_errors()
647 return req; in p9_client_prepare_req()
650 p9pdu_prepare(&req->tc, req->tc.tag, type); in p9_client_prepare_req()
656 return req; in p9_client_prepare_req()
694 return req; in p9_client_rpc()
[all …]
A Dtrans_virtio.c132 struct p9_req_t *req; in req_done() local
146 req->rc.size = len; in req_done()
201 p9_req_put(client, req); in p9_virtio_cancelled()
272 VIRTQUEUE_NUM, req->tc.sdata, req->tc.size); in p9_virtio_request()
277 VIRTQUEUE_NUM, req->rc.sdata, req->rc.capacity); in p9_virtio_request()
395 req->rc.size = P9_ZC_HDR_SZ; in handle_rerror()
398 size = req->rc.size - in_hdr_len; in handle_rerror()
448 memcpy(&req->tc.sdata[req->tc.size - 4], &v, 4); in p9_virtio_zc_request()
467 memcpy(&req->tc.sdata[req->tc.size - 4], &v, 4); in p9_virtio_zc_request()
479 VIRTQUEUE_NUM, req->tc.sdata, req->tc.size); in p9_virtio_zc_request()
[all …]
/net/ceph/
A Dosd_client.c490 req->r_request, req->r_reply); in ceph_osdc_release_request()
533 memset(req, 0, sizeof(*req)); in request_init()
661 for (op = req->r_ops; op != &req->r_ops[req->r_num_ops]; op++) { in get_num_data_items()
1456 req, req->r_tid); in link_request()
1475 req, req->r_tid); in unlink_request()
2047 for (op = req->r_ops; op != &req->r_ops[req->r_num_ops]; op++) { in setup_request_data()
2339 __func__, req, req->r_tid, req->r_t.pgid.pool, req->r_t.pgid.seed, in send_request()
2517 req->r_tid, req->r_callback, req->r_result); in __complete_request()
2520 req->r_callback(req); in __complete_request()
2695 req, req->r_tid, req->r_map_dne_bound, map->epoch); in check_pool_dne()
[all …]
A Dmon_client.c595 kfree(req); in DEFINE_RB_FUNCS()
600 if (req) in put_generic_request()
614 req = kzalloc(sizeof(*req), gfp); in alloc_generic_request()
615 if (!req) in alloc_generic_request()
624 return req; in alloc_generic_request()
644 req->request->hdr.tid = cpu_to_le64(req->tid); in send_generic_request()
668 req->complete_cb(req); in complete_generic_request()
717 if (!req) { in get_generic_reply()
781 if (!req) in ceph_monc_do_statfs()
859 if (!req) in __ceph_monc_get_version()
[all …]
/net/ipv4/
A Dudp_diag.c39 if (req->sdiag_family == AF_INET) in udp_dump_one()
42 req->id.idiag_src[0], req->id.idiag_sport, in udp_dump_one()
43 req->id.idiag_dst[0], req->id.idiag_dport, in udp_dump_one()
49 req->id.idiag_sport, in udp_dump_one()
51 req->id.idiag_dport, in udp_dump_one()
179 req->id.idiag_dst[0], req->id.idiag_dport, in __udp_diag_destroy()
180 req->id.idiag_src[0], req->id.idiag_sport, in __udp_diag_destroy()
187 req->id.idiag_dst[3], req->id.idiag_dport, in __udp_diag_destroy()
188 req->id.idiag_src[3], req->id.idiag_sport, in __udp_diag_destroy()
194 req->id.idiag_dport, in __udp_diag_destroy()
[all …]
A Dinet_connection_sock.c704 req = NULL; in inet_csk_accept()
735 if (req) in inet_csk_accept()
744 req = NULL; in inet_csk_accept()
894 if (!req) in reqsk_alloc_noprof()
916 return req; in reqsk_alloc_noprof()
927 if (req) { in inet_reqsk_alloc()
941 return req; in inet_reqsk_alloc()
1084 req = nreq; in reqsk_timer_handler()
1123 req->rsk_ops->syn_ack_timeout(req); in reqsk_timer_handler()
1419 inet_csk_reqsk_queue_drop(req->rsk_listener, req); in inet_csk_complete_hashdance()
[all …]
A Dsyncookies.c211 reqsk_put(req); in tcp_get_cookie_sock()
308 reqsk_free(req); in cookie_bpf_check()
309 req = NULL; in cookie_bpf_check()
312 return req; in cookie_bpf_check()
331 if (!req) in cookie_tcp_reqsk_alloc()
335 reqsk_free(req); in cookie_tcp_reqsk_alloc()
342 req->mss = mss; in cookie_tcp_reqsk_alloc()
353 return req; in cookie_tcp_reqsk_alloc()
425 if (!req) { in cookie_v4_check()
476 &req->rsk_rcv_wnd, &req->rsk_window_clamp, in cookie_v4_check()
[all …]
A Dtcp_minisocks.c444 (req->rsk_window_clamp > full_space || req->rsk_window_clamp == 0)) in tcp_openreq_init_rwin()
456 &req->rsk_rcv_wnd, in tcp_openreq_init_rwin()
457 &req->rsk_window_clamp, in tcp_openreq_init_rwin()
509 ireq = inet_rsk(req); in smc_check_reset_syn_req()
601 if (req->num_timeout) { in tcp_create_openreq_child()
626 ao_key = treq->af_specific->ao_lookup(sk, req, tcp_rsk(req)->ao_keyid, -1); in tcp_create_openreq_child()
816 req->rsk_ops->send_ack(sk, skb, req); in tcp_check_req()
863 inet_rsk(req)->acked = 1; in tcp_check_req()
875 req, &own_req); in tcp_check_req()
884 reqsk_queue_removed(&inet_csk(req->rsk_listener)->icsk_accept_queue, req); in tcp_check_req()
[all …]
/net/sunrpc/xprtrdma/
A Drpc_rdma.c306 (*mr)->mr_req = req; in rpcrdma_mr_prepare()
350 seg = req->rl_segments; in rpcrdma_encode_read_list()
799 if (!req->rl_sendctx) in rpcrdma_prepare_send_sges()
802 req->rl_sendctx->sc_req = req; in rpcrdma_prepare_send_sges()
804 req->rl_wr.wr_cqe = &req->rl_sendctx->sc_cqe; in rpcrdma_prepare_send_sges()
805 req->rl_wr.sg_list = req->rl_sendctx->sc_sges; in rpcrdma_prepare_send_sges()
877 xdr_init_encode(xdr, &req->rl_hdrbuf, rdmab_data(req->rl_rdmabuf), in rpcrdma_marshal_req()
972 ret = rpcrdma_prepare_send_sges(r_xprt, req, req->rl_hdrbuf.len, in rpcrdma_marshal_req()
983 frwr_reset(req); in rpcrdma_marshal_req()
1358 req->rl_reply = NULL; in rpcrdma_unpin_rqst()
[all …]
A Dbackchannel.c63 xdr_init_encode(&req->rl_stream, &req->rl_hdrbuf, in rpcrdma_bc_marshal_reply()
64 rdmab_data(req->rl_rdmabuf), rqst); in rpcrdma_bc_marshal_reply()
114 if (frwr_send(r_xprt, req)) in xprt_rdma_bc_send_reply()
159 req->rl_reply = NULL; in xprt_rdma_bc_free_rqst()
170 struct rpcrdma_req *req; in rpcrdma_bc_rqst_get() local
193 if (!req) in rpcrdma_bc_rqst_get()
196 rpcrdma_req_destroy(req); in rpcrdma_bc_rqst_get()
201 rqst = &req->rl_slot; in rpcrdma_bc_rqst_get()
224 struct rpcrdma_req *req; in rpcrdma_bc_receive_call() local
259 req = rpcr_to_rdmar(rqst); in rpcrdma_bc_receive_call()
[all …]
A Dverbs.c825 req = kzalloc(sizeof(*req), XPRTRDMA_GFP_FLAGS); in rpcrdma_req_create()
826 if (req == NULL) in rpcrdma_req_create()
830 if (!req->rl_sendbuf) in rpcrdma_req_create()
834 if (!req->rl_recvbuf) in rpcrdma_req_create()
842 return req; in rpcrdma_req_create()
847 kfree(req); in rpcrdma_req_create()
1074 if (!req) in rpcrdma_buffer_create()
1113 kfree(req); in rpcrdma_req_destroy()
1195 if (req->rl_reply) { in rpcrdma_reply_put()
1215 if (req) in rpcrdma_buffer_get()
[all …]
/net/sunrpc/auth_gss/
A Dgss_krb5_crypto.c135 skcipher_request_zero(req); in krb5_encrypt()
174 struct ahash_request *req; in gss_krb5_checksum() local
183 if (!req) in gss_krb5_checksum()
195 checksummer, req); in gss_krb5_checksum()
217 ahash_request_free(req); in gss_krb5_checksum()
503 desc.req = req; in krb5_cbc_cts_encrypt()
563 desc.req = req; in krb5_cbc_cts_decrypt()
735 struct ahash_request *req; in krb5_etm_checksum() local
749 if (!req) in krb5_etm_checksum()
762 checksummer, req); in krb5_etm_checksum()
[all …]
/net/xfrm/
A Dxfrm_ipcomp.c26 struct acomp_req *req; member
49 struct acomp_req *req = ipcomp_cb(skb)->req; in ipcomp_post_acomp() local
59 dlen = req->dlen; in ipcomp_post_acomp()
164 ipcomp_cb(skb)->req = req; in ipcomp_setup_req()
165 if (!req) in ipcomp_setup_req()
196 return req; in ipcomp_setup_req()
205 err = PTR_ERR(req); in ipcomp_decompress()
206 if (IS_ERR(req)) in ipcomp_decompress()
265 req = ipcomp_cb(skb)->req; in ipcomp_output_done()
280 err = PTR_ERR(req); in ipcomp_compress()
[all …]
/net/mac80211/
A Dscan.c387 local->hw_scan_req->req.n_channels = req->n_channels; in ieee80211_prep_hw_scan()
424 req->ie, req->ie_len, in ieee80211_prep_hw_scan()
430 local->hw_scan_req->req.no_cck = req->no_cck; in ieee80211_prep_hw_scan()
644 req)) in ieee80211_run_deferred_scan()
779 local->hw_scan_req->req.ssids = req->ssids; in __ieee80211_start_scan()
780 local->hw_scan_req->req.n_ssids = req->n_ssids; in __ieee80211_start_scan()
784 local->hw_scan_req->req.n_channels = req->n_channels; in __ieee80211_start_scan()
788 req->n_channels * sizeof(req->channels[0]); in __ieee80211_start_scan()
790 local->hw_scan_req->req.flags = req->flags; in __ieee80211_start_scan()
792 local->hw_scan_req->req.duration = req->duration; in __ieee80211_start_scan()
[all …]
/net/mptcp/
A Dtoken_test.c8 struct mptcp_subflow_request_sock *req; in build_req_sock() local
12 KUNIT_EXPECT_NOT_ERR_OR_NULL(test, req); in build_req_sock()
13 mptcp_token_init_request((struct request_sock *)req); in build_req_sock()
14 sock_net_set((struct sock *)req, &init_net); in build_req_sock()
15 return req; in build_req_sock()
24 mptcp_token_new_request((struct request_sock *)req)); in mptcp_token_test_req_basic()
25 KUNIT_EXPECT_NE(test, 0, (int)req->token); in mptcp_token_test_req_basic()
101 msk->token = req->token; in mptcp_token_test_accept()
102 mptcp_token_accept(req, msk); in mptcp_token_test_accept()
124 msk->token = req->token; in mptcp_token_test_destroyed()
[all …]
/net/rxrpc/
A Dcall_event.c69 req->retrans = true; in rxrpc_retransmit_data()
76 req->tq = NULL; in rxrpc_retransmit_data()
77 req->n = 0; in rxrpc_retransmit_data()
117 req.tq = tq; in rxrpc_resend()
119 req.n = 1; in rxrpc_resend()
143 if (req.tq && in rxrpc_resend_tlp()
149 for (req.tq = call->tx_queue; req.tq; req.tq = req.tq->next) { in rxrpc_resend_tlp()
239 if (!req.tq) in rxrpc_transmit_fresh_data()
240 req.tq = tq; in rxrpc_transmit_fresh_data()
242 req.n++; in rxrpc_transmit_fresh_data()
[all …]
A Drxkad.c211 if (!req) { in rxkad_prime_packet_security()
229 skcipher_request_free(req); in rxkad_prime_packet_security()
290 skcipher_request_zero(req); in rxkad_secure_packet_auth()
333 skcipher_request_zero(req); in rxkad_secure_packet_encrypt()
363 if (!req) in rxkad_secure_packet()
380 skcipher_request_zero(req); in rxkad_secure_packet()
589 if (!req) in rxkad_verify_packet()
740 if (!req) in rxkad_encrypt_response()
974 if (!req) in rxkad_decrypt_ticket()
1314 if (!req) in rxkad_init()
[all …]
/net/wireless/
A Dpmsr.c299 req = kzalloc(struct_size(req, peers, count), GFP_KERNEL); in nl80211_pmsr_start()
300 if (!req) in nl80211_pmsr_start()
302 req->n_peers = count; in nl80211_pmsr_start()
345 kfree(req); in nl80211_pmsr_start()
391 if (tmp == req) { in cfg80211_pmsr_complete()
392 list_del(&req->list); in cfg80211_pmsr_complete()
393 to_free = req; in cfg80211_pmsr_complete()
615 if (req->nl_portid) in cfg80211_pmsr_process_abort()
624 kfree(req); in cfg80211_pmsr_process_abort()
646 req->nl_portid = 0; in cfg80211_pmsr_wdev_down()
[all …]
/net/bluetooth/
A Decdh_helper.c48 struct kpp_request *req; in compute_ecdh_secret() local
57 req = kpp_request_alloc(tfm, GFP_KERNEL); in compute_ecdh_secret()
58 if (!req) { in compute_ecdh_secret()
68 kpp_request_set_input(req, &src, 64); in compute_ecdh_secret()
69 kpp_request_set_output(req, &dst, 32); in compute_ecdh_secret()
84 kpp_request_free(req); in compute_ecdh_secret()
148 struct kpp_request *req; in generate_ecdh_public_key() local
158 if (!req) { in generate_ecdh_public_key()
164 kpp_request_set_input(req, NULL, 0); in generate_ecdh_public_key()
165 kpp_request_set_output(req, &dst, 64); in generate_ecdh_public_key()
[all …]

Completed in 84 milliseconds

1234567