Lines Matching refs:run
92 struct ng_pipe_hookrun run; member
113 + priv->overhead ) * hinfo->run.fifo_queues * \
303 struct ng_pipe_run *run; in ngp_rcvmsg() local
336 NG_MKRESPONSE(resp, msg, sizeof(*run), M_NOWAIT); in ngp_rcvmsg()
341 run = (struct ng_pipe_run *) resp->data; in ngp_rcvmsg()
342 bcopy(&priv->upper.run, &run->downstream, in ngp_rcvmsg()
343 sizeof(run->downstream)); in ngp_rcvmsg()
344 bcopy(&priv->lower.run, &run->upstream, in ngp_rcvmsg()
345 sizeof(run->upstream)); in ngp_rcvmsg()
606 if (hinfo->run.qin_frames == 0 && hinfo->run.qout_frames == 0 && in ngp_rcvdata()
635 if (hinfo->run.qin_frames == 0) { in ngp_rcvdata()
668 hinfo->run.fifo_queues++; in ngp_rcvdata()
675 hinfo->run.qin_frames++; in ngp_rcvdata()
676 hinfo->run.qin_octets += m->m_pkthdr.len; in ngp_rcvdata()
679 if (hinfo->run.qin_frames > hinfo->cfg.qin_size_limit) { in ngp_rcvdata()
698 hinfo->run.qin_octets -= m1->m_pkthdr.len; in ngp_rcvdata()
704 hinfo->run.fifo_queues--; in ngp_rcvdata()
706 hinfo->run.qin_frames--; in ngp_rcvdata()
784 hinfo->run.qin_frames--; in pipe_dequeue()
785 hinfo->run.qin_octets -= m->m_pkthdr.len; in pipe_dequeue()
813 hinfo->run.fifo_queues--; in pipe_dequeue()
832 hinfo->run.qout_frames>=hinfo->cfg.qout_size_limit) { in pipe_dequeue()
847 hinfo->run.qout_frames++; in pipe_dequeue()
848 hinfo->run.qout_octets += m->m_pkthdr.len; in pipe_dequeue()
862 hinfo->run.qout_frames--; in pipe_dequeue()
863 hinfo->run.qout_octets -= plen; in pipe_dequeue()
879 if ((hinfo->run.qin_frames != 0 || hinfo->run.qout_frames != 0) && in pipe_dequeue()