diff --git a/tests/automatic/asapo_fabric/parallel_data_transfer.cpp b/tests/automatic/asapo_fabric/parallel_data_transfer.cpp index aa8b34547c820b42c93150703815f16e3dcb3673..07c5fcc5600af523c0d95d572c3549b6cf6ce6b1 100644 --- a/tests/automatic/asapo_fabric/parallel_data_transfer.cpp +++ b/tests/automatic/asapo_fabric/parallel_data_transfer.cpp @@ -33,8 +33,9 @@ void ServerChildThread(FabricServer* server, std::atomic<int>* serverTotalReques // In order to run the tests more stable. Otherwise a timeout could occurred with valgrind int tries = 0; do { + err = nullptr; server->RecvAny(&clientAddress, &messageId, &request, sizeof(request), &err); - } while (err == IOErrorTemplates::kTimeout && tries++ < 2); + } while (err == IOErrorTemplates::kTimeout && tries++ < 4); M_AssertEq(nullptr, err, "server->RecvAny"); M_AssertEq("Hello World", request.message); M_AssertEq(messageId / kEachInstanceRuns, request.data_id); // is client index diff --git a/tests/automatic/asapo_fabric/simple_data_transfer.cpp b/tests/automatic/asapo_fabric/simple_data_transfer.cpp index d5e4d9bda4bddb6d0a39e4d212ac46649bc7b9f6..00da5b38caa82feef7a05ca5ff941557d5337c2c 100644 --- a/tests/automatic/asapo_fabric/simple_data_transfer.cpp +++ b/tests/automatic/asapo_fabric/simple_data_transfer.cpp @@ -38,6 +38,7 @@ void ServerMasterThread(const std::string& hostname, uint16_t port, char* expect // In order to run the tests more stable. Otherwise a timeout could occurred with valgrind int tries = 0; do { + err = nullptr; server->RecvAny(&clientAddress, &messageId, &request, sizeof(request), &err); } while (err == IOErrorTemplates::kTimeout && tries++ < 2); M_AssertEq(nullptr, err, "server->RecvAny"); diff --git a/tests/automatic/asapo_fabric/timeout_test.cpp b/tests/automatic/asapo_fabric/timeout_test.cpp index d71ea1c3a0ed3cd5fa0bad902a3a85bf4f6395b6..fc454fcb5d96e36d82fb7844d8f9481a9106cbec 100644 --- a/tests/automatic/asapo_fabric/timeout_test.cpp +++ b/tests/automatic/asapo_fabric/timeout_test.cpp @@ -33,6 +33,7 @@ void ServerMasterThread(const std::string& hostname, uint16_t port) { // In order to run the tests more stable. Otherwise a timeout could occurred with valgrind int tries = 0; do { + err = nullptr; server->RecvAny(&clientAddress, &messageId, &dummyBuffer, sizeof(dummyBuffer), &err); } while (err == IOErrorTemplates::kTimeout && tries++ < 2); M_AssertEq(nullptr, err, "server->RecvAny"); diff --git a/tests/automatic/asapo_fabric/wrong_memory_info.cpp b/tests/automatic/asapo_fabric/wrong_memory_info.cpp index 76988ddc42322edd0a74550536b0ae86203ed393..8281b4ab0e41683b5b38c8fa33687f2d1a2fe03d 100644 --- a/tests/automatic/asapo_fabric/wrong_memory_info.cpp +++ b/tests/automatic/asapo_fabric/wrong_memory_info.cpp @@ -49,6 +49,7 @@ void ServerMasterThread(const std::string& hostname, uint16_t port) { // Simulate correct memory details int tries = 0; do { + err = nullptr; server->RecvAny(&clientAddress, &messageId, &request, sizeof(request), &err); } while (err == IOErrorTemplates::kTimeout && tries++ < 2); M_AssertEq(nullptr, err, "server->RecvAny(2)"); @@ -62,6 +63,7 @@ void ServerMasterThread(const std::string& hostname, uint16_t port) { GenericRequestHeader request2{}; tries = 0; do { + err = nullptr; server->RecvAny(&clientAddress, &messageId, &request2, sizeof(request2), &err); } while (err == IOErrorTemplates::kTimeout && tries++ < 2); M_AssertEq(nullptr, err, "server->RecvAny(3)"); diff --git a/tests/automatic/consumer/consumer_api_python/consumer_api.py b/tests/automatic/consumer/consumer_api_python/consumer_api.py index 9a491dcea4f61c3c8ec475ac5cb052c9db9bc602..65176c687c8f36d0dc07ae4bcc96c70e2221dff7 100644 --- a/tests/automatic/consumer/consumer_api_python/consumer_api.py +++ b/tests/automatic/consumer/consumer_api_python/consumer_api.py @@ -149,7 +149,7 @@ def check_single(broker,group_id_new): else: exit_on_noerr("wrong query") - broker = asapo_consumer.create_server_broker("bla",path, True, beamtime,"",token,1000) + broker = asapo_consumer.create_server_broker("bla",path, True, beamtime,"",token,1000,network_type) try: broker.get_last(group_id_new, meta_only=True) except asapo_consumer.AsapoUnavailableServiceError as err: diff --git a/tests/automatic/high_avail/services_restart/check_linux.sh b/tests/automatic/high_avail/services_restart/check_linux.sh index 434e13eb1123559347678f51db3e109c9a016da3..c47355c086686345ce73f0eb461e8cdfaec117d5 100644 --- a/tests/automatic/high_avail/services_restart/check_linux.sh +++ b/tests/automatic/high_avail/services_restart/check_linux.sh @@ -62,7 +62,7 @@ nomad run authorizer.nmd nomad run discovery.nmd nomad run receiver_$7.nmd -if ["$4" = "receiver"]; then +if [[ "$4" == "receiver" ]]; then nomad run $4_$7.nmd else nomad run $4.nmd