Searched refs:npkts (Results 1 – 4 of 4) sorted by relevance
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() local599 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()[all …]
1149 assert(bunch->hdr.npkts <= BT_MAX_PKTS); in next_bunch()1151 count = bunch->hdr.npkts * sizeof(struct io_pkt); in next_bunch()1273 struct iocb *list[bunch->hdr.npkts]; in process_bunch()1275 assert(0 < bunch->hdr.npkts && bunch->hdr.npkts <= BT_MAX_PKTS); in process_bunch()1276 while (!is_send_done(tip) && (i < bunch->hdr.npkts)) { in process_bunch()1278 int ntodo = min(nfree_current(tip), bunch->hdr.npkts - i); in process_bunch()1307 assert(i <= bunch->hdr.npkts); in process_bunch()
35 __u64 npkts; member
210 __u16 npkts; member