Lines Matching refs:pendingReads
62 IncFsFd pendingReads; member
64 constexpr IncFsControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs) in IncFsControl()
65 : cmd(cmd), pendingReads(pendingReads), logs(logs) {} in IncFsControl()
311 unique_fd pendingReads(fcntl(cmd.get(), F_DUPFD_CLOEXEC, cmd.get())); in makeControl() local
312 if (!pendingReads.ok()) { in makeControl()
317 auto control = IncFs_CreateControl(cmd.get(), pendingReads.get(), logs.get()); in makeControl()
320 (void)pendingReads.release(); in makeControl()
490 return control->pendingReads; in IncFs_GetControlFd()
506 out[PENDING_READS] = std::exchange(control->pendingReads, -1); in IncFs_ReleaseControlFds()
511 IncFsControl* IncFs_CreateControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs) { in IncFs_CreateControl() argument
512 return new IncFsControl(cmd, pendingReads, logs); in IncFs_CreateControl()
520 if (control->pendingReads >= 0) { in IncFs_DeleteControl()
521 close(control->pendingReads); in IncFs_DeleteControl()
994 if (!control || control->pendingReads < 0) { in IncFs_WaitForPendingReads()
998 std::vector<incfs_pending_read_info> pendingReads; in IncFs_WaitForPendingReads() local
999 pendingReads.resize(*bufferSize); in IncFs_WaitForPendingReads()
1001 waitForReads(control->pendingReads, timeoutMs, pendingReads.data(), bufferSize)) { in IncFs_WaitForPendingReads()
1006 .bootClockTsUs = pendingReads[i].timestamp_us, in IncFs_WaitForPendingReads()
1007 .block = (IncFsBlockIndex)pendingReads[i].block_index, in IncFs_WaitForPendingReads()
1008 .serialNo = pendingReads[i].serial_number, in IncFs_WaitForPendingReads()
1010 memcpy(&buffer[i].id.data, pendingReads[i].file_id.bytes, sizeof(buffer[i].id.data)); in IncFs_WaitForPendingReads()
1025 std::vector<incfs_pending_read_info> pendingReads; in IncFs_WaitForPageReads() local
1026 pendingReads.resize(*bufferSize); in IncFs_WaitForPageReads()
1027 if (const auto res = waitForReads(logsFd, timeoutMs, pendingReads.data(), bufferSize)) { in IncFs_WaitForPageReads()
1032 .bootClockTsUs = pendingReads[i].timestamp_us, in IncFs_WaitForPageReads()
1033 .block = (IncFsBlockIndex)pendingReads[i].block_index, in IncFs_WaitForPageReads()
1034 .serialNo = pendingReads[i].serial_number, in IncFs_WaitForPageReads()
1036 memcpy(&buffer[i].id.data, pendingReads[i].file_id.bytes, sizeof(buffer[i].id.data)); in IncFs_WaitForPageReads()