| /net/sunrpc/xprtrdma/ |
| D | verbs.c | 83 static void rpcrdma_rep_destroy(struct rpcrdma_rep *rep);
184 struct rpcrdma_rep *rep = container_of(cqe, struct rpcrdma_rep, in rpcrdma_wc_receive() local
195 rpcrdma_set_xdrlen(&rep->rr_hdrbuf, wc->byte_len); in rpcrdma_wc_receive()
196 rep->rr_wc_flags = wc->wc_flags; in rpcrdma_wc_receive()
197 rep->rr_inv_rkey = wc->ex.invalidate_rkey; in rpcrdma_wc_receive()
199 ib_dma_sync_single_for_cpu(rdmab_device(rep->rr_rdmabuf), in rpcrdma_wc_receive()
200 rdmab_addr(rep->rr_rdmabuf), in rpcrdma_wc_receive()
203 rpcrdma_reply_handler(rep); in rpcrdma_wc_receive()
208 rpcrdma_rep_destroy(rep); in rpcrdma_wc_receive()
964 struct rpcrdma_rep *rep; in rpcrdma_rep_create() local
[all …]
|
| D | rpc_rdma.c | 539 struct rpcrdma_rep *rep = req->rl_reply; in rpcrdma_sendctx_done() local
541 rpcrdma_complete_rqst(rep); in rpcrdma_sendctx_done()
542 rep->rr_rxprt->rx_stats.reply_waits_for_send++; in rpcrdma_sendctx_done()
1137 rpcrdma_is_bcall(struct rpcrdma_xprt *r_xprt, struct rpcrdma_rep *rep) in rpcrdma_is_bcall() argument
1141 struct xdr_stream *xdr = &rep->rr_stream; in rpcrdma_is_bcall()
1144 if (rep->rr_proc != rdma_msg) in rpcrdma_is_bcall()
1159 if (*p++ != rep->rr_xid) in rpcrdma_is_bcall()
1175 rpcrdma_bc_receive_call(r_xprt, rep); in rpcrdma_is_bcall()
1282 rpcrdma_decode_msg(struct rpcrdma_xprt *r_xprt, struct rpcrdma_rep *rep, in rpcrdma_decode_msg() argument
1285 struct xdr_stream *xdr = &rep->rr_stream; in rpcrdma_decode_msg()
[all …]
|
| D | backchannel.c | 222 struct rpcrdma_rep *rep) in rpcrdma_bc_receive_call() argument
232 p = xdr_inline_decode(&rep->rr_stream, 0); in rpcrdma_bc_receive_call()
233 size = xdr_stream_remaining(&rep->rr_stream); in rpcrdma_bc_receive_call()
262 req->rl_reply = rep; in rpcrdma_bc_receive_call()
|
| D | xprt_rdma.h | 529 void frwr_reminv(struct rpcrdma_rep *rep, struct list_head *mrs);
555 void rpcrdma_complete_rqst(struct rpcrdma_rep *rep);
556 void rpcrdma_reply_handler(struct rpcrdma_rep *rep);
|
| D | frwr_ops.c | 417 void frwr_reminv(struct rpcrdma_rep *rep, struct list_head *mrs) in frwr_reminv() argument
422 if (mr->mr_handle == rep->rr_inv_rkey) { in frwr_reminv()
574 struct rpcrdma_rep *rep = mr->mr_req->rl_reply; in frwr_wc_localinv_done() local
582 rpcrdma_complete_rqst(rep); in frwr_wc_localinv_done()
|
| /net/tipc/ |
| D | netlink_compat.c | 60 struct sk_buff *rep; member
240 if (tipc_skb_tailroom(msg->rep) <= 1) { in __tipc_nl_compat_dumpit()
262 if ((TIPC_SKB_MAX - msg->rep->len) <= 1) { in __tipc_nl_compat_dumpit()
263 char *tail = skb_tail_pointer(msg->rep); in __tipc_nl_compat_dumpit()
287 msg->rep = tipc_tlv_alloc(msg->rep_size); in tipc_nl_compat_dumpit()
288 if (!msg->rep) in tipc_nl_compat_dumpit()
292 tipc_tlv_init(msg->rep, msg->rep_type); in tipc_nl_compat_dumpit()
297 kfree_skb(msg->rep); in tipc_nl_compat_dumpit()
298 msg->rep = NULL; in tipc_nl_compat_dumpit()
305 kfree_skb(msg->rep); in tipc_nl_compat_dumpit()
[all …]
|
| D | net.c | 323 struct sk_buff *rep; in tipc_nl_net_addr_legacy_get() local
326 rep = nlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL); in tipc_nl_net_addr_legacy_get()
327 if (!rep) in tipc_nl_net_addr_legacy_get()
330 msg.skb = rep; in tipc_nl_net_addr_legacy_get()
|
| D | bearer.c | 884 struct sk_buff *rep; in tipc_nl_bearer_get() local
903 rep = nlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL); in tipc_nl_bearer_get()
904 if (!rep) in tipc_nl_bearer_get()
907 msg.skb = rep; in tipc_nl_bearer_get()
924 return genlmsg_reply(rep, info); in tipc_nl_bearer_get()
927 nlmsg_free(rep); in tipc_nl_bearer_get()
1237 struct sk_buff *rep; in tipc_nl_media_get() local
1253 rep = nlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL); in tipc_nl_media_get()
1254 if (!rep) in tipc_nl_media_get()
1257 msg.skb = rep; in tipc_nl_media_get()
[all …]
|
| /net/ceph/crush/ |
| D | mapper.c | 467 int rep; in crush_choose_firstn() local
484 for (rep = stable ? 0 : outpos; rep < numrep && count > 0 ; rep++) { in crush_choose_firstn()
497 r = rep + parent_r; in crush_choose_firstn()
658 int rep; in crush_choose_indep() local
670 for (rep = outpos; rep < endpos; rep++) { in crush_choose_indep()
671 out[rep] = CRUSH_ITEM_UNDEF; in crush_choose_indep()
673 out2[rep] = CRUSH_ITEM_UNDEF; in crush_choose_indep()
680 for (rep = outpos; rep < endpos; rep++) { in crush_choose_indep()
681 dprintk(" %d", out[rep]); in crush_choose_indep()
685 for (rep = outpos; rep < endpos; rep++) { in crush_choose_indep()
[all …]
|
| /net/vmw_vsock/ |
| D | diag.c | 18 struct vsock_diag_msg *rep; in sk_diag_fill() local
21 nlh = nlmsg_put(skb, portid, seq, SOCK_DIAG_BY_FAMILY, sizeof(*rep), in sk_diag_fill()
26 rep = nlmsg_data(nlh); in sk_diag_fill()
27 rep->vdiag_family = AF_VSOCK; in sk_diag_fill()
34 rep->vdiag_type = sk->sk_type; in sk_diag_fill()
35 rep->vdiag_state = sk->sk_state; in sk_diag_fill()
36 rep->vdiag_shutdown = sk->sk_shutdown; in sk_diag_fill()
37 rep->vdiag_src_cid = vsk->local_addr.svm_cid; in sk_diag_fill()
38 rep->vdiag_src_port = vsk->local_addr.svm_port; in sk_diag_fill()
39 rep->vdiag_dst_cid = vsk->remote_addr.svm_cid; in sk_diag_fill()
[all …]
|
| /net/netlink/ |
| D | diag.c | 49 struct netlink_diag_msg *rep; in sk_diag_fill() local
52 nlh = nlmsg_put(skb, portid, seq, SOCK_DIAG_BY_FAMILY, sizeof(*rep), in sk_diag_fill()
57 rep = nlmsg_data(nlh); in sk_diag_fill()
58 rep->ndiag_family = AF_NETLINK; in sk_diag_fill()
59 rep->ndiag_type = sk->sk_type; in sk_diag_fill()
60 rep->ndiag_protocol = sk->sk_protocol; in sk_diag_fill()
61 rep->ndiag_state = sk->sk_state; in sk_diag_fill()
63 rep->ndiag_ino = sk_ino; in sk_diag_fill()
64 rep->ndiag_portid = nlk->portid; in sk_diag_fill()
65 rep->ndiag_dst_portid = nlk->dst_portid; in sk_diag_fill()
[all …]
|
| D | af_netlink.c | 2403 struct nlmsghdr *rep; in netlink_ack() local
2439 rep = __nlmsg_put(skb, NETLINK_CB(in_skb).portid, nlh->nlmsg_seq, in netlink_ack()
2441 errmsg = nlmsg_data(rep); in netlink_ack()
2465 nlmsg_end(skb, rep); in netlink_ack()
|
| /net/unix/ |
| D | diag.c | 128 struct unix_diag_msg *rep; in sk_diag_fill() local
130 nlh = nlmsg_put(skb, portid, seq, SOCK_DIAG_BY_FAMILY, sizeof(*rep), in sk_diag_fill()
135 rep = nlmsg_data(nlh); in sk_diag_fill()
136 rep->udiag_family = AF_UNIX; in sk_diag_fill()
137 rep->udiag_type = sk->sk_type; in sk_diag_fill()
138 rep->udiag_state = sk->sk_state; in sk_diag_fill()
139 rep->pad = 0; in sk_diag_fill()
140 rep->udiag_ino = sk_ino; in sk_diag_fill()
141 sock_diag_save_cookie(sk, rep->udiag_cookie); in sk_diag_fill()
266 struct sk_buff *rep; in unix_diag_get_exact() local
[all …]
|
| /net/mptcp/ |
| D | mptcp_diag.c | 33 struct sk_buff *rep; in mptcp_diag_dump_one() local
45 rep = nlmsg_new(nla_total_size(sizeof(struct inet_diag_msg)) + in mptcp_diag_dump_one()
50 if (!rep) in mptcp_diag_dump_one()
53 err = inet_sk_diag_fill(sk, inet_csk(sk), rep, cb, req, 0, in mptcp_diag_dump_one()
57 kfree_skb(rep); in mptcp_diag_dump_one()
60 err = netlink_unicast(net->diag_nlsk, rep, NETLINK_CB(in_skb).portid, in mptcp_diag_dump_one()
|
| /net/ipv4/ |
| D | raw_diag.c | 94 struct sk_buff *rep; in raw_diag_dump_one() local
104 rep = nlmsg_new(nla_total_size(sizeof(struct inet_diag_msg)) + in raw_diag_dump_one()
108 if (!rep) { in raw_diag_dump_one()
113 err = inet_sk_diag_fill(sk, NULL, rep, cb, r, 0, in raw_diag_dump_one()
118 kfree_skb(rep); in raw_diag_dump_one()
122 err = netlink_unicast(net->diag_nlsk, rep, in raw_diag_dump_one()
|
| D | udp_diag.c | 35 struct sk_buff *rep; in udp_dump_one() local
66 rep = nlmsg_new(nla_total_size(sizeof(struct inet_diag_msg)) + in udp_dump_one()
70 if (!rep) in udp_dump_one()
73 err = inet_sk_diag_fill(sk, NULL, rep, cb, req, 0, in udp_dump_one()
77 kfree_skb(rep); in udp_dump_one()
80 err = netlink_unicast(net->diag_nlsk, rep, NETLINK_CB(in_skb).portid, in udp_dump_one()
|
| D | tcp_ipv4.c | 668 } rep; in tcp_v4_send_reset() local
692 memset(&rep, 0, sizeof(rep)); in tcp_v4_send_reset()
693 rep.th.dest = th->source; in tcp_v4_send_reset()
694 rep.th.source = th->dest; in tcp_v4_send_reset()
695 rep.th.doff = sizeof(struct tcphdr) / 4; in tcp_v4_send_reset()
696 rep.th.rst = 1; in tcp_v4_send_reset()
699 rep.th.seq = th->ack_seq; in tcp_v4_send_reset()
701 rep.th.ack = 1; in tcp_v4_send_reset()
702 rep.th.ack_seq = htonl(ntohl(th->seq) + th->syn + th->fin + in tcp_v4_send_reset()
707 arg.iov[0].iov_base = (unsigned char *)&rep; in tcp_v4_send_reset()
[all …]
|
| D | inet_diag.c | 555 struct sk_buff *rep; in inet_diag_dump_one_icsk() local
563 rep = nlmsg_new(inet_sk_attr_size(sk, req, net_admin), GFP_KERNEL); in inet_diag_dump_one_icsk()
564 if (!rep) { in inet_diag_dump_one_icsk()
569 err = sk_diag_fill(sk, rep, cb, req, 0, net_admin); in inet_diag_dump_one_icsk()
572 nlmsg_free(rep); in inet_diag_dump_one_icsk()
575 err = netlink_unicast(net->diag_nlsk, rep, NETLINK_CB(in_skb).portid, in inet_diag_dump_one_icsk()
|
| /net/sctp/ |
| D | diag.c | 254 struct sk_buff *rep; in sctp_tsp_dump_one() local
262 rep = nlmsg_new(inet_assoc_attr_size(assoc), GFP_KERNEL); in sctp_tsp_dump_one()
263 if (!rep) in sctp_tsp_dump_one()
272 err = inet_sctp_diag_fill(sk, assoc, rep, req, in sctp_tsp_dump_one()
280 kfree_skb(rep); in sctp_tsp_dump_one()
284 err = netlink_unicast(net->diag_nlsk, rep, NETLINK_CB(in_skb).portid, in sctp_tsp_dump_one()
|
| /net/netfilter/ipset/ |
| D | ip_set_core.c | 1753 struct nlmsghdr *rep, *nlh = nlmsg_hdr(skb); in call_ad() local
1766 rep = __nlmsg_put(skb2, NETLINK_CB(skb).portid, in call_ad()
1768 errmsg = nlmsg_data(rep); in call_ad()
|