Lines Matching refs:num_events
306 int num_events = 0; in waitEvents() local
310 while (num_events < min_events) { in waitEvents()
349 num_events += this_events; in waitEvents()
379 unsigned num_events = 0; in cancelEvents() local
387 num_events++; in cancelEvents()
390 if (num_events != end - start) { in cancelEvents()
394 int evs = TEMP_FAILURE_RETRY(io_getevents(mCtx, num_events, AIO_BUFS_MAX, events, nullptr)); in cancelEvents()
395 if (static_cast<unsigned>(evs) != num_events) { in cancelEvents()
401 if (num_events && ::read(mEventFd, &ev_cnt, sizeof(ev_cnt)) == -1) in cancelEvents()
487 unsigned num_events = 0; in receiveFile() local
490 while (num_events < short_i) { in receiveFile()
495 num_events += this_events; in receiveFile()
498 cancelEvents(mIobuf[i].iocb.data(), ioevs, num_events, mIobuf[i].actual); in receiveFile()
611 int num_events = 0; in sendFile() local
613 &num_events) != ret) { in sendFile()
615 cancelEvents(mIobuf[(i-1)%NUM_IO_BUFS].iocb.data(), ioevs, num_events, in sendFile()