From d3e2e768c6ed47a5f7e43ebf614046ede9650ada Mon Sep 17 00:00:00 2001 From: "Scott E. Graves" Date: Thu, 26 Dec 2024 10:56:51 -0600 Subject: [PATCH] unit test fixes --- .../repertory_test/src/file_manager_test.cpp | 74 ++++++++++--------- 1 file changed, 39 insertions(+), 35 deletions(-) diff --git a/repertory/repertory_test/src/file_manager_test.cpp b/repertory/repertory_test/src/file_manager_test.cpp index cc5245e5..21ec70a7 100644 --- a/repertory/repertory_test/src/file_manager_test.cpp +++ b/repertory/repertory_test/src/file_manager_test.cpp @@ -431,16 +431,6 @@ TEST_F(file_manager_test, return api_error::success; }); - std::uint64_t handle{}; - std::shared_ptr open_file; -#if defined(_WIN32) - EXPECT_EQ(api_error::success, mgr.open("/test_write_partial_download.txt", - false, {}, handle, open_file)); -#else - EXPECT_EQ(api_error::success, mgr.open("/test_write_partial_download.txt", - false, O_RDWR, handle, open_file)); -#endif - EXPECT_CALL(mp, read_file_bytes) .WillRepeatedly([&file](const std::string & /* api_path */, std::size_t size, std::uint64_t offset, @@ -465,6 +455,17 @@ TEST_F(file_manager_test, return api_error::download_stopped; }); + + std::uint64_t handle{}; + std::shared_ptr open_file; +#if defined(_WIN32) + EXPECT_EQ(api_error::success, mgr.open("/test_write_partial_download.txt", + false, {}, handle, open_file)); +#else + EXPECT_EQ(api_error::success, mgr.open("/test_write_partial_download.txt", + false, O_RDWR, handle, open_file)); +#endif + EXPECT_CALL(mp, set_item_meta("/test_write_partial_download.txt", _)) .WillOnce( [](const std::string &, const api_meta_map &meta2) -> api_error { @@ -588,16 +589,6 @@ TEST_F(file_manager_test, upload_occurs_after_write_if_fully_downloaded) { return api_error::success; }); - std::uint64_t handle{}; - std::shared_ptr open_file; -#if defined(_WIN32) - EXPECT_EQ(api_error::success, mgr.open("/test_write_full_download.txt", false, - {}, handle, open_file)); -#else - EXPECT_EQ(api_error::success, mgr.open("/test_write_full_download.txt", false, - O_RDWR, handle, open_file)); -#endif - EXPECT_CALL(mp, read_file_bytes) .WillRepeatedly([&file](const std::string & /* api_path */, std::size_t size, std::uint64_t offset, @@ -610,6 +601,17 @@ TEST_F(file_manager_test, upload_occurs_after_write_if_fully_downloaded) { EXPECT_EQ(bytes_read, data.size()); return ret; }); + + std::uint64_t handle{}; + std::shared_ptr open_file; +#if defined(_WIN32) + EXPECT_EQ(api_error::success, mgr.open("/test_write_full_download.txt", false, + {}, handle, open_file)); +#else + EXPECT_EQ(api_error::success, mgr.open("/test_write_full_download.txt", false, + O_RDWR, handle, open_file)); +#endif + EXPECT_CALL(mp, set_item_meta("/test_write_full_download.txt", _)) .WillOnce( [](const std::string &, const api_meta_map &meta2) -> api_error { @@ -1478,26 +1480,16 @@ TEST_F(file_manager_test, file_is_closed_after_download_timeout) { event_capture capture({"item_timeout"}); - std::uint64_t handle{}; - std::shared_ptr open_file; -#if defined(_WIN32) - EXPECT_EQ(api_error::success, mgr.open("/test_download_timeout.txt", false, - {}, handle, open_file)); -#else - EXPECT_EQ(api_error::success, mgr.open("/test_download_timeout.txt", false, - O_RDWR, handle, open_file)); -#endif - EXPECT_CALL(mp, read_file_bytes) - .WillRepeatedly([](const std::string & /* api_path */, - std::size_t /*size*/, std::uint64_t offset, - data_buffer & /*data*/, + .WillRepeatedly([](const std::string & /* api_path */, std::size_t size, + std::uint64_t offset, data_buffer &data, stop_type &stop_requested) -> api_error { if (stop_requested) { return api_error::download_stopped; } if (offset == 0U) { + data.resize(size); return api_error::success; } @@ -1508,13 +1500,25 @@ TEST_F(file_manager_test, file_is_closed_after_download_timeout) { return api_error::download_stopped; }); + std::uint64_t handle{}; + std::shared_ptr open_file; +#if defined(_WIN32) + EXPECT_EQ(api_error::success, mgr.open("/test_download_timeout.txt", false, + {}, handle, open_file)); +#else + EXPECT_EQ(api_error::success, mgr.open("/test_download_timeout.txt", false, + O_RDWR, handle, open_file)); +#endif + data_buffer data{}; EXPECT_EQ(api_error::success, open_file->read(1U, 0U, data)); mgr.close(handle); - EXPECT_CALL(mp, set_item_meta("/test_download_timeout.txt", META_SOURCE, _)) - .WillOnce(Return(api_error::success)); + if (open_file->is_write_supported()) { + EXPECT_CALL(mp, set_item_meta("/test_download_timeout.txt", META_SOURCE, _)) + .WillOnce(Return(api_error::success)); + } EXPECT_EQ(std::size_t(1U), mgr.get_open_file_count()); capture.wait_for_empty();