/darwin-on-arm/xnu/bsd/netinet/ |
H A D | tcp_lro.c | 55 unsigned int lro_eject_req = 0; /* Counter for tracking flow ejections */ 131 struct lro_flow *flow; local 148 flow = &lro_flow_list[*flow_id]; 150 if ((flow->lr_faddr.s_addr == ip_hdr->ip_src.s_addr) && 151 (flow->lr_laddr.s_addr == ip_hdr->ip_dst.s_addr) && 152 (flow->lr_fport == tcp_hdr->th_sport) && 153 (flow->lr_lport == tcp_hdr->th_dport)) { 154 if (flow->lr_tcphdr == NULL) { 155 if (ntohl(seqnum) == flow->lr_seq) { 160 __func__, ntohl(seqnum), flow 206 struct lro_flow *flow = NULL; local 227 struct lro_flow *flow = NULL; local 598 struct lro_flow *flow; local [all...] |
/darwin-on-arm/xnu/bsd/net/classq/ |
H A D | classq_blue.c | 295 blue_getq_flow(struct blue *bp, class_queue_t *q, u_int32_t flow, argument 301 /* flow of 0 means head of queue */ 302 if ((m = ((flow == 0) ? _getq(q) : _getq_flow(q, flow))) == NULL) { 321 blue_purgeq(struct blue *bp, class_queue_t *q, u_int32_t flow, argument 329 while ((m = blue_getq_flow(bp, q, flow, TRUE)) != NULL) {
|
H A D | classq.c | 139 /* get a packet of a specific flow beginning from the head of the queue */ 141 _getq_flow(class_queue_t *q, u_int32_t flow) argument 146 if (flow == 0 || ((m->m_flags & M_PKTHDR) && 147 m->m_pkthdr.m_flowhash == flow)) { 324 _flushq_flow(class_queue_t *q, u_int32_t flow, u_int32_t *cnt, u_int32_t *len) argument 333 if (flow == 0 || ((m->m_flags & M_PKTHDR) && 334 m->m_pkthdr.m_flowhash == flow)) {
|
H A D | classq_red.c | 470 red_getq_flow(struct red *rp, class_queue_t *q, u_int32_t flow, boolean_t purge) argument 475 /* flow of 0 means head of queue */ 476 if ((m = ((flow == 0) ? _getq(q) : _getq_flow(q, flow))) == NULL) { 495 red_purgeq(struct red *rp, class_queue_t *q, u_int32_t flow, u_int32_t *packets, argument 503 while ((m = red_getq_flow(rp, q, flow, TRUE)) != NULL) {
|
H A D | classq_rio.c | 464 rio_getq_flow(struct rio *rp, class_queue_t *q, u_int32_t flow, boolean_t purge) argument 470 /* flow of 0 means head of queue */ 471 if ((m = ((flow == 0) ? _getq(q) : _getq_flow(q, flow))) == NULL) 495 rio_purgeq(struct rio *rp, class_queue_t *q, u_int32_t flow, u_int32_t *packets, argument 503 while ((m = rio_getq_flow(rp, q, flow, TRUE)) != NULL) {
|
H A D | classq_sfb.c | 182 /* Place the flow control entries in current bin on level 0 */ 384 log(LOG_ERR, "%s: SFB unable to allocate flow control lists\n", 412 /* Move all the flow control entries to the ifnet list */ 530 /* clear/adjust bin statistics and flow control lists */ 650 /* non-conformant or else misclassified flow; queue it anyway */ 722 /* deliver flow control feedback to the sockets */ 750 /* deliver flow control feedback to the sockets */ 818 /* Already on flow control list; just return */ 835 * early-drop probability is kept in pmark of each bin of the flow 942 /* flow contro 1012 sfb_getq_flow(struct sfb *sp, class_queue_t *q, u_int32_t flow, boolean_t purge) argument 1091 sfb_purgeq(struct sfb *sp, class_queue_t *q, u_int32_t flow, u_int32_t *packets, u_int32_t *bytes) argument [all...] |
H A D | if_classq.h | 46 CLASSQRQ_PURGE_SC = 2, /* purge service class (and flow) */ 54 u_int32_t flow; /* (in) 0 means all flows */ member in struct:cqrq_purge_sc 180 /* give flow control feedback */ 182 /* give flow control feedback */ 184 /* give flow control feedback */
|
/darwin-on-arm/xnu/bsd/net/pktsched/ |
H A D | pktsched_priq.c | 248 VERIFY(pr->flow != 0); 255 pr->flow, &pr->packets, &pr->bytes); 264 pr->flow, &cnt, &len); 774 priq_purgeq(struct priq_if *pif, struct priq_class *cl, u_int32_t flow, argument 792 rio_purgeq(cl->cl_rio, &cl->cl_q, flow, &cnt, &len); 797 red_purgeq(cl->cl_red, &cl->cl_q, flow, &cnt, &len); 802 blue_purgeq(cl->cl_blue, &cl->cl_q, flow, &cnt, &len); 806 sfb_purgeq(cl->cl_sfb, &cl->cl_q, flow, &cnt, &len); 808 _flushq_flow(&cl->cl_q, flow, &cnt, &len); 824 "qlen=[%d,%d] cnt=%d len=%d flow [all...] |
H A D | pktsched_tcq.c | 220 VERIFY(pr->flow != 0); 227 pr->flow, &pr->packets, &pr->bytes); 236 pr->flow, &cnt, &len); 735 tcq_purgeq(struct tcq_if *tif, struct tcq_class *cl, u_int32_t flow, argument 751 rio_purgeq(cl->cl_rio, &cl->cl_q, flow, &cnt, &len); 756 red_purgeq(cl->cl_red, &cl->cl_q, flow, &cnt, &len); 761 blue_purgeq(cl->cl_blue, &cl->cl_q, flow, &cnt, &len); 765 sfb_purgeq(cl->cl_sfb, &cl->cl_q, flow, &cnt, &len); 767 _flushq_flow(&cl->cl_q, flow, &cnt, &len); 780 "qlen=[%d,%d] cnt=%d len=%d flow [all...] |
H A D | pktsched_fairq.c | 1084 fairq_purgeq(struct fairq_if *fif, struct fairq_class *cl, u_int32_t flow, argument 1104 rio_purgeq(cl->cl_rio, &b->queue, flow, &cnt, &len); 1109 red_purgeq(cl->cl_red, &b->queue, flow, &cnt, &len); 1114 blue_purgeq(cl->cl_blue, &b->queue, flow, &cnt, &len); 1118 sfb_purgeq(cl->cl_sfb, &b->queue, flow, &cnt, &len); 1120 _flushq_flow(&b->queue, flow, &cnt, &len); 1138 "qlen=[%d,%d] cnt=%d len=%d flow=0x%x\n", 1141 cnt, len, flow);
|
H A D | pktsched_rmclass.c | 1502 rmc_drop(struct rm_class *cl, u_int32_t flow, u_int32_t *packets, argument 1513 rio_purgeq(cl->rio_, &cl->q_, flow, &pkt, &len); 1518 red_purgeq(cl->red_, &cl->q_, flow, &pkt, &len); 1523 blue_purgeq(cl->blue_, &cl->q_, flow, &pkt, &len); 1527 sfb_purgeq(cl->sfb_, &cl->q_, flow, &pkt, &len); 1529 _flushq_flow(&cl->q_, flow, &pkt, &len);
|
H A D | pktsched_qfq.c | 347 VERIFY(pr->flow != 0); 354 pr->flow, &pr->packets, &pr->bytes); 363 pr->flow, &cnt, &len); 1027 * Assign a reasonable start time for a new flow k in group i. 1408 qfq_purgeq(struct qfq_if *qif, struct qfq_class *cl, u_int32_t flow, argument 1424 rio_purgeq(cl->cl_rio, &cl->cl_q, flow, &cnt, &len); 1429 red_purgeq(cl->cl_red, &cl->cl_q, flow, &cnt, &len); 1434 blue_purgeq(cl->cl_blue, &cl->cl_q, flow, &cnt, &len); 1438 sfb_purgeq(cl->cl_sfb, &cl->cl_q, flow, &cnt, &len); 1440 _flushq_flow(&cl->cl_q, flow, [all...] |
H A D | pktsched_hfsc.c | 1017 hfsc_purgeq(struct hfsc_if *hif, struct hfsc_class *cl, u_int32_t flow, argument 1035 rio_purgeq(cl->cl_rio, &cl->cl_q, flow, &cnt, &len); 1040 red_purgeq(cl->cl_red, &cl->cl_q, flow, &cnt, &len); 1045 blue_purgeq(cl->cl_blue, &cl->cl_q, flow, &cnt, &len); 1049 sfb_purgeq(cl->cl_sfb, &cl->cl_q, flow, &cnt, &len); 1051 _flushq_flow(&cl->cl_q, flow, &cnt, &len); 1072 "qlen=[%d,%d] cnt=%d len=%d flow=0x%x\n", 1075 cnt, len, flow);
|
/darwin-on-arm/xnu/bsd/net/ |
H A D | if.c | 1339 if_qflush_sc(struct ifnet *ifp, mbuf_svc_class_t sc, u_int32_t flow, argument 1347 VERIFY(flow != 0); 1353 IFCQ_PURGE_SC(ifq, sc, flow, cnt, len); 1360 ALTQ_PURGE_SC(IFCQ_ALTQ(ifq), sc, flow, a_cnt, a_len); local
|