/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 …]
|