File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed
Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -245,12 +245,14 @@ namespace MultiClientTests
245245 {
246246 service.emplace (ioctx, jobMan);
247247 ioctxRunThread = std::thread{ [&] {pmquell (ioctx.run ()); } };
248+ // wait before every test to ensure that service is available
249+ std::this_thread::sleep_for (50ms);
248250 }
249251 void Cleanup ()
250252 {
251253 service.reset ();
252254 ioctxRunThread.join ();
253- // sleep after every test to ensure that named pipe is no longer available
255+ // sleep after every test to ensure that previous named pipe has vacated
254256 std::this_thread::sleep_for (50ms);
255257 }
256258 ClientProcess LaunchClient (std::vector<std::string> args = {})
@@ -320,7 +322,7 @@ namespace MultiClientTests
320322 // verify frame data received
321323 const auto frames = std::move (client.GetFrames ().frames );
322324 Logger::WriteMessage (std::format (" Read [{}] frames\n " , frames.size ()).c_str ());
323- Assert::IsTrue (frames.size () >= 25ull , L" Minimum threshold frames received" );
325+ Assert::IsTrue (frames.size () >= 20ull , L" Minimum threshold frames received" );
324326 }
325327 };
326328
Original file line number Diff line number Diff line change @@ -86,6 +86,7 @@ int MultiClientTest(std::unique_ptr<pmapi::Session> pSession)
8686 while (std::getline (std::cin, line)) {
8787 if (line == " %quit" ) {
8888 std::cout << " %%{quit-ok}%%" << std::endl;
89+ std::this_thread::sleep_for (25ms);
8990 return 0 ;
9091 }
9192 else if (line == " %get-frames" ) {
You can’t perform that action at this time.
0 commit comments