| /net/caif/ |
| D | cfpkt_skbuff.c | 17 #define PKT_ERROR(pkt, errmsg) \ argument
19 cfpkt_priv(pkt)->erronous = true; \
20 skb_reset_tail_pointer(&pkt->skb); \
45 static inline struct cfpkt_priv_data *cfpkt_priv(struct cfpkt *pkt) in cfpkt_priv() argument
47 return (struct cfpkt_priv_data *) pkt->skb.cb; in cfpkt_priv()
50 static inline bool is_erronous(struct cfpkt *pkt) in is_erronous() argument
52 return cfpkt_priv(pkt)->erronous; in is_erronous()
55 static inline struct sk_buff *pkt_to_skb(struct cfpkt *pkt) in pkt_to_skb() argument
57 return &pkt->skb; in pkt_to_skb()
67 struct cfpkt *pkt = skb_to_pkt(nativepkt); in cfpkt_fromnative() local
[all …]
|
| D | cfctrl.c | 23 int cmd, struct cfpkt *pkt){ in handle_loop() argument
28 int cmd, struct cfpkt *pkt);
30 static int cfctrl_recv(struct cflayer *layr, struct cfpkt *pkt);
178 struct cfpkt *pkt; in cfctrl_enum_req() local
186 pkt = cfpkt_create(CFPKT_CTRL_PKT_LEN); in cfctrl_enum_req()
187 if (!pkt) in cfctrl_enum_req()
190 init_info(cfpkt_info(pkt), cfctrl); in cfctrl_enum_req()
191 cfpkt_info(pkt)->dev_info->id = physlinkid; in cfctrl_enum_req()
193 cfpkt_addbdy(pkt, CFCTRL_CMD_ENUM); in cfctrl_enum_req()
194 cfpkt_addbdy(pkt, physlinkid); in cfctrl_enum_req()
[all …]
|
| D | cfserl.c | 29 static int cfserl_receive(struct cflayer *layr, struct cfpkt *pkt);
30 static int cfserl_transmit(struct cflayer *layr, struct cfpkt *pkt);
58 struct cfpkt *pkt = NULL; in cfserl_receive() local
72 pkt = layr->incomplete_frm; in cfserl_receive()
73 if (pkt == NULL) { in cfserl_receive()
78 pkt = newpkt; in cfserl_receive()
85 cfpkt_extr_head(pkt, &tmp8, 1); in cfserl_receive()
87 while (cfpkt_more(pkt) in cfserl_receive()
89 cfpkt_extr_head(pkt, &tmp8, 1); in cfserl_receive()
91 if (!cfpkt_more(pkt)) { in cfserl_receive()
[all …]
|
| D | cfdgml.c | 24 static int cfdgml_receive(struct cflayer *layr, struct cfpkt *pkt);
25 static int cfdgml_transmit(struct cflayer *layr, struct cfpkt *pkt);
40 static int cfdgml_receive(struct cflayer *layr, struct cfpkt *pkt) in cfdgml_receive() argument
49 if (cfpkt_extr_head(pkt, &cmd, 1) < 0) { in cfdgml_receive()
51 cfpkt_destroy(pkt); in cfdgml_receive()
56 if (cfpkt_extr_head(pkt, &dgmhdr, 3) < 0) { in cfdgml_receive()
58 cfpkt_destroy(pkt); in cfdgml_receive()
61 ret = layr->up->receive(layr->up, pkt); in cfdgml_receive()
68 cfpkt_destroy(pkt); in cfdgml_receive()
72 cfpkt_destroy(pkt); in cfdgml_receive()
[all …]
|
| D | cfrfml.c | 21 static int cfrfml_receive(struct cflayer *layr, struct cfpkt *pkt);
22 static int cfrfml_transmit(struct cflayer *layr, struct cfpkt *pkt);
72 struct cfpkt *pkt, int *err) in rfm_append() argument
78 if (cfpkt_extr_head(pkt, seghead, 6) < 0) in rfm_append()
85 tmppkt = cfpkt_append(rfml->incomplete_frm, pkt, in rfm_append()
97 static int cfrfml_receive(struct cflayer *layr, struct cfpkt *pkt) in cfrfml_receive() argument
112 if (cfpkt_extr_head(pkt, &tmp, 1) < 0) in cfrfml_receive()
119 if (cfpkt_peek_head(pkt, rfml->seghead, 6) < 0) in cfrfml_receive()
124 if (cfpkt_erroneous(pkt)) in cfrfml_receive()
126 rfml->incomplete_frm = pkt; in cfrfml_receive()
[all …]
|
| D | cffrml.c | 28 static int cffrml_receive(struct cflayer *layr, struct cfpkt *pkt);
29 static int cffrml_transmit(struct cflayer *layr, struct cfpkt *pkt);
82 static int cffrml_receive(struct cflayer *layr, struct cfpkt *pkt) in cffrml_receive() argument
91 cfpkt_extr_head(pkt, &tmp, 2); in cffrml_receive()
98 if (cfpkt_setlen(pkt, len) < 0) { in cffrml_receive()
101 cfpkt_destroy(pkt); in cffrml_receive()
109 cfpkt_extr_trail(pkt, &tmp, 2); in cffrml_receive()
111 pktchks = cfpkt_iterate(pkt, cffrml_checksum, 0xffff); in cffrml_receive()
113 cfpkt_add_trail(pkt, &tmp, 2); in cffrml_receive()
121 if (cfpkt_erroneous(pkt)) { in cffrml_receive()
[all …]
|
| D | cfveil.c | 23 static int cfvei_receive(struct cflayer *layr, struct cfpkt *pkt);
24 static int cfvei_transmit(struct cflayer *layr, struct cfpkt *pkt);
39 static int cfvei_receive(struct cflayer *layr, struct cfpkt *pkt) in cfvei_receive() argument
48 if (cfpkt_extr_head(pkt, &cmd, 1) < 0) { in cfvei_receive()
50 cfpkt_destroy(pkt); in cfvei_receive()
55 ret = layr->up->receive(layr->up, pkt); in cfvei_receive()
59 cfpkt_destroy(pkt); in cfvei_receive()
63 cfpkt_destroy(pkt); in cfvei_receive()
66 cfpkt_destroy(pkt); in cfvei_receive()
70 cfpkt_destroy(pkt); in cfvei_receive()
[all …]
|
| D | cfutill.c | 24 static int cfutill_receive(struct cflayer *layr, struct cfpkt *pkt);
25 static int cfutill_transmit(struct cflayer *layr, struct cfpkt *pkt);
40 static int cfutill_receive(struct cflayer *layr, struct cfpkt *pkt) in cfutill_receive() argument
48 if (cfpkt_extr_head(pkt, &cmd, 1) < 0) { in cfutill_receive()
50 cfpkt_destroy(pkt); in cfutill_receive()
56 return layr->up->receive(layr->up, pkt); in cfutill_receive()
59 cfpkt_destroy(pkt); in cfutill_receive()
63 cfpkt_destroy(pkt); in cfutill_receive()
69 cfpkt_destroy(pkt); in cfutill_receive()
72 cfpkt_destroy(pkt); in cfutill_receive()
[all …]
|
| D | cfvidl.c | 19 static int cfvidl_receive(struct cflayer *layr, struct cfpkt *pkt);
20 static int cfvidl_transmit(struct cflayer *layr, struct cfpkt *pkt);
36 static int cfvidl_receive(struct cflayer *layr, struct cfpkt *pkt) in cfvidl_receive() argument
39 if (cfpkt_extr_head(pkt, &videoheader, 4) < 0) { in cfvidl_receive()
41 cfpkt_destroy(pkt); in cfvidl_receive()
44 return layr->up->receive(layr->up, pkt); in cfvidl_receive()
47 static int cfvidl_transmit(struct cflayer *layr, struct cfpkt *pkt) in cfvidl_transmit() argument
55 cfpkt_destroy(pkt); in cfvidl_transmit()
59 cfpkt_add_head(pkt, &videoheader, 4); in cfvidl_transmit()
61 info = cfpkt_info(pkt); in cfvidl_transmit()
[all …]
|
| D | cfsrvl.c | 109 struct cfpkt *pkt; in cfservl_modemcmd() local
112 pkt = cfpkt_create(SRVL_CTRL_PKT_SIZE); in cfservl_modemcmd()
113 if (!pkt) in cfservl_modemcmd()
116 if (cfpkt_add_head(pkt, &flow_on, 1) < 0) { in cfservl_modemcmd()
118 cfpkt_destroy(pkt); in cfservl_modemcmd()
121 info = cfpkt_info(pkt); in cfservl_modemcmd()
125 cfpkt_set_prio(pkt, TC_PRIO_CONTROL); in cfservl_modemcmd()
126 return layr->dn->transmit(layr->dn, pkt); in cfservl_modemcmd()
130 struct cfpkt *pkt; in cfservl_modemcmd() local
133 pkt = cfpkt_create(SRVL_CTRL_PKT_SIZE); in cfservl_modemcmd()
[all …]
|
| /net/vmw_vsock/ |
| D | virtio_transport_common.c | 51 struct virtio_vsock_pkt *pkt; in virtio_transport_alloc_pkt() local
54 pkt = kzalloc(sizeof(*pkt), GFP_KERNEL); in virtio_transport_alloc_pkt()
55 if (!pkt) in virtio_transport_alloc_pkt()
58 pkt->hdr.type = cpu_to_le16(info->type); in virtio_transport_alloc_pkt()
59 pkt->hdr.op = cpu_to_le16(info->op); in virtio_transport_alloc_pkt()
60 pkt->hdr.src_cid = cpu_to_le64(src_cid); in virtio_transport_alloc_pkt()
61 pkt->hdr.dst_cid = cpu_to_le64(dst_cid); in virtio_transport_alloc_pkt()
62 pkt->hdr.src_port = cpu_to_le32(src_port); in virtio_transport_alloc_pkt()
63 pkt->hdr.dst_port = cpu_to_le32(dst_port); in virtio_transport_alloc_pkt()
64 pkt->hdr.flags = cpu_to_le32(info->flags); in virtio_transport_alloc_pkt()
[all …]
|
| D | virtio_transport.c | 90 struct virtio_vsock_pkt *pkt) in virtio_transport_send_pkt_loopback() argument
92 int len = pkt->len; in virtio_transport_send_pkt_loopback()
95 list_add_tail(&pkt->list, &vsock->loopback_list); in virtio_transport_send_pkt_loopback()
120 struct virtio_vsock_pkt *pkt; in virtio_transport_send_pkt_work() local
131 pkt = list_first_entry(&vsock->send_pkt_list, in virtio_transport_send_pkt_work()
133 list_del_init(&pkt->list); in virtio_transport_send_pkt_work()
136 virtio_transport_deliver_tap_pkt(pkt); in virtio_transport_send_pkt_work()
138 reply = pkt->reply; in virtio_transport_send_pkt_work()
140 sg_init_one(&hdr, &pkt->hdr, sizeof(pkt->hdr)); in virtio_transport_send_pkt_work()
142 if (pkt->buf) { in virtio_transport_send_pkt_work()
[all …]
|
| D | vmci_transport.c | 40 struct vmci_transport_packet *pkt);
44 struct vmci_transport_packet *pkt);
47 struct vmci_transport_packet *pkt);
50 struct vmci_transport_packet *pkt);
53 struct vmci_transport_packet *pkt);
55 struct vmci_transport_packet *pkt);
64 struct vmci_transport_packet pkt; member
118 vmci_transport_packet_init(struct vmci_transport_packet *pkt, in vmci_transport_packet_init() argument
131 pkt->dg.src = vmci_make_handle(VMADDR_CID_ANY, in vmci_transport_packet_init()
133 pkt->dg.dst = vmci_make_handle(dst->svm_cid, in vmci_transport_packet_init()
[all …]
|
| /net/rxrpc/ |
| D | output.c | 71 struct rxrpc_ack_buffer *pkt, in rxrpc_fill_out_ack() argument
81 u8 *ackp = pkt->acks; in rxrpc_fill_out_ack()
96 pkt->ack.bufferSpace = htons(0); in rxrpc_fill_out_ack()
97 pkt->ack.maxSkew = htons(0); in rxrpc_fill_out_ack()
98 pkt->ack.firstPacket = htonl(hard_ack + 1); in rxrpc_fill_out_ack()
99 pkt->ack.previousPacket = htonl(call->ackr_highest_seq); in rxrpc_fill_out_ack()
100 pkt->ack.serial = htonl(serial); in rxrpc_fill_out_ack()
101 pkt->ack.reason = reason; in rxrpc_fill_out_ack()
102 pkt->ack.nAcks = top - hard_ack; in rxrpc_fill_out_ack()
105 pkt->whdr.flags |= RXRPC_REQUEST_ACK; in rxrpc_fill_out_ack()
[all …]
|
| D | conn_event.c | 36 } __attribute__((packed)) pkt; in rxrpc_conn_retransmit_call() local
46 &pkt.ack, sizeof(pkt.ack)) < 0) in rxrpc_conn_retransmit_call()
48 if (pkt.ack.reason == RXRPC_ACK_PING_RESPONSE) in rxrpc_conn_retransmit_call()
69 iov[0].iov_base = &pkt; in rxrpc_conn_retransmit_call()
70 iov[0].iov_len = sizeof(pkt.whdr); in rxrpc_conn_retransmit_call()
76 pkt.whdr.epoch = htonl(conn->proto.epoch); in rxrpc_conn_retransmit_call()
77 pkt.whdr.cid = htonl(conn->proto.cid | channel); in rxrpc_conn_retransmit_call()
78 pkt.whdr.callNumber = htonl(call_id); in rxrpc_conn_retransmit_call()
79 pkt.whdr.seq = 0; in rxrpc_conn_retransmit_call()
80 pkt.whdr.type = chan->last_type; in rxrpc_conn_retransmit_call()
[all …]
|
| /net/netfilter/ |
| D | nft_chain_filter.c | 21 struct nft_pktinfo pkt; in nft_do_chain_ipv4() local
23 nft_set_pktinfo(&pkt, skb, state); in nft_do_chain_ipv4()
24 nft_set_pktinfo_ipv4(&pkt, skb); in nft_do_chain_ipv4()
26 return nft_do_chain(&pkt, priv); in nft_do_chain_ipv4()
65 struct nft_pktinfo pkt; in nft_do_chain_arp() local
67 nft_set_pktinfo(&pkt, skb, state); in nft_do_chain_arp()
68 nft_set_pktinfo_unspec(&pkt, skb); in nft_do_chain_arp()
70 return nft_do_chain(&pkt, priv); in nft_do_chain_arp()
105 struct nft_pktinfo pkt; in nft_do_chain_ipv6() local
107 nft_set_pktinfo(&pkt, skb, state); in nft_do_chain_ipv6()
[all …]
|
| D | nft_reject_inet.c | 19 const struct nft_pktinfo *pkt) in nft_reject_inet_eval() argument
23 switch (nft_pf(pkt)) { in nft_reject_inet_eval()
27 nf_send_unreach(pkt->skb, priv->icmp_code, in nft_reject_inet_eval()
28 nft_hook(pkt)); in nft_reject_inet_eval()
31 nf_send_reset(nft_net(pkt), pkt->skb, nft_hook(pkt)); in nft_reject_inet_eval()
34 nf_send_unreach(pkt->skb, in nft_reject_inet_eval()
36 nft_hook(pkt)); in nft_reject_inet_eval()
43 nf_send_unreach6(nft_net(pkt), pkt->skb, in nft_reject_inet_eval()
44 priv->icmp_code, nft_hook(pkt)); in nft_reject_inet_eval()
47 nf_send_reset6(nft_net(pkt), pkt->skb, nft_hook(pkt)); in nft_reject_inet_eval()
[all …]
|
| D | nf_tables_trace.c | 110 const struct nft_pktinfo *pkt) in nf_trace_fill_pkt_info() argument
112 const struct sk_buff *skb = pkt->skb; in nf_trace_fill_pkt_info()
116 nh_end = pkt->tprot_set ? pkt->xt.thoff : skb->len; in nf_trace_fill_pkt_info()
122 if (pkt->tprot_set) { in nf_trace_fill_pkt_info()
123 len = min_t(unsigned int, skb->len - pkt->xt.thoff, in nf_trace_fill_pkt_info()
126 pkt->xt.thoff, len)) in nf_trace_fill_pkt_info()
185 const struct nft_pktinfo *pkt = info->pkt; in nft_trace_notify() local
191 if (!nfnetlink_has_listeners(nft_net(pkt), NFNLGRP_NFTRACE)) in nft_trace_notify()
226 if (nla_put_be32(skb, NFTA_TRACE_NFPROTO, htonl(nft_pf(pkt)))) in nft_trace_notify()
232 if (trace_fill_id(skb, pkt->skb)) in nft_trace_notify()
[all …]
|
| D | nft_tproxy.c | 23 const struct nft_pktinfo *pkt) in nft_tproxy_eval_v4() argument
26 struct sk_buff *skb = pkt->skb; in nft_tproxy_eval_v4()
33 if (pkt->tprot != IPPROTO_TCP && in nft_tproxy_eval_v4()
34 pkt->tprot != IPPROTO_UDP) { in nft_tproxy_eval_v4()
49 sk = nf_tproxy_get_sock_v4(nft_net(pkt), skb, iph->protocol, in nft_tproxy_eval_v4()
66 sk = nf_tproxy_handle_time_wait4(nft_net(pkt), skb, taddr, tport, sk); in nft_tproxy_eval_v4()
71 sk = nf_tproxy_get_sock_v4(nft_net(pkt), skb, iph->protocol, in nft_tproxy_eval_v4()
86 const struct nft_pktinfo *pkt) in nft_tproxy_eval_v6() argument
89 struct sk_buff *skb = pkt->skb; in nft_tproxy_eval_v6()
92 int thoff = pkt->xt.thoff; in nft_tproxy_eval_v6()
[all …]
|
| D | nf_tables_core.c | 28 const struct nft_pktinfo *pkt = info->pkt; in __nft_trace_packet() local
30 if (!info->trace || !pkt->skb->nf_trace) in __nft_trace_packet()
63 const struct nft_pktinfo *pkt) in nft_payload_fast_eval() argument
66 const struct sk_buff *skb = pkt->skb; in nft_payload_fast_eval()
73 if (!pkt->tprot_set) in nft_payload_fast_eval()
75 ptr = skb_network_header(skb) + pkt->xt.thoff; in nft_payload_fast_eval()
96 const struct nft_pktinfo *pkt) in nft_update_chain_stats() argument
111 stats->bytes += pkt->skb->len; in nft_update_chain_stats()
125 struct nft_pktinfo *pkt) in expr_call_ops_eval() argument
131 return fun(expr, regs, pkt); } while (0) in expr_call_ops_eval()
[all …]
|
| D | nft_exthdr.c | 38 const struct nft_pktinfo *pkt) in nft_exthdr_ipv6_eval() argument
45 if (pkt->skb->protocol != htons(ETH_P_IPV6)) in nft_exthdr_ipv6_eval()
48 err = ipv6_find_hdr(pkt->skb, &offset, priv->type, NULL, NULL); in nft_exthdr_ipv6_eval()
58 if (skb_copy_bits(pkt->skb, offset, dest, priv->len) < 0) in nft_exthdr_ipv6_eval()
134 const struct nft_pktinfo *pkt) in nft_exthdr_ipv4_eval() argument
138 struct sk_buff *skb = pkt->skb; in nft_exthdr_ipv4_eval()
145 err = ipv4_find_option(nft_net(pkt), skb, &offset, priv->type); in nft_exthdr_ipv4_eval()
155 if (skb_copy_bits(pkt->skb, offset, dest, priv->len) < 0) in nft_exthdr_ipv4_eval()
163 nft_tcp_header_pointer(const struct nft_pktinfo *pkt, in nft_tcp_header_pointer() argument
168 if (!pkt->tprot_set || pkt->tprot != IPPROTO_TCP) in nft_tcp_header_pointer()
[all …]
|
| /net/ipv6/netfilter/ |
| D | nft_fib_ipv6.c | 23 const struct nft_pktinfo *pkt, in nft_fib6_flowi_init() argument
39 fl6->flowi6_oif = get_ifindex(dev ? dev : pkt->skb->dev); in nft_fib6_flowi_init()
49 fl6->flowi6_mark = pkt->skb->mark; in nft_fib6_flowi_init()
57 const struct nft_pktinfo *pkt, in __nft_fib6_eval_type() argument
65 .flowi6_proto = pkt->tprot, in __nft_fib6_eval_type()
70 dev = nft_in(pkt); in __nft_fib6_eval_type()
72 dev = nft_out(pkt); in __nft_fib6_eval_type()
74 nft_fib6_flowi_init(&fl6, priv, pkt, dev, iph); in __nft_fib6_eval_type()
76 if (dev && nf_ipv6_chk_addr(nft_net(pkt), &fl6.daddr, dev, true)) in __nft_fib6_eval_type()
79 route_err = nf_ip6_route(nft_net(pkt), (struct dst_entry **)&rt, in __nft_fib6_eval_type()
[all …]
|
| /net/ipv4/netfilter/ |
| D | nft_fib_ipv4.c | 28 const struct nft_pktinfo *pkt) in nft_fib4_eval_type() argument
31 int noff = skb_network_offset(pkt->skb); in nft_fib4_eval_type()
38 dev = nft_in(pkt); in nft_fib4_eval_type()
40 dev = nft_out(pkt); in nft_fib4_eval_type()
42 iph = skb_header_pointer(pkt->skb, noff, sizeof(_iph), &_iph); in nft_fib4_eval_type()
53 *dst = inet_dev_addr_type(nft_net(pkt), dev, addr); in nft_fib4_eval_type()
58 const struct nft_pktinfo *pkt) in nft_fib4_eval() argument
61 int noff = skb_network_offset(pkt->skb); in nft_fib4_eval()
80 oif = nft_out(pkt); in nft_fib4_eval()
82 oif = nft_in(pkt); in nft_fib4_eval()
[all …]
|
| /net/bridge/netfilter/ |
| D | nft_reject_bridge.c | 299 const struct nft_pktinfo *pkt) in nft_reject_bridge_eval() argument
302 const unsigned char *dest = eth_hdr(pkt->skb)->h_dest; in nft_reject_bridge_eval()
308 switch (eth_hdr(pkt->skb)->h_proto) { in nft_reject_bridge_eval()
312 nft_reject_br_send_v4_unreach(nft_net(pkt), pkt->skb, in nft_reject_bridge_eval()
313 nft_in(pkt), in nft_reject_bridge_eval()
314 nft_hook(pkt), in nft_reject_bridge_eval()
318 nft_reject_br_send_v4_tcp_reset(nft_net(pkt), pkt->skb, in nft_reject_bridge_eval()
319 nft_in(pkt), in nft_reject_bridge_eval()
320 nft_hook(pkt)); in nft_reject_bridge_eval()
323 nft_reject_br_send_v4_unreach(nft_net(pkt), pkt->skb, in nft_reject_bridge_eval()
[all …]
|
| /net/can/j1939/ |
| D | transport.c | 331 offset_start = session->pkt.tx_acked * 7; in j1939_session_skb_drop_old()
404 offset_start = session->pkt.dpo * 7; in j1939_session_skb_get()
720 dat[3] = session->pkt.total; in j1939_session_tx_rts()
731 session->pkt.tx = 0; in j1939_session_tx_rts()
760 unsigned int pkt; in j1939_session_tx_dpo() local
767 session->pkt.dpo = session->pkt.tx_acked; in j1939_session_tx_dpo()
768 pkt = session->pkt.dpo; in j1939_session_tx_dpo()
769 dat[1] = session->pkt.last - session->pkt.tx_acked; in j1939_session_tx_dpo()
770 dat[2] = (pkt >> 0); in j1939_session_tx_dpo()
771 dat[3] = (pkt >> 8); in j1939_session_tx_dpo()
[all …]
|