Differential D33267 Diff 100628 sys/netpfil/ipfw/dn_aqm_codel.c

Changeset View

Standalone View

sys/netpfil/ipfw/dn_aqm_codel.c

	Show First 20 Lines • Show All 186 Lines • ▼ Show 20 Lines
	* Extract a packet from the head of queue 'q'			* Extract a packet from the head of queue 'q'
	* Return a packet or NULL if the queue is empty.			* Return a packet or NULL if the queue is empty.
	* Also extract packet's timestamp from mtag.			* Also extract packet's timestamp from mtag.
	*/			*/
	struct mbuf *			struct mbuf *
	codel_extract_head(struct dn_queue q, aqm_time_t pkt_ts)			codel_extract_head(struct dn_queue q, aqm_time_t pkt_ts)
	{			{
	struct m_tag *mtag;			struct m_tag *mtag;
	struct mbuf *m = q->mq.head;			struct mbuf *m;

				next: m = q->mq.head;
	if (m == NULL)			if (m == NULL)
	return m;			return m;
	q->mq.head = m->m_nextpkt;			q->mq.head = m->m_nextpkt;

	/* Update stats */			/* Update stats */
	update_stats(q, -m->m_pkthdr.len, 0);			update_stats(q, -m->m_pkthdr.len, 0);

	if (q->ni.length == 0) /* queue is now idle */			if (q->ni.length == 0) /* queue is now idle */
	q->q_time = V_dn_cfg.curr_time;			q->q_time = V_dn_cfg.curr_time;

	/* extract packet TS*/			/* extract packet TS*/
	mtag = m_tag_locate(m, MTAG_ABI_COMPAT, DN_AQM_MTAG_TS, NULL);			mtag = m_tag_locate(m, MTAG_ABI_COMPAT, DN_AQM_MTAG_TS, NULL);
	if (mtag == NULL) {			if (mtag == NULL) {
	D("Codel timestamp mtag not found!");			D("Codel timestamp mtag not found!");
	*pkt_ts = 0;			*pkt_ts = 0;
	} else {			} else {
	pkt_ts = (aqm_time_t *)(mtag + 1);			pkt_ts = (aqm_time_t *)(mtag + 1);
	m_tag_delete(m,mtag);			m_tag_delete(m,mtag);
				}
				if (m->m_pkthdr.rcvif != NULL &&
				__predict_false(m_rcvif_restore(m) == NULL)) {
				m_freem(m);
				goto next;
	}			}

	return m;			return m;
	}			}

	/*			/*
	* Enqueue a packet 'm' in queue 'q'			* Enqueue a packet 'm' in queue 'q'
	*/			*/
	▲ Show 20 Lines • Show All 221 Lines • Show Last 20 Lines