File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -500,9 +500,11 @@ struct SharedMemoryManager
500500 }
501501 else
502502 {
503- // Non-creator: open existing segment, retry briefly if not yet created
504- const int maxRetries = 50 ;
505- const int retryDelayMs = 10 ;
503+ // Non-creator: open existing segment, retry briefly if not yet created.
504+ // Message buffers need longer waits (server subprocess may still be starting),
505+ // data buffers are typically ready immediately (server creates before sending init).
506+ const int maxRetries = 100 ;
507+ const int retryDelayMs = 100 ;
506508 for (int attempt = 0 ; attempt < maxRetries; ++attempt)
507509 {
508510 *shm_fd = shm_open (name.c_str (), O_RDWR, 0666 );
Original file line number Diff line number Diff line change @@ -60,6 +60,7 @@ if(CMAKE_SYSTEM_NAME STREQUAL "Linux")
6060 target_link_libraries (grk_messenger_test rt )
6161endif ()
6262add_test (NAME grk_messenger_test COMMAND grk_messenger_test )
63+ set_tests_properties (grk_messenger_test PROPERTIES RESOURCE_LOCK shm_grok )
6364
6465add_executable (grk_messenger_loopback grk_messenger_loopback.cpp )
6566target_include_directories (grk_messenger_loopback PRIVATE
@@ -70,6 +71,7 @@ if(CMAKE_SYSTEM_NAME STREQUAL "Linux")
7071 target_link_libraries (grk_messenger_loopback rt )
7172endif ()
7273add_test (NAME grk_messenger_loopback COMMAND grk_messenger_loopback )
74+ set_tests_properties (grk_messenger_loopback PROPERTIES RESOURCE_LOCK shm_grok )
7375
7476add_executable (grk_shm_batch_compress grk_shm_batch_compress.cpp )
7577target_include_directories (grk_shm_batch_compress PRIVATE
You can’t perform that action at this time.
0 commit comments