Lines Matching refs:stream
129 const struct stream_bool stream,
191 if (!stream.down && (src32 == dst32) && (ip6->saddr.s6_addr32[1] == ip6->daddr.s6_addr32[1]))
204 if (is_ethernet) __builtin_memcpy(stream.down ? kd.dstMac : ku.dstMac, eth->h_dest, ETH_ALEN);
206 Tether6Value* v = stream.down ? bpf_tether_downstream6_map_lookup_elem(&kd)
212 uint32_t stat_and_limit_k = stream.down ? skb->ifindex : v->oif;
257 __sync_fetch_and_add(stream.down ? &stat_v->rxErrors : &stat_v->txErrors, 1);
269 __sync_fetch_and_add(stream.down ? &stat_v->rxErrors : &stat_v->txErrors, 1);
289 __sync_fetch_and_add(stream.down ? &stat_v->rxPackets : &stat_v->txPackets, packets);
290 __sync_fetch_and_add(stream.down ? &stat_v->rxBytes : &stat_v->txBytes, L3_bytes);
365 const struct stream_bool stream, const struct updatetime_bool updatetime,
425 Tether4Value* v = stream.down ? bpf_tether_downstream4_map_lookup_elem(&k)
431 uint32_t stat_and_limit_k = stream.down ? skb->ifindex : v->oif;
476 __sync_fetch_and_add(stream.down ? &stat_v->rxErrors : &stat_v->txErrors, 1);
490 __sync_fetch_and_add(stream.down ? &stat_v->rxErrors : &stat_v->txErrors, 1);
544 __sync_fetch_and_add(stream.down ? &stat_v->rxPackets : &stat_v->txPackets, packets);
545 __sync_fetch_and_add(stream.down ? &stat_v->rxBytes : &stat_v->txBytes, L3_bytes);
558 const struct stream_bool stream,
650 rawip, stream, updatetime, /* is_tcp */ true, kver);
653 rawip, stream, updatetime, /* is_tcp */ false, kver);
812 const struct stream_bool stream) {
817 const struct stream_bool stream) {
822 const struct stream_bool stream) {
831 return do_xdp_forward6(ctx, ETHER, stream);
833 return do_xdp_forward4(ctx, ETHER, stream);
840 const struct stream_bool stream) {
848 if (v == 6) return do_xdp_forward6(ctx, RAWIP, stream);
849 if (v == 4) return do_xdp_forward4(ctx, RAWIP, stream);