Lines Matching refs:pendingReads
64 IncFsFd pendingReads; member
67 constexpr IncFsControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs, IncFsFd blocksWritten) in IncFsControl()
68 : cmd(cmd), pendingReads(pendingReads), logs(logs), blocksWritten(blocksWritten) {} in IncFsControl()
403 ab::unique_fd pendingReads(fcntl(cmd.get(), F_DUPFD_CLOEXEC, cmd.get())); in makeControl() local
404 if (!pendingReads.ok()) { in makeControl()
419 IncFs_CreateControl(cmd.get(), pendingReads.get(), logs.get(), blocksWritten.get()); in makeControl()
422 (void)pendingReads.release(); in makeControl()
621 return control->pendingReads; in IncFs_GetControlFd()
639 out[PENDING_READS] = std::exchange(control->pendingReads, -1); in IncFs_ReleaseControlFds()
645 IncFsControl* IncFs_CreateControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs, in IncFs_CreateControl() argument
647 return new IncFsControl(cmd, pendingReads, logs, blocksWritten); in IncFs_CreateControl()
655 if (control->pendingReads >= 0) { in IncFs_DeleteControl()
656 close(control->pendingReads); in IncFs_DeleteControl()
1200 std::vector<RawPendingRead> pendingReads(*bufferSize); in waitForReads() local
1201 if (const auto res = waitForReadsImpl(readFd, timeoutMs, pendingReads.data(), bufferSize)) { in waitForReads()
1205 buffer[i] = convertRead<PublicPendingRead>(pendingReads[i]); in waitForReads()
1221 if (!control || control->pendingReads < 0) { in IncFs_WaitForPendingReads()
1225 return waitForReads(control->pendingReads, timeoutMs, buffer, bufferSize); in IncFs_WaitForPendingReads()
1230 if (!control || control->pendingReads < 0) { in IncFs_WaitForPendingReadsWithUid()
1234 return waitForReads(control->pendingReads, timeoutMs, buffer, bufferSize); in IncFs_WaitForPendingReadsWithUid()