This is an automated email from the ASF dual-hosted git repository.
isapego pushed a commit to branch ignite-27304
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/ignite-27304 by this push:
new 682a1239a2a IGNITE-27304: Fix startup logic
682a1239a2a is described below
commit 682a1239a2a6338f15001629a6fc30a32cf44612
Author: Igor Sapego <[email protected]>
AuthorDate: Mon Mar 23 22:49:30 2026 +0100
IGNITE-27304: Fix startup logic
---
modules/platforms/cpp/ignite/client/ignite_client.cpp | 14 --------------
modules/platforms/cpp/tests/client-test/main.cpp | 12 ++++++++----
2 files changed, 8 insertions(+), 18 deletions(-)
diff --git a/modules/platforms/cpp/ignite/client/ignite_client.cpp
b/modules/platforms/cpp/ignite/client/ignite_client.cpp
index 6aa5f316345..b821aa3dead 100644
--- a/modules/platforms/cpp/ignite/client/ignite_client.cpp
+++ b/modules/platforms/cpp/ignite/client/ignite_client.cpp
@@ -45,25 +45,11 @@ ignite_client
ignite_client::start(ignite_client_configuration configuration, st
auto status = future.wait_for(timeout);
- std::cout << "Status: " << int(status) << std::endl;
- std::cout << "std::future_status::ready: " <<
int(std::future_status::ready) << std::endl;
- std::cout << "std::future_status::deferred: " <<
int(std::future_status::deferred) << std::endl;
- std::cout << "std::future_status::timeout: " <<
int(std::future_status::timeout) << std::endl;
-
- std::cout << "status == std::future_status::ready: " << bool(status ==
std::future_status::ready) << std::endl;
- std::cout << "status == std::future_status::deferred: " << bool(status ==
std::future_status::deferred) << std::endl;
- std::cout << "status == std::future_status::timeout: " << bool(status ==
std::future_status::timeout) << std::endl;
-
if (status == std::future_status::timeout) {
impl->stop();
- std::cout << "Before throw" << std::endl;
throw ignite_error(error::code::CONNECTION, "Can not establish
connection within timeout");
- std::cout << "After throw" << std::endl;
}
- std::cout << "After throw 2" << std::endl;
-
-
assert(status == std::future_status::ready);
auto res = future.get();
if (res.has_error()) {
diff --git a/modules/platforms/cpp/tests/client-test/main.cpp
b/modules/platforms/cpp/tests/client-test/main.cpp
index 9139c2e6119..2b1e3749e8e 100644
--- a/modules/platforms/cpp/tests/client-test/main.cpp
+++ b/modules/platforms/cpp/tests/client-test/main.cpp
@@ -71,24 +71,28 @@ int main(int argc, char **argv) {
ignite_runner runner;
set_process_abort_handler([&](int signal) {
- std::cout << "Caught signal " << signal << " during tests" <<
std::endl;
+ std::cerr << "Caught signal " << signal << " during tests" <<
std::endl;
runner.stop();
});
if (!check_test_node_connectable(std::chrono::seconds(5))) {
runner.start();
- ensure_node_connectable(std::chrono::seconds(60));
+ auto timeout = std::chrono::minutes(5);
+ if (!check_test_node_connectable(timeout)) {
+ std::cerr << "Failed to start node within timeout: " <<
timeout.count() << "min" << std::endl;
+ return 3;
+ }
}
try {
::testing::InitGoogleTest(&argc, argv);
[[maybe_unused]] int run_res = RUN_ALL_TESTS();
} catch (const std::exception &err) {
- std::cout << "Uncaught error: " << err.what() << std::endl;
+ std::cerr << "Uncaught error: " << err.what() << std::endl;
return 1;
} catch (...) {
- std::cout << "Unknown uncaught error" << std::endl;
+ std::cerr << "Unknown uncaught error" << std::endl;
return 2;
}