diff options
| author | Dan Engelbrecht <[email protected]> | 2023-05-11 00:05:32 +0200 |
|---|---|---|
| committer | Dan Engelbrecht <[email protected]> | 2023-05-11 00:05:32 +0200 |
| commit | 7ee9c3f72d268966612dec914460cca90bb8e4fe (patch) | |
| tree | f647eca49bcb90b002d7189d336d905de9e96132 /src/zenserver-test/zenserver-test.cpp | |
| parent | need to set 'id' for user info in sentry (#287) (diff) | |
| download | zen-7ee9c3f72d268966612dec914460cca90bb8e4fe.tar.xz zen-7ee9c3f72d268966612dec914460cca90bb8e4fe.zip | |
Revert "add timeout to server spawns in tests"
This reverts commit b8a305713892cb23907ca61e07a70bdfb73ac2f5.
Diffstat (limited to 'src/zenserver-test/zenserver-test.cpp')
| -rw-r--r-- | src/zenserver-test/zenserver-test.cpp | 44 |
1 files changed, 22 insertions, 22 deletions
diff --git a/src/zenserver-test/zenserver-test.cpp b/src/zenserver-test/zenserver-test.cpp index f690444e0..3195181d1 100644 --- a/src/zenserver-test/zenserver-test.cpp +++ b/src/zenserver-test/zenserver-test.cpp @@ -374,7 +374,7 @@ TEST_CASE("default.single") ZEN_INFO("Waiting..."); - CHECK(Instance.WaitUntilReady(2000)); + Instance.WaitUntilReady(); std::atomic<uint64_t> RequestCount{0}; std::atomic<uint64_t> BatchCounter{0}; @@ -429,8 +429,8 @@ TEST_CASE("multi.basic") ZEN_INFO("Waiting..."); - CHECK(Instance1.WaitUntilReady(2000)); - CHECK(Instance2.WaitUntilReady(2000)); + Instance1.WaitUntilReady(); + Instance2.WaitUntilReady(); std::atomic<uint64_t> RequestCount{0}; std::atomic<uint64_t> BatchCounter{0}; @@ -477,7 +477,7 @@ TEST_CASE("project.basic") ZenServerInstance Instance1(TestEnv); Instance1.SetTestDir(TestDir); Instance1.SpawnServer(PortNumber); - CHECK(Instance1.WaitUntilReady(2000)); + Instance1.WaitUntilReady(); std::atomic<uint64_t> RequestCount{0}; @@ -643,7 +643,7 @@ TEST_CASE("project.pipe") ZenServerInstance Instance1(TestEnv); Instance1.SetTestDir(TestDir); Instance1.SpawnServer(PortNumber); - CHECK(Instance1.WaitUntilReady(2000)); + Instance1.WaitUntilReady(); zen::LocalProjectClient LocalClient(PortNumber); @@ -690,7 +690,7 @@ namespace utils { { Inst.SetTestDir(DataDir); Inst.SpawnServer(Port, Args); - CHECK(Inst.WaitUntilReady(2000)); + Inst.WaitUntilReady(); } }; @@ -698,7 +698,7 @@ namespace utils { { Server.SetTestDir(Cfg.DataDir); Server.SpawnServer(Cfg.Port, Cfg.Args); - CHECK(Server.WaitUntilReady(2000)); + Server.WaitUntilReady(); } } // namespace utils @@ -720,7 +720,7 @@ TEST_CASE("zcache.basic") ZenServerInstance Instance1(TestEnv); Instance1.SetTestDir(TestDir); Instance1.SpawnServer(PortNumber); - CHECK(Instance1.WaitUntilReady(2000)); + Instance1.WaitUntilReady(); // Populate with some simple data @@ -778,7 +778,7 @@ TEST_CASE("zcache.basic") ZenServerInstance Instance1(TestEnv); Instance1.SetTestDir(TestDir); Instance1.SpawnServer(PortNumber); - CHECK(Instance1.WaitUntilReady(2000)); + Instance1.WaitUntilReady(); // Retrieve data again @@ -862,7 +862,7 @@ TEST_CASE("zcache.cbpackage") ZenServerInstance Instance1(TestEnv); Instance1.SetTestDir(TestDir); Instance1.SpawnServer(PortNumber); - CHECK(Instance1.WaitUntilReady(2000)); + Instance1.WaitUntilReady(); const std::string_view Bucket = "mosdef"sv; zen::IoHash Key; @@ -906,13 +906,13 @@ TEST_CASE("zcache.cbpackage") ZenServerInstance RemoteInstance(TestEnv); RemoteInstance.SetTestDir(RemoteDataDir); RemoteInstance.SpawnServer(RemotePortNumber); - CHECK(RemoteInstance.WaitUntilReady(2000)); + RemoteInstance.WaitUntilReady(); ZenServerInstance LocalInstance(TestEnv); LocalInstance.SetTestDir(LocalDataDir); LocalInstance.SpawnServer(LocalPortNumber, fmt::format("--upstream-thread-count=0 --upstream-zen-url=http://localhost:{}", RemotePortNumber)); - CHECK(LocalInstance.WaitUntilReady(2000)); + LocalInstance.WaitUntilReady(); const std::string_view Bucket = "mosdef"sv; zen::IoHash Key; @@ -969,13 +969,13 @@ TEST_CASE("zcache.cbpackage") ZenServerInstance RemoteInstance(TestEnv); RemoteInstance.SetTestDir(RemoteDataDir); RemoteInstance.SpawnServer(RemotePortNumber); - CHECK(RemoteInstance.WaitUntilReady(2000)); + RemoteInstance.WaitUntilReady(); ZenServerInstance LocalInstance(TestEnv); LocalInstance.SetTestDir(LocalDataDir); LocalInstance.SpawnServer(LocalPortNumber, fmt::format("--upstream-thread-count=0 --upstream-zen-url=http://localhost:{}", RemotePortNumber)); - CHECK(LocalInstance.WaitUntilReady(2000)); + LocalInstance.WaitUntilReady(); const std::string_view Bucket = "mosdef"sv; zen::IoHash Key; @@ -1460,7 +1460,7 @@ TEST_CASE("zcache.rpc") ZenServerInstance Inst(TestEnv); Inst.SetTestDir(TestDir); Inst.SpawnServer(PortNumber); - CHECK(Inst.WaitUntilReady(2000)); + Inst.WaitUntilReady(); CachePolicy Policy = CachePolicy::Default; std::vector<zen::CacheKey> Keys = PutCacheRecords(BaseUri, "ue4.ddc"sv, "mastodon"sv, 128); @@ -1491,7 +1491,7 @@ TEST_CASE("zcache.rpc") ZenServerInstance Inst(TestEnv); Inst.SetTestDir(TestDir); Inst.SpawnServer(PortNumber); - CHECK(Inst.WaitUntilReady(2000)); + Inst.WaitUntilReady(); CachePolicy Policy = CachePolicy::Default; std::vector<zen::CacheKey> ExistingKeys = PutCacheRecords(BaseUri, "ue4.ddc"sv, "mastodon"sv, 128); @@ -1591,7 +1591,7 @@ TEST_CASE("zcache.rpc") ZenServerInstance Inst(TestEnv); Inst.SetTestDir(TestDir); Inst.SpawnServer(PortNumber); - CHECK(Inst.WaitUntilReady(2000)); + Inst.WaitUntilReady(); std::vector<zen::CacheKey> SmallKeys = PutCacheRecords(BaseUri, "ue4.ddc"sv, "mastodon"sv, 4, 1024); std::vector<zen::CacheKey> LargeKeys = PutCacheRecords(BaseUri, "ue4.ddc"sv, "mastodon"sv, 4, 1024 * 1024 * 16, SmallKeys.size()); @@ -2536,7 +2536,7 @@ public: { auto& Instance = m_Instances[i]; - CHECK(Instance->WaitUntilReady(2000)); + Instance->WaitUntilReady(); } } @@ -2679,7 +2679,7 @@ TEST_CASE("websocket.basic") ZenServerInstance Inst(TestEnv); Inst.SetTestDir(TestDir); Inst.SpawnServer(PortNumber, "--websocket-port=8848"sv); - CHECK(Inst.WaitUntilReady(2000)); + Inst.WaitUntilReady(); asio::io_context IoCtx; IoDispatcher IoDispatcher(IoCtx); @@ -3266,14 +3266,14 @@ TEST_CASE("lifetime.owner") std::filesystem::path TestDir1 = TestEnv.CreateNewTestDir(); Zen1.SetTestDir(TestDir1); Zen1.SpawnServer(PortNumber); - CHECK(Zen1.WaitUntilReady(2000)); + Zen1.WaitUntilReady(); Zen1.Detach(); ZenServerInstance Zen2(TestEnv); std::filesystem::path TestDir2 = TestEnv.CreateNewTestDir(); Zen2.SetTestDir(TestDir2); Zen2.SpawnServer(PortNumber); - CHECK(Zen2.WaitUntilReady(2000)); + Zen2.WaitUntilReady(); Zen2.Detach(); } @@ -3292,7 +3292,7 @@ TEST_CASE("lifetime.owner.2") ZenServerInstance Zen1(TestEnv); Zen1.SetTestDir(TestDir1); Zen1.SpawnServer(PortNumber); - CHECK(Zen1.WaitUntilReady(2000)); + Zen1.WaitUntilReady(); ZenServerInstance Zen2(TestEnv); Zen2.SetTestDir(TestDir2); |