Lines Matching refs:control_
53 auto wfd = openForSpecialOps(control_, fileId(id)); in writeTestRanges()
109 auto fd = openForSpecialOps(control_, fileId(1)); in writeBlock()
126 ASSERT_TRUE(control_.logs() >= 0); in testWriteBlockAndPageRead()
128 makeFile(control_, mountPath(test_file_name_), 0555, id, in testWriteBlockAndPageRead()
134 auto res = waitForPageReads(control_, std::chrono::seconds(5), &reads); in testWriteBlockAndPageRead()
161 makeFile(control_, mountPath(test_file_name_), 0555, id, in testWaitForPendingReads()
167 waitForPendingReads(control_, std::chrono::seconds(10), &pending_reads)); in testWaitForPendingReads()
179 auto fd = openForSpecialOps(control_, fileId(1)); in testWaitForPendingReads()
219 ASSERT_EQ(0, makeDir(control_, mountPath(test_dir_name_))); in TEST_F()
233 makeFile(control_, mountPath(test_file_name_), 0555, fileId(1), in TEST_F()
243 ASSERT_TRUE(control_); in TEST_F()
244 EXPECT_GE(IncFs_GetControlFd(control_, CMD), 0); in TEST_F()
245 EXPECT_GE(IncFs_GetControlFd(control_, PENDING_READS), 0); in TEST_F()
246 EXPECT_GE(IncFs_GetControlFd(control_, LOGS), 0); in TEST_F()
247 EXPECT_EQ((features() & Features::v2) != 0, IncFs_GetControlFd(control_, BLOCKS_WRITTEN) >= 0); in TEST_F()
249 auto fds = control_.releaseFds(); in TEST_F()
254 ASSERT_TRUE(control_); in TEST_F()
255 EXPECT_LT(IncFs_GetControlFd(control_, CMD), 0); in TEST_F()
256 EXPECT_LT(IncFs_GetControlFd(control_, PENDING_READS), 0); in TEST_F()
257 EXPECT_LT(IncFs_GetControlFd(control_, LOGS), 0); in TEST_F()
258 EXPECT_LT(IncFs_GetControlFd(control_, BLOCKS_WRITTEN), 0); in TEST_F()
260 control_.close(); in TEST_F()
261 EXPECT_FALSE(control_); in TEST_F()
286 ASSERT_EQ(makeDir(control_, dir_path), 0); in TEST_F()
293 ASSERT_EQ(makeDirs(control_, dir_path), 0); in TEST_F()
295 ASSERT_EQ(makeDirs(control_, dir_path), 0); in TEST_F()
297 ASSERT_EQ(makeDirs(control_, nested), 0); in TEST_F()
299 ASSERT_NE(makeDirs(control_, "/"), 0); in TEST_F()
305 ASSERT_EQ(0, makeDir(control_, mountPath(test_dir_name_))); in TEST_F()
311 makeFile(control_, test_file, 0555, fileId(1), in TEST_F()
326 ASSERT_EQ(mount_dir_path_, root(control_)) << "Error: " << errno; in TEST_F()
351 ASSERT_EQ(0, makeDir(control_, mountPath(test_dir_name_))); in TEST_F()
355 makeFile(control_, file_path, 0111, fileId(1), in TEST_F()
363 ASSERT_EQ(0, makeDir(control_, mountPath(test_dir_name_))); in TEST_F()
367 makeFile(control_, file_path, 0555, fileId(1), in TEST_F()
375 ASSERT_EQ(0, makeDir(control_, mountPath(test_dir_name_))); in TEST_F()
384 makeFile(control_, file_path, 0111, fileId(1), in TEST_F()
393 makeMappedFile(control_, mapped_file_path, 0111, in TEST_F()
402 ASSERT_EQ(fileId(1), getFileId(control_, file_path)); in TEST_F()
404 ASSERT_EQ(kIncFsInvalidFileId, getFileId(control_, mapped_file_path)); in TEST_F()
410 makeFile(control_, mountPath(test_file_name_), 0555, id, in TEST_F()
412 EXPECT_EQ(id, getFileId(control_, mountPath(test_file_name_))) << "errno = " << errno; in TEST_F()
413 EXPECT_EQ(kIncFsInvalidFileId, getFileId(control_, test_file_name_)); in TEST_F()
414 EXPECT_EQ(kIncFsInvalidFileId, getFileId(control_, "asdf")); in TEST_F()
421 makeFile(control_, mountPath(test_file_name_), 0555, fileId(1), in TEST_F()
424 const auto raw_metadata = getMetadata(control_, mountPath(test_file_name_)); in TEST_F()
430 const auto raw_metadata = getMetadata(control_, fileId(1)); in TEST_F()
438 ASSERT_EQ(0, makeFile(control_, mountPath(test_file_name_), 0555, fileId(1), {.size = 0})); in TEST_F()
439 ASSERT_EQ(0, makeDir(control_, mountPath(test_dir_name_))); in TEST_F()
443 ASSERT_EQ(0, link(control_, mountPath(test_file_name_), linked_file_path)); in TEST_F()
445 ASSERT_EQ(0, unlink(control_, linked_file_path)); in TEST_F()
482 makeFile(control_, mountPath(test_file_name_), 0555, fileId(1), in TEST_F()
487 auto fd = openForSpecialOps(control_, fileId(1)); in TEST_F()
512 EXPECT_EQ(-ENODATA, IncFs_IsEverythingFullyLoaded(control_)); in TEST_F()
546 EXPECT_EQ(-ENODATA, IncFs_IsEverythingFullyLoaded(control_)); in TEST_F()
575 EXPECT_EQ(-ENODATA, IncFs_IsEverythingFullyLoaded(control_)); in TEST_F()
616 EXPECT_EQ(-ENODATA, IncFs_IsEverythingFullyLoaded(control_)); in TEST_F()
644 EXPECT_EQ(0, IncFs_IsEverythingFullyLoaded(control_)); in TEST_F()
649 makeFile(control_, mountPath(test_file_name_), 0555, fileId(1), in TEST_F()
653 auto fd = openForSpecialOps(control_, fileId(1)); in TEST_F()
713 auto fd = openForSpecialOps(control_, fileId(1)); in TEST_F()
737 auto fd = openForSpecialOps(control_, fileId(1)); in TEST_F()
776 EXPECT_EQ(LoadingState::MissingBlocks, isEverythingFullyLoaded(control_)); in TEST_F()
796 EXPECT_EQ(LoadingState::Full, isEverythingFullyLoaded(control_)); in TEST_F()
806 makeFile(control_, mountPath(test_file_name_), 0555, id, {.size = test_file_size_})); in TEST_F()
809 ASSERT_EQ(0, IncFs_WaitForFsWrittenBlocksChange(control_, 0, &blocksWritten)); in TEST_F()
812 auto fd = openForSpecialOps(control_, fileId(1)); in TEST_F()
825 ASSERT_EQ(0, IncFs_WaitForFsWrittenBlocksChange(control_, 0, &blocksWritten)); in TEST_F()
837 EXPECT_EQ(0, IncFs_SetUidReadTimeouts(control_, timeouts, std::size(timeouts))); in TEST_F()
842 EXPECT_EQ(-E2BIG, IncFs_GetUidReadTimeouts(control_, outTimeouts, &outSize)); in TEST_F()
846 EXPECT_EQ(0, IncFs_GetUidReadTimeouts(control_, outTimeouts, &outSize)); in TEST_F()
859 EXPECT_EQ(0, IncFs_ListIncompleteFiles(control_, nullptr, &count)); in TEST_F()
861 EXPECT_EQ(0, IncFs_WaitForLoadingComplete(control_, 0)); in TEST_F()
872 makeFile(control_, mountPath(test_file_name_), 0555, id, {.size = test_file_size_})); in TEST_F()
875 EXPECT_EQ(-E2BIG, IncFs_ListIncompleteFiles(control_, nullptr, &count)); in TEST_F()
877 EXPECT_EQ(-ETIMEDOUT, IncFs_WaitForLoadingComplete(control_, 0)); in TEST_F()
881 EXPECT_EQ(0, IncFs_ListIncompleteFiles(control_, ids, &count)); in TEST_F()
885 auto fd = openForSpecialOps(control_, id); in TEST_F()
898 EXPECT_EQ(0, IncFs_ListIncompleteFiles(control_, ids, &count)); in TEST_F()
900 EXPECT_EQ(0, IncFs_WaitForLoadingComplete(control_, 0)); in TEST_F()
911 makeFile(control_, mountPath(test_file_name_), 0555, id, {.size = test_file_size_})); in TEST_F()
914 EXPECT_EQ(-E2BIG, IncFs_ListIncompleteFiles(control_, nullptr, &count)); in TEST_F()
916 EXPECT_EQ(-ETIMEDOUT, IncFs_WaitForLoadingComplete(control_, 0)); in TEST_F()
920 ASSERT_EQ(0, makeFile(control_, mountPath("test2"), 0555, id2, {.size = test_file_size_})); in TEST_F()
924 EXPECT_EQ(0, IncFs_ListIncompleteFiles(control_, ids, &count)); in TEST_F()
929 auto fd = openForSpecialOps(control_, id); in TEST_F()
942 EXPECT_EQ(0, IncFs_ListIncompleteFiles(control_, ids, &count)); in TEST_F()
945 EXPECT_EQ(-ETIMEDOUT, IncFs_WaitForLoadingComplete(control_, 0)); in TEST_F()
955 makeFile(control_, mountPath("test1"), 0555, fileId(1), in TEST_F()
958 makeFile(control_, mountPath("test2"), 0555, fileId(2), in TEST_F()
961 makeFile(control_, mountPath("test3"), 0555, fileId(3), in TEST_F()
965 auto waiter = std::thread([&] { res = IncFs_WaitForLoadingComplete(control_, 5 * 1000); }); in TEST_F()
970 auto fd = openForSpecialOps(control_, fileId(1)); in TEST_F()
984 auto fd = openForSpecialOps(control_, fileId(3)); in TEST_F()
998 auto fd = openForSpecialOps(control_, fileId(2)); in TEST_F()
1015 if (IncFs_ListIncompleteFiles(control_, ids, &count) != 0) { in TEST_F()
1035 makeFile(control_, mountPath(test_file_name_), 0555, id, in TEST_F()
1040 IncFs_GetFileBlockCountByPath(control_, mountPath(test_file_name_).c_str(), &counts)); in TEST_F()
1046 EXPECT_EQ(0, IncFs_GetFileBlockCountById(control_, id, &counts)); in TEST_F()
1052 auto fd = openForSpecialOps(control_, id); in TEST_F()
1065 IncFs_GetFileBlockCountByPath(control_, mountPath(test_file_name_).c_str(), &counts)); in TEST_F()
1071 EXPECT_EQ(0, IncFs_GetFileBlockCountById(control_, id, &counts)); in TEST_F()
1089 IncFs_GetFileBlockCountByPath(control_, mountPath(test_file_name_).c_str(), &counts)); in TEST_F()
1098 IncFs_GetFileBlockCountByPath(control_, mountPath(test_file_name_).c_str(), &counts)); in TEST_F()
1110 IncFs_ReserveSpaceByPath(control_, mountPath("1"s += test_file_name_).c_str(), size)); in TEST_F()
1111 EXPECT_EQ(0, IncFs_ReserveSpaceByPath(control_, mountPath(test_file_name_).c_str(), size)); in TEST_F()
1112 EXPECT_EQ(0, IncFs_ReserveSpaceByPath(control_, mountPath(test_file_name_).c_str(), 2 * size)); in TEST_F()
1113 EXPECT_EQ(0, IncFs_ReserveSpaceByPath(control_, mountPath(test_file_name_).c_str(), 2 * size)); in TEST_F()
1115 IncFs_ReserveSpaceByPath(control_, mountPath(test_file_name_).c_str(), in TEST_F()
1118 IncFs_ReserveSpaceByPath(control_, mountPath(test_file_name_).c_str(), in TEST_F()
1121 EXPECT_EQ(-ENOENT, IncFs_ReserveSpaceById(control_, fileId(2), size)); in TEST_F()
1122 EXPECT_EQ(0, IncFs_ReserveSpaceById(control_, fileId(1), size)); in TEST_F()
1123 EXPECT_EQ(0, IncFs_ReserveSpaceById(control_, fileId(1), 2 * size)); in TEST_F()
1124 EXPECT_EQ(0, IncFs_ReserveSpaceById(control_, fileId(1), 2 * size)); in TEST_F()
1125 EXPECT_EQ(0, IncFs_ReserveSpaceById(control_, fileId(1), kTrimReservedSpace)); in TEST_F()
1126 EXPECT_EQ(0, IncFs_ReserveSpaceById(control_, fileId(1), kTrimReservedSpace)); in TEST_F()
1133 EXPECT_EQ(-EINVAL, IncFs_ForEachFile(control_, nullptr, nullptr)); in TEST_F()
1134 EXPECT_EQ(-EINVAL, IncFs_ForEachIncompleteFile(control_, nullptr, nullptr)); in TEST_F()
1135 EXPECT_EQ(0, IncFs_ForEachFile(control_, nullptr, [](auto, auto, auto) { return true; })); in TEST_F()
1137 IncFs_ForEachIncompleteFile(control_, nullptr, in TEST_F()
1139 EXPECT_EQ(0, IncFs_ForEachFile(control_, this, [](auto, auto, auto) { return true; })); in TEST_F()
1141 IncFs_ForEachIncompleteFile(control_, this, [](auto, auto, auto) { return true; })); in TEST_F()
1143 int res = makeFile(control_, mountPath("incomplete.txt"), 0555, fileId(1), in TEST_F()
1147 EXPECT_EQ(1, IncFs_ForEachFile(control_, this, [](auto, auto context, auto id) { in TEST_F()
1153 IncFs_ForEachIncompleteFile(control_, this, [](auto, auto, auto) { return true; })); in TEST_F()
1158 EXPECT_EQ(1, IncFs_ForEachFile(control_, this, [](auto, auto context, auto id) { in TEST_F()
1163 EXPECT_EQ(2, IncFs_ForEachFile(control_, this, [](auto, auto context, auto id) { in TEST_F()
1169 IncFs_ForEachIncompleteFile(control_, this, [](auto, auto context, auto id) { in TEST_F()
1196 EXPECT_EQ(0, IncFs_GetLastReadError(control_, &lastReadError)); in TEST_F()
1222 makeFile(control_, mountPath(test_file_name_), 0555, id, in TEST_F()
1236 EXPECT_EQ(0, IncFs_GetLastReadError(control_, &lastReadError)); in TEST_F()
1265 auto wfd = openForSpecialOps(control_, id); in TEST_F()
1303 EXPECT_EQ(0, IncFs_GetLastReadError(control_, &lastReadError)); in TEST_F()
1329 ASSERT_EQ(0, makeFile(control_, mountPath(test_file_name_), 0555, id, {.size = testFileSize})); in TEST_F()
1333 waitForPendingReads(control_, std::chrono::seconds(1), &pending_reads)); in TEST_F()
1336 auto fd = openForSpecialOps(control_, fileId(1)); in TEST_F()
1357 EXPECT_EQ(0, IncFs_GetLastReadError(control_, &lastReadError)); in TEST_F()
1382 ASSERT_EQ(0, makeFile(control_, mountPath(test_file_name_), 0555, id, {.size = testFileSize})); in TEST_F()
1384 auto fdToFill = openForSpecialOps(control_, fileId(1)); in TEST_F()
1400 ASSERT_EQ(0, IncFs_SetUidReadTimeouts(control_, timeouts, std::size(timeouts))); in TEST_F()
1408 EXPECT_EQ(0, IncFs_GetLastReadError(control_, &lastReadError)); in TEST_F()
1434 ASSERT_EQ(0, makeDir(control_, mountPath(test_dir_name_))); in TEST_F()
1445 makeFile(control_, file_path, 0111, file_id, in TEST_F()
1454 makeMappedFile(control_, mapped_file_path, 0111, in TEST_F()
1463 ASSERT_EQ(LoadingState::MissingBlocks, isFullyLoaded(control_, file_path)); in TEST_F()
1464 ASSERT_EQ(LoadingState::MissingBlocks, isFullyLoaded(control_, file_id)); in TEST_F()
1465 ASSERT_EQ((LoadingState)-ENOTSUP, isFullyLoaded(control_, mapped_file_path)); in TEST_F()
1468 ASSERT_EQ(BlockCounts{.totalDataBlocks = 2}, *getBlockCount(control_, file_path)); in TEST_F()
1469 ASSERT_EQ(BlockCounts{.totalDataBlocks = 2}, *getBlockCount(control_, file_id)); in TEST_F()
1470 ASSERT_FALSE(getBlockCount(control_, mapped_file_path)); in TEST_F()
1476 ASSERT_EQ(LoadingState::MissingBlocks, isFullyLoaded(control_, file_path)); in TEST_F()
1477 ASSERT_EQ(LoadingState::MissingBlocks, isFullyLoaded(control_, file_id)); in TEST_F()
1478 ASSERT_EQ((LoadingState)-ENOTSUP, isFullyLoaded(control_, mapped_file_path)); in TEST_F()
1481 ASSERT_EQ(onePage, *getBlockCount(control_, file_path)); in TEST_F()
1482 ASSERT_EQ(onePage, *getBlockCount(control_, file_id)); in TEST_F()
1483 ASSERT_FALSE(getBlockCount(control_, mapped_file_path)); in TEST_F()
1489 ASSERT_EQ(LoadingState::Full, isFullyLoaded(control_, file_path)); in TEST_F()
1490 ASSERT_EQ(LoadingState::Full, isFullyLoaded(control_, file_id)); in TEST_F()
1491 ASSERT_EQ((LoadingState)-ENOTSUP, isFullyLoaded(control_, mapped_file_path)); in TEST_F()
1494 ASSERT_EQ(twoPages, *getBlockCount(control_, file_path)); in TEST_F()
1495 ASSERT_EQ(twoPages, *getBlockCount(control_, file_id)); in TEST_F()
1496 ASSERT_FALSE(getBlockCount(control_, mapped_file_path)); in TEST_F()