Lines Matching defs:le
156 const struct lro_entry *le, const struct mbuf *m,
173 if (le->m_head) {
174 log.u_bbr.flex3 = le->m_head->m_pkthdr.lro_nsegs;
175 log.u_bbr.flex4 = le->m_head->m_pkthdr.lro_tcp_d_len;
176 log.u_bbr.flex5 = le->m_head->m_pkthdr.len;
177 log.u_bbr.delRate = le->m_head->m_flags;
178 log.u_bbr.rttProp = le->m_head->m_pkthdr.rcv_tstmp;
183 log.u_bbr.epoch = le->next_seq;
184 log.u_bbr.lt_epoch = le->ack_seq;
186 log.u_bbr.cwnd_gain = le->window;
189 log.u_bbr.bw_inuse = (uintptr_t)le->m_head;
192 log.u_bbr.flex7 = le->compressed;
193 log.u_bbr.pacing_gain = le->uncompressed;
206 tcp_lro_get_last_if_ackcmp(struct lro_ctrl *lc, struct lro_entry *le,
217 tcp_lro_log(tp, lc, le, NULL, 23, 0, 0, 0, 0);
230 tcp_lro_log(tp, lc, le, NULL, 21, 0, 0, 0, 0);
254 struct lro_entry *le, struct mbuf **pp, struct mbuf **cmp,
286 lro_type = le->inner.data.lro_type;
289 lro_type = le->outer.data.lro_type;
292 tcp_hdr_offset -= sizeof(*le->outer.ip4);
294 IP_PROBE(receive, NULL, NULL, le->outer.ip4, lc->ifp,
295 le->outer.ip4, NULL);
298 tcp_hdr_offset -= sizeof(*le->outer.ip6);
300 IP_PROBE(receive, NULL, NULL, le->outer.ip6, lc->ifp,
301 NULL, le->outer.ip6);
308 switch (le->outer.data.lro_type) {
310 IP_PROBE(receive, NULL, NULL, le->outer.ip4, lc->ifp,
311 le->outer.ip4, NULL);
312 UDP_PROBE(receive, NULL, NULL, le->outer.ip4, NULL,
313 le->outer.udp);
316 IP_PROBE(receive, NULL, NULL, le->outer.ip6, lc->ifp,
317 NULL, le->outer.ip6);
318 UDP_PROBE(receive, NULL, NULL, le->outer.ip6, NULL,
319 le->outer.udp);
325 tcp_hdr_offset -= sizeof(*le->outer.ip4);
327 IP_PROBE(receive, NULL, NULL, le->inner.ip4, NULL,
328 le->inner.ip4, NULL);
331 switch (le->outer.data.lro_type) {
333 IP_PROBE(receive, NULL, NULL, le->outer.ip4, lc->ifp,
334 le->outer.ip4, NULL);
335 UDP_PROBE(receive, NULL, NULL, le->outer.ip4, NULL,
336 le->outer.udp);
339 IP_PROBE(receive, NULL, NULL, le->outer.ip6, lc->ifp,
340 NULL, le->outer.ip6);
341 UDP_PROBE(receive, NULL, NULL, le->outer.ip6, NULL,
342 le->outer.udp);
348 tcp_hdr_offset -= sizeof(*le->outer.ip6);
350 IP_PROBE(receive, NULL, NULL, le->inner.ip6, NULL, NULL,
351 le->inner.ip6);
409 nm = tcp_lro_get_last_if_ackcmp(lc, le, tp, &n_mbuf,
443 le->compressed++;
460 le->uncompressed++;
465 tcp_queue_pkts(struct tcpcb *tp, struct lro_entry *le)
470 STAILQ_HEAD(, mbuf) q = { le->m_head,
471 &STAILQ_NEXT(le->m_last_mbuf, m_stailqpkt) };
473 le->m_head = NULL;
474 le->m_last_mbuf = NULL;
514 _tcp_lro_flush_tcphpts(struct lro_ctrl *lc, struct lro_entry *le)
523 (le->outer.data.vlan_id != 0) ||
524 (le->inner.data.lro_type != LRO_TYPE_NONE))
536 if (__predict_false(le->outer.data.lro_type == LRO_TYPE_IPV6_TCP &&
537 IN6_IS_ADDR_UNSPECIFIED(&le->outer.data.s_addr.v6)))
540 if (__predict_false(le->inner.data.lro_type == LRO_TYPE_IPV6_TCP &&
541 IN6_IS_ADDR_UNSPECIFIED(&le->inner.data.s_addr.v6)))
564 (le->inner.data.lro_type == LRO_TYPE_NONE) ? &le->outer : &le->inner);
605 for (pp = &le->m_head; *pp != NULL; ) {
607 if (do_bpf_strip_and_compress(tp, lc, le, pp, &cmp, &mv_to,
624 tcp_lro_log(tp, lc, le, NULL, 25, 0, 0, 0, 0);
630 tcp_lro_log(tp, lc, le, NULL, 24, 0, 0, 0, 0);
632 tcp_lro_log(tp, lc, le, NULL, 26, 0, 0, 0, 0);
638 if (pp == &le->m_head)
639 le->m_last_mbuf = *pp;
641 le->m_last_mbuf = __containerof(pp, struct mbuf, m_nextpkt);
644 if (le->m_head != NULL) {
647 tcp_lro_log(tp, lc, le, NULL, 22, 1, tp->t_flags2, 0, 1);
649 tcp_queue_pkts(tp, le);