start migration

tests/automatic/asapo_fabric/parallel_data_transfer.cpp

@@ -18,7 +18,7 @@ std::future<void> serverIsDoneFuture = serverIsDone.get_future();
 
 constexpr size_t kRdmaSize = 5 * 1024 * 1024;
 constexpr int kServerThreads = 2;
-constexpr int kEachInstanceRuns = 10;
+constexpr int kEachInstanceRuns = 3;
 constexpr int kClientThreads = 4;
 
 void ServerChildThread(FabricServer* server, std::atomic<int>* serverTotalRequests, char* expectedRdmaBuffer) {

tests/automatic/asapo_fabric/simple_data_transfer.cpp

@@ -17,7 +17,7 @@ std::promise<void> serverIsDone;
 std::future<void> serverIsDoneFuture = serverIsDone.get_future();
 
 constexpr int kTotalRuns = 3;
-constexpr int kEachInstanceRuns = 5;
+constexpr int kEachInstanceRuns = 2;
 constexpr size_t kRdmaSize = 5 * 1024 * 1024;
 
 void ServerMasterThread(const std::string& hostname, uint16_t port, char* expectedRdmaBuffer) {

tests/automatic/full_chain/simple_chain_filegen_batches/check_linux.sh

@@ -51,10 +51,6 @@ sleep 1
 
 token=`$asapo_tool_bin token -endpoint http://localhost:8400/asapo-authorizer -secret admin_token.key -types read $beamtime_id`
 
-
-mkdir  /tmp/asapo/test_in/processed/test1
-mkdir  /tmp/asapo/test_in/processed/test2
-
 #producer
 echo "Start producer"
 mkdir -p ${receiver_folder}
@@ -63,6 +59,10 @@ producerid=`echo $!`
 
 sleep 1
 
+mkdir  /tmp/asapo/test_in/processed/test1
+mkdir  /tmp/asapo/test_in/processed/test2
+
+
 echo hello > /tmp/asapo/test_in/processed/test1/file1
 echo hello > /tmp/asapo/test_in/processed/test1/file2
 echo hello > /tmp/asapo/test_in/processed/test2/file1

tests/automatic/high_avail/receiver_mongo_restart/check_linux.sh

@@ -83,7 +83,7 @@ start_mongo
 
 wait
 
-echo "db.data_default.validate(true)" | mongo --port 27016 ${beamtime_id}_detector
+echo "db.data_default.validate({full: true})" | mongo --port 27016 ${beamtime_id}_detector
 
 echo processed files:
 echo "db.data_default.count()" | mongo --port 27016 ${beamtime_id}_detector

tests/valgrind.suppressions

@@ -95,7 +95,6 @@
    Memcheck:Param
    socketcall.sendto(msg)
    fun:send
-   fun:ofi_send_socket
 }
 {
    asapo_fabric__sockets__leak