feat tests: use less address space in tests and fix flaps

Tests: протестировано локально и в CI
commit_hash:6c009b7f44a5516d9637b320e4eb2db83579b688

Author: apolukhin

core/src/components/common_component_list_test.cpp

@@ -32,7 +32,7 @@ constexpr std::string_view kStaticConfig = R"(
 # yaml
 components_manager:
   coro_pool:
-    initial_size: 5000
+    initial_size: 50
     max_size: 50000
   default_task_processor: main-task-processor
   event_thread_pool:

core/src/engine/subprocess/process_starter.cpp

@@ -122,47 +122,53 @@ ProcessStarter::Exec(const std::string& executable_path, const std::vector<std::
     Promise<ChildProcess> promise;
     auto future = promise.get_future();
 
+    LOG_DEBUG() << fmt::format(
+        "do fork() + {}(), executable_path={}, args=[\'{}\'], env=[{}]",
+        options.use_path ? "execv" : "execvp",
+        executable_path,
+        fmt::join(args, "' '"),
+        fmt::join(
+            env | boost::adaptors::transformed([](const auto& key_value) {
+                return key_value.first + '=' + key_value.second;
+            }),
+            ", "
+        )
+    );
     thread_control_.RunInEvLoopAsync([&, promise = std::move(promise)]() mutable {
-        const auto keys = env | boost::adaptors::transformed([](const auto& key_value) {
-                              return key_value.first + '=' + key_value.second;
-                          });
-        LOG_DEBUG() << fmt::format(
-            "do fork() + {}(), executable_path={}, args=[\'{}\'], env=[{}]",
-            options.use_path ? "execv" : "execvp",
-            executable_path,
-            fmt::join(args, "' '"),
-            fmt::join(keys, ", ")
-        );
-
-        const auto pid = utils::CheckSyscall(fork(), "fork");
-        if (pid) {
-            // in parent thread
-            span.AddTag("child-process-pid", pid);
-            LOG_DEBUG() << "Started child process with pid=" << pid;
-            Promise<ChildProcessStatus> exec_result_promise;
-            auto res = ChildProcessMapSet(pid, ev::ChildProcessMapValue(std::move(exec_result_promise)));
-            if (res.second) {
-                promise.set_value(ChildProcess{ChildProcessImpl{pid, res.first->status_promise.get_future()}});
+        try {
+            const auto pid = utils::CheckSyscall(fork(), "fork");
+            if (pid) {
+                // in parent thread
+                span.AddTag("child-process-pid", pid);
+                LOG_DEBUG() << "Started child process with pid=" << pid;
+                Promise<ChildProcessStatus> exec_result_promise;
+                auto res = ChildProcessMapSet(pid, ev::ChildProcessMapValue(std::move(exec_result_promise)));
+                if (res.second) {
+                    promise.set_value(ChildProcess{ChildProcessImpl{pid, res.first->status_promise.get_future()}});
+                } else {
+                    const auto msg = fmt::format("process with pid={} already exists in child_process_map", pid);
+                    LOG_ERROR() << msg << ", send SIGKILL";
+                    ChildProcessImpl(pid, Future<ChildProcessStatus>{}).SendSignal(SIGKILL);
+                    promise.set_exception(std::make_exception_ptr(std::runtime_error(msg)));
+                }
             } else {
-                const auto msg = fmt::format("process with pid={} already exists in child_process_map", pid);
-                LOG_ERROR() << msg << ", send SIGKILL";
-                ChildProcessImpl(pid, Future<ChildProcessStatus>{}).SendSignal(SIGKILL);
-                promise.set_exception(std::make_exception_ptr(std::runtime_error(msg)));
-            }
-        } else {
-            // in child thread
-            try {
+                // in child thread
                 try {
-                    DoExec(executable_path, args, env, options.stdout_file, options.stderr_file, options.use_path);
-                } catch (const std::exception& ex) {
-                    std::cerr << "Cannot execute child: " << ex.what();
+                    try {
+                        DoExec(executable_path, args, env, options.stdout_file, options.stderr_file, options.use_path);
+                    } catch (const std::exception& ex) {
+                        std::cerr << "Cannot execute child: " << ex.what();
+                    }
+                } catch (...) {
+                    // must not do anything in a child
+                    std::abort();
                 }
-            } catch (...) {
-                // must not do anything in a child
+                // on success execve or execvp does not return
                 std::abort();
             }
-            // on success execve or execvp does not return
-            std::abort();
+        } catch (const std::exception& /*e*/) {
+            // utils::CheckSyscall may throw and without the following line a useless "Broken promise" is reported
+            promise.set_exception(std::current_exception());
         }
     });
 

core/src/middlewares/pipeline_test.cpp

@@ -146,7 +146,7 @@ TEST(MiddlewarePipeline, DisableWeakConnection) {
     ASSERT_EQ(expected, list);
 }
 
-TEST(MiddlewarePipeline, DisableStrongConnection) {
+TEST(MiddlewarePipelineDeathTest, DisableStrongConnection) {
     auto dependencies = kDefaultDependencies;
 
     // disable 'grpc-server-congestion-control'
@@ -158,7 +158,7 @@ TEST(MiddlewarePipeline, DisableStrongConnection) {
     EXPECT_UINVARIANT_FAILURE(middlewares::impl::BuildPipeline(std::move(dependencies)));
 }
 
-TEST(MiddlewarePipeline, DependencyToOtherGroup) {
+TEST(MiddlewarePipelineDeathTest, DependencyToOtherGroup) {
     auto dependencies = kDefaultDependencies;
     // Dependency from User to Core is not allowed
     dependencies.insert(Dependency<middlewares::groups::User, U1, Log>(kWeakConnect));