Lines Matching refs:num_events
307 int num_events = 0; in waitEvents() local
311 while (num_events < min_events) { in waitEvents()
350 num_events += this_events; in waitEvents()
380 unsigned num_events = 0; in cancelEvents() local
388 num_events++; in cancelEvents()
390 if (is_batch_cancel && num_events == 1) { in cancelEvents()
391 num_events = end - start; in cancelEvents()
395 if (num_events != end - start) { in cancelEvents()
399 int evs = TEMP_FAILURE_RETRY(io_getevents(mCtx, num_events, AIO_BUFS_MAX, events, nullptr)); in cancelEvents()
400 if (static_cast<unsigned>(evs) != num_events) { in cancelEvents()
406 if (num_events && ::read(mEventFd, &ev_cnt, sizeof(ev_cnt)) == -1) in cancelEvents()
492 unsigned num_events = 0; in receiveFile() local
495 while (num_events < short_i) { in receiveFile()
500 num_events += this_events; in receiveFile()
503 cancelEvents(mIobuf[i].iocb.data(), ioevs, num_events, mIobuf[i].actual, in receiveFile()
618 int num_events = 0; in sendFile() local
620 &num_events) != ret) { in sendFile()
622 cancelEvents(mIobuf[(i-1)%NUM_IO_BUFS].iocb.data(), ioevs, num_events, in sendFile()