| /net/netlink/ |
| D | diag.c | 61 struct netlink_diag_msg *rep; in sk_diag_fill() local
64 nlh = nlmsg_put(skb, portid, seq, SOCK_DIAG_BY_FAMILY, sizeof(*rep), in sk_diag_fill()
69 rep = nlmsg_data(nlh); in sk_diag_fill()
70 rep->ndiag_family = AF_NETLINK; in sk_diag_fill()
71 rep->ndiag_type = sk->sk_type; in sk_diag_fill()
72 rep->ndiag_protocol = sk->sk_protocol; in sk_diag_fill()
73 rep->ndiag_state = sk->sk_state; in sk_diag_fill()
75 rep->ndiag_ino = sk_ino; in sk_diag_fill()
76 rep->ndiag_portid = nlk->portid; in sk_diag_fill()
77 rep->ndiag_dst_portid = nlk->dst_portid; in sk_diag_fill()
[all …]
|
| D | af_netlink.c | 2552 struct nlmsghdr *rep; in netlink_ack() local
2576 rep = __nlmsg_put(skb, NETLINK_CB(in_skb).portid, nlh->nlmsg_seq, in netlink_ack()
2578 errmsg = nlmsg_data(rep); in netlink_ack()
|
| /net/sunrpc/xprtrdma/ |
| D | rpc_rdma.c | 562 rpcrdma_count_chunks(struct rpcrdma_rep *rep, unsigned int max, int wrchunk, __be32 **iptrp) in rpcrdma_count_chunks() argument
593 if ((char *) cur_wchunk > rep->rr_base + rep->rr_len) in rpcrdma_count_chunks()
714 rpcrdma_unbind_func(struct rpcrdma_rep *rep) in rpcrdma_unbind_func() argument
716 wake_up(&rep->rr_unbind); in rpcrdma_unbind_func()
725 rpcrdma_reply_handler(struct rpcrdma_rep *rep) in rpcrdma_reply_handler() argument
730 struct rpc_xprt *xprt = rep->rr_xprt; in rpcrdma_reply_handler()
736 if (rep->rr_len == ~0U) { in rpcrdma_reply_handler()
737 rpcrdma_recv_buffer_put(rep); in rpcrdma_reply_handler()
744 if (rep->rr_len < 28) { in rpcrdma_reply_handler()
748 headerp = (struct rpcrdma_msg *) rep->rr_base; in rpcrdma_reply_handler()
[all …]
|
| D | verbs.c | 80 struct rpcrdma_rep *rep; in rpcrdma_run_tasklet() local
87 rep = list_entry(rpcrdma_tasklets_g.next, in rpcrdma_run_tasklet()
89 list_del(&rep->rr_list); in rpcrdma_run_tasklet()
90 func = rep->rr_func; in rpcrdma_run_tasklet()
91 rep->rr_func = NULL; in rpcrdma_run_tasklet()
95 func(rep); in rpcrdma_run_tasklet()
97 rpcrdma_recv_buffer_put(rep); in rpcrdma_run_tasklet()
107 rpcrdma_schedule_tasklet(struct rpcrdma_rep *rep) in rpcrdma_schedule_tasklet() argument
112 list_add_tail(&rep->rr_list, &rpcrdma_tasklets_g); in rpcrdma_schedule_tasklet()
149 struct rpcrdma_rep *rep = in rpcrdma_event_process() local
[all …]
|
| D | transport.c | 564 struct rpcrdma_rep *rep; in xprt_rdma_free() local
576 rep = req->rl_reply; in xprt_rdma_free()
579 __func__, rep, (rep && rep->rr_func) ? " (with waiter)" : ""); in xprt_rdma_free()
596 if (rep && wait_event_interruptible(rep->rr_unbind, !rep->rr_func)) { in xprt_rdma_free()
597 rep->rr_func = NULL; /* abandon the callback */ in xprt_rdma_free()
|
| /net/unix/ |
| D | diag.c | 116 struct unix_diag_msg *rep; in sk_diag_fill() local
118 nlh = nlmsg_put(skb, portid, seq, SOCK_DIAG_BY_FAMILY, sizeof(*rep), in sk_diag_fill()
123 rep = nlmsg_data(nlh); in sk_diag_fill()
124 rep->udiag_family = AF_UNIX; in sk_diag_fill()
125 rep->udiag_type = sk->sk_type; in sk_diag_fill()
126 rep->udiag_state = sk->sk_state; in sk_diag_fill()
127 rep->udiag_ino = sk_ino; in sk_diag_fill()
128 sock_diag_save_cookie(sk, rep->udiag_cookie); in sk_diag_fill()
247 struct sk_buff *rep; in unix_diag_get_exact() local
266 rep = nlmsg_new(sizeof(struct unix_diag_msg) + extra_len, GFP_KERNEL); in unix_diag_get_exact()
[all …]
|
| /net/ipv4/ |
| D | udp_diag.c | 39 struct sk_buff *rep; in udp_dump_one() local
68 rep = nlmsg_new(sizeof(struct inet_diag_msg) + in udp_dump_one()
71 if (!rep) in udp_dump_one()
74 err = inet_sk_diag_fill(sk, NULL, rep, req, in udp_dump_one()
81 kfree_skb(rep); in udp_dump_one()
84 err = netlink_unicast(net->diag_nlsk, rep, NETLINK_CB(in_skb).portid, in udp_dump_one()
|
| D | tcp_ipv4.c | 612 } rep; in tcp_v4_send_reset() local
631 memset(&rep, 0, sizeof(rep)); in tcp_v4_send_reset()
632 rep.th.dest = th->source; in tcp_v4_send_reset()
633 rep.th.source = th->dest; in tcp_v4_send_reset()
634 rep.th.doff = sizeof(struct tcphdr) / 4; in tcp_v4_send_reset()
635 rep.th.rst = 1; in tcp_v4_send_reset()
638 rep.th.seq = th->ack_seq; in tcp_v4_send_reset()
640 rep.th.ack = 1; in tcp_v4_send_reset()
641 rep.th.ack_seq = htonl(ntohl(th->seq) + th->syn + th->fin + in tcp_v4_send_reset()
646 arg.iov[0].iov_base = (unsigned char *)&rep; in tcp_v4_send_reset()
[all …]
|
| D | inet_diag.c | 353 struct sk_buff *rep; in inet_diag_dump_one_icsk() local
361 rep = nlmsg_new(sizeof(struct inet_diag_msg) + in inet_diag_dump_one_icsk()
364 if (!rep) { in inet_diag_dump_one_icsk()
369 err = sk_diag_fill(sk, rep, req, in inet_diag_dump_one_icsk()
377 nlmsg_free(rep); in inet_diag_dump_one_icsk()
380 err = netlink_unicast(net->diag_nlsk, rep, NETLINK_CB(in_skb).portid, in inet_diag_dump_one_icsk()
|
| /net/ceph/crush/ |
| D | mapper.c | 301 int rep; in crush_choose() local
314 for (rep = outpos; rep < numrep; rep++) { in crush_choose()
327 r = rep; in crush_choose()
|
| /net/netfilter/ipset/ |
| D | ip_set_core.c | 1319 struct nlmsghdr *rep, *nlh = nlmsg_hdr(skb); in call_ad() local
1331 rep = __nlmsg_put(skb2, NETLINK_CB(skb).portid, in call_ad()
1333 errmsg = nlmsg_data(rep); in call_ad()
|