Lines Matching refs:npkts
255 cur->hdr.npkts = 0; in io_bunch_create()
278 assert(cur->hdr.npkts < BT_MAX_PKTS); in io_bunch_add()
281 cur->pkts[cur->hdr.npkts++] = iop; // Struct copy in io_bunch_add()
572 assert(0 < hdrp->npkts && hdrp->npkts <= BT_MAX_PKTS); in bunch_output_hdr()
586 (unsigned long long)hdrp->npkts); in bunch_output_hdr()
597 size_t npkts = stream->cur->hdr.npkts; in bunch_output_pkts() local
599 assert(0 < npkts && npkts <= BT_MAX_PKTS); in bunch_output_pkts()
600 if (fwrite(p, sizeof(struct io_pkt), npkts, stream->ofp) != npkts) { in bunch_output_pkts()
609 for (i = 0; i < npkts; i++, p++) in bunch_output_pkts()
626 if (cur->hdr.npkts) { in stream_flush()
627 assert(cur->hdr.npkts <= BT_MAX_PKTS); in stream_flush()
632 stream->pkts += cur->hdr.npkts; in stream_flush()
645 if (stream->cur->hdr.npkts >= max_pkts_per_bunch) in bunch_done()