Home
last modified time | relevance | path

Searched refs:rep (Results 1 – 20 of 20) sorted by relevance

/net/tipc/
A Dnetlink_compat.c61 struct sk_buff *rep; member
287 if (!msg->rep) in tipc_nl_compat_dumpit()
297 msg->rep = NULL; in tipc_nl_compat_dumpit()
304 kfree_skb(msg->rep); in tipc_nl_compat_dumpit()
305 msg->rep = NULL; in tipc_nl_compat_dumpit()
313 msg->rep = NULL; in tipc_nl_compat_dumpit()
321 msg->rep = NULL; in tipc_nl_compat_dumpit()
399 if (!msg->rep) in tipc_nl_compat_doit()
1182 if (!msg->rep) in tipc_cmd_show_stats_compat()
1202 if (!msg->rep) in tipc_nl_compat_handle()
[all …]
A Dnet.c327 struct sk_buff *rep; in tipc_nl_net_addr_legacy_get() local
330 rep = nlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL); in tipc_nl_net_addr_legacy_get()
331 if (!rep) in tipc_nl_net_addr_legacy_get()
334 msg.skb = rep; in tipc_nl_net_addr_legacy_get()
A Dbearer.c915 struct sk_buff *rep; in tipc_nl_bearer_get() local
934 rep = nlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL); in tipc_nl_bearer_get()
935 if (!rep) in tipc_nl_bearer_get()
938 msg.skb = rep; in tipc_nl_bearer_get()
955 return genlmsg_reply(rep, info); in tipc_nl_bearer_get()
958 nlmsg_free(rep); in tipc_nl_bearer_get()
1265 struct sk_buff *rep; in tipc_nl_media_get() local
1282 if (!rep) in tipc_nl_media_get()
1285 msg.skb = rep; in tipc_nl_media_get()
1302 return genlmsg_reply(rep, info); in tipc_nl_media_get()
[all …]
/net/ceph/crush/
A Dmapper.c471 int rep; in crush_choose_firstn() local
488 for (rep = stable ? 0 : outpos; rep < numrep && count > 0 ; rep++) { in crush_choose_firstn()
661 int rep; in crush_choose_indep() local
673 for (rep = outpos; rep < endpos; rep++) { in crush_choose_indep()
683 for (rep = outpos; rep < endpos; rep++) { in crush_choose_indep()
688 for (rep = outpos; rep < endpos; rep++) { in crush_choose_indep()
694 for (rep = outpos; rep < endpos; rep++) { in crush_choose_indep()
784 out2, rep, in crush_choose_indep()
810 for (rep = outpos; rep < endpos; rep++) { in crush_choose_indep()
825 for (rep = outpos; rep < endpos; rep++) { in crush_choose_indep()
[all …]
/net/sunrpc/xprtrdma/
A Dverbs.c955 rep = kzalloc(sizeof(*rep), XPRTRDMA_GFP_FLAGS); in rpcrdma_rep_create()
956 if (rep == NULL) in rpcrdma_rep_create()
962 if (!rep->rr_rdmabuf) in rpcrdma_rep_create()
968 xdr_buf_init(&rep->rr_hdrbuf, rdmab_data(rep->rr_rdmabuf), in rpcrdma_rep_create()
973 rep->rr_recv_wr.wr_cqe = &rep->rr_cqe; in rpcrdma_rep_create()
974 rep->rr_recv_wr.sg_list = &rep->rr_rdmabuf->rg_iov; in rpcrdma_rep_create()
980 return rep; in rpcrdma_rep_create()
983 kfree(rep); in rpcrdma_rep_create()
991 kfree(rep); in rpcrdma_rep_free()
1371 if (!rep) in rpcrdma_post_recvs()
[all …]
A Drpc_rdma.c525 rpcrdma_complete_rqst(rep); in rpcrdma_sendctx_done()
1143 if (*p++ != rep->rr_xid) in rpcrdma_is_bcall()
1359 rep->rr_rqst = NULL; in rpcrdma_unpin_rqst()
1381 switch (rep->rr_proc) { in rpcrdma_complete_rqst()
1444 xdr_init_decode(&rep->rr_stream, &rep->rr_hdrbuf, in rpcrdma_reply_handler()
1449 rep->rr_xid = *p++; in rpcrdma_reply_handler()
1450 rep->rr_vers = *p++; in rpcrdma_reply_handler()
1452 rep->rr_proc = *p++; in rpcrdma_reply_handler()
1481 req->rl_reply = rep; in rpcrdma_reply_handler()
1482 rep->rr_rqst = rqst; in rpcrdma_reply_handler()
[all …]
A Dbackchannel.c154 struct rpcrdma_rep *rep = req->rl_reply; in xprt_rdma_bc_free_rqst() local
158 rpcrdma_rep_put(&r_xprt->rx_buf, rep); in xprt_rdma_bc_free_rqst()
220 struct rpcrdma_rep *rep) in rpcrdma_bc_receive_call() argument
230 p = xdr_inline_decode(&rep->rr_stream, 0); in rpcrdma_bc_receive_call()
231 size = xdr_stream_remaining(&rep->rr_stream); in rpcrdma_bc_receive_call()
260 req->rl_reply = rep; in rpcrdma_bc_receive_call()
A Dxprt_rdma.h489 void rpcrdma_rep_put(struct rpcrdma_buffer *buf, struct rpcrdma_rep *rep);
543 void frwr_reminv(struct rpcrdma_rep *rep, struct list_head *mrs);
570 void rpcrdma_complete_rqst(struct rpcrdma_rep *rep);
571 void rpcrdma_unpin_rqst(struct rpcrdma_rep *rep);
572 void rpcrdma_reply_handler(struct rpcrdma_rep *rep);
A Dfrwr_ops.c429 void frwr_reminv(struct rpcrdma_rep *rep, struct list_head *mrs) in frwr_reminv() argument
434 if (mr->mr_handle == rep->rr_inv_rkey) { in frwr_reminv()
574 struct rpcrdma_rep *rep; in frwr_wc_localinv_done() local
580 rep = mr->mr_req->rl_reply; in frwr_wc_localinv_done()
584 if (rep) in frwr_wc_localinv_done()
585 rpcrdma_unpin_rqst(rep); in frwr_wc_localinv_done()
590 rpcrdma_complete_rqst(rep); in frwr_wc_localinv_done()
/net/vmw_vsock/
A Ddiag.c18 struct vsock_diag_msg *rep; in sk_diag_fill() local
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()
41 rep->vdiag_ino = sock_i_ino(sk); in sk_diag_fill()
[all …]
/net/unix/
A Ddiag.c118 struct unix_diag_msg *rep; in sk_diag_fill() local
125 rep = nlmsg_data(nlh); in sk_diag_fill()
126 rep->udiag_family = AF_UNIX; in sk_diag_fill()
127 rep->udiag_type = sk->sk_type; in sk_diag_fill()
128 rep->udiag_state = READ_ONCE(sk->sk_state); in sk_diag_fill()
129 rep->pad = 0; in sk_diag_fill()
130 rep->udiag_ino = sk_ino; in sk_diag_fill()
131 sock_diag_save_cookie(sk, rep->udiag_cookie); in sk_diag_fill()
245 struct sk_buff *rep; in unix_diag_get_exact() local
266 if (!rep) in unix_diag_get_exact()
[all …]
/net/netlink/
A Ddiag.c49 struct netlink_diag_msg *rep; in sk_diag_fill() local
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()
66 rep->ndiag_dst_group = nlk->dst_group; in sk_diag_fill()
[all …]
A Daf_netlink.c2469 struct nlmsghdr *rep; in netlink_ack() local
2493 rep = nlmsg_put(skb, NETLINK_CB(in_skb).portid, nlh->nlmsg_seq, in netlink_ack()
2495 if (!rep) in netlink_ack()
2497 errmsg = nlmsg_data(rep); in netlink_ack()
2512 nlmsg_end(skb, rep); in netlink_ack()
/net/ipv4/
A Draw_diag.c93 struct sk_buff *rep; in raw_diag_dump_one() local
103 rep = nlmsg_new(nla_total_size(sizeof(struct inet_diag_msg)) + in raw_diag_dump_one()
107 if (!rep) { in raw_diag_dump_one()
112 err = inet_sk_diag_fill(sk, NULL, rep, cb, r, 0, in raw_diag_dump_one()
117 kfree_skb(rep); in raw_diag_dump_one()
121 err = nlmsg_unicast(net->diag_nlsk, rep, NETLINK_CB(in_skb).portid); in raw_diag_dump_one()
A Dudp_diag.c35 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 = nlmsg_unicast(net->diag_nlsk, rep, NETLINK_CB(in_skb).portid); in udp_dump_one()
A Dtcp_ipv4.c748 } rep; in tcp_v4_send_reset() local
774 memset(&rep, 0, sizeof(rep)); in tcp_v4_send_reset()
776 rep.th.source = th->dest; in tcp_v4_send_reset()
778 rep.th.rst = 1; in tcp_v4_send_reset()
783 rep.th.ack = 1; in tcp_v4_send_reset()
798 if (aoh && tcp_v4_ao_sign_reset(sk, skb, aoh, &arg, &rep.th, rep.opt)) in tcp_v4_send_reset()
865 if (rep.opt[0] == 0) { in tcp_v4_send_reset()
869 rep.opt[0] = mrst; in tcp_v4_send_reset()
947 } rep; in tcp_v4_send_ack() local
973 rep.th.ack = 1; in tcp_v4_send_ack()
[all …]
A Dinet_diag.c572 struct sk_buff *rep; in inet_diag_dump_one_icsk() local
580 rep = nlmsg_new(inet_sk_attr_size(sk, req, net_admin), GFP_KERNEL); in inet_diag_dump_one_icsk()
581 if (!rep) { in inet_diag_dump_one_icsk()
586 err = sk_diag_fill(sk, rep, cb, req, 0, net_admin); in inet_diag_dump_one_icsk()
589 nlmsg_free(rep); in inet_diag_dump_one_icsk()
592 err = nlmsg_unicast(net->diag_nlsk, rep, NETLINK_CB(in_skb).portid); in inet_diag_dump_one_icsk()
/net/mptcp/
A Dmptcp_diag.c32 struct sk_buff *rep; in mptcp_diag_dump_one() local
44 rep = nlmsg_new(nla_total_size(sizeof(struct inet_diag_msg)) + in mptcp_diag_dump_one()
49 if (!rep) in mptcp_diag_dump_one()
52 err = inet_sk_diag_fill(sk, inet_csk(sk), rep, cb, req, 0, in mptcp_diag_dump_one()
56 kfree_skb(rep); in mptcp_diag_dump_one()
59 err = nlmsg_unicast(net->diag_nlsk, rep, NETLINK_CB(in_skb).portid); in mptcp_diag_dump_one()
/net/sctp/
A Ddiag.c252 struct sk_buff *rep; in sctp_sock_dump_one() local
259 rep = nlmsg_new(inet_assoc_attr_size(assoc), GFP_KERNEL); in sctp_sock_dump_one()
260 if (!rep) in sctp_sock_dump_one()
269 err = inet_sctp_diag_fill(sk, assoc, rep, req, sk_user_ns(NETLINK_CB(skb).sk), in sctp_sock_dump_one()
278 return nlmsg_unicast(sock_net(skb->sk)->diag_nlsk, rep, NETLINK_CB(skb).portid); in sctp_sock_dump_one()
282 kfree_skb(rep); in sctp_sock_dump_one()
/net/netfilter/ipset/
A Dip_set_core.c1763 struct nlmsghdr *rep, *nlh = nlmsg_hdr(skb); in call_ad() local
1776 rep = nlmsg_put(skb2, NETLINK_CB(skb).portid, in call_ad()
1778 errmsg = nlmsg_data(rep); in call_ad()

Completed in 61 milliseconds