Searched refs:flow (Results 1 - 14 of 14) sorted by relevance

/darwin-on-arm/xnu/bsd/netinet/
H A Dtcp_lro.c55 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 Dclassq_blue.c295 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 Dclassq.c139 /* 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 Dclassq_red.c470 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 Dclassq_rio.c464 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 Dclassq_sfb.c182 /* 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 Dif_classq.h46 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 Dpktsched_priq.c248 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 Dpktsched_tcq.c220 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 Dpktsched_fairq.c1084 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 Dpktsched_rmclass.c1502 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 Dpktsched_qfq.c347 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 Dpktsched_hfsc.c1017 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 Dif.c1339 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

Completed in 102 milliseconds