Debug test connection

Author: everoddandeven

pytest.ini

@@ -1,9 +1,9 @@
 [pytest]
 minversion = 6.0
 addopts = -v
-log_level = INFO
+log_level = DEBUG
 log_cli = True
-log_cli_level = INFO
+log_cli_level = DEBUG
 console_output_style = progress
 testpaths =
     tests

src/cpp/common/py_monero_common.cpp

@@ -26,7 +26,10 @@ void PyThreadPoller::init_common(const std::string& name) {
 }
 
 void PyThreadPoller::set_is_polling(bool is_polling) {
-  if (is_polling == m_is_polling) return;
+  if (is_polling == m_is_polling) {
+    std::cout << "Already set " << is_polling << std::endl;
+    return;
+  }
   m_is_polling = is_polling;
 
   if (m_is_polling) {
@@ -46,12 +49,17 @@ void PyThreadPoller::set_period_in_ms(uint64_t period_ms) {
 }
 
 void PyThreadPoller::run_poll_loop() {
-  if (m_poll_loop_running) return; // only run one loop at a time
+  if (m_poll_loop_running) {
+    std::cout << "PyThreadPoller::run_poll_loop(): already running loop" << std::endl;
+    return; // only run one loop at a time
+  }
   m_poll_loop_running = true;
 
   // start pool loop thread
   // TODO: use global threadpool, background sync wasm wallet in c++ thread
+  std::cout << "Initializing thread..." << std::endl;
   m_thread = boost::thread([this]() {
+    std::cout << "Started thread" << std::endl;
 
     // poll while enabled
     while (m_is_polling) {
@@ -67,8 +75,11 @@ void PyThreadPoller::run_poll_loop() {
       }
     }
 
+    std::cout << "End thread" << std::endl;
     m_poll_loop_running = false;
   });
+  std::cout << "Initialized thread" << std::endl;
+
 }
 
 py::object PyGenUtils::convert_value(const std::string& val) {
@@ -753,8 +764,10 @@ void PyMoneroConnectionManager::stop_polling() {
 }
 
 void PyMoneroConnectionManager::start_polling(const boost::optional<uint64_t>& period_ms, const boost::optional<bool>& auto_switch, const boost::optional<uint64_t>& timeout_ms, const boost::optional<PyMoneroConnectionPollType>& poll_type, const boost::optional<std::vector<std::shared_ptr<PyMoneroRpcConnection>>> &excluded_connections) {
+  std::cout << "PyMoneroConnectionManager::start_polling()" << std::endl;
   // stop polling
   stop_polling();
+  std::cout << "PyMoneroConnectionManager::start_polling(): stopped polling" << std::endl;
 
   // apply defaults
   uint64_t poll_period_ms = period_ms == boost::none ? DEFAULT_POLL_PERIOD : period_ms.get();
@@ -770,7 +783,9 @@ void PyMoneroConnectionManager::start_polling(const boost::optional<uint64_t>& p
   }
 
   // start polling
+  std::cout << "PyMoneroConnectionManager::start_polling(): set polling..." << std::endl;
   set_is_polling(true);
+  std::cout << "PyMoneroConnectionManager::start_polling(): set polling: " << m_is_polling << std::endl;
 }
 
 std::shared_ptr<PyMoneroRpcConnection> PyMoneroConnectionManager::get_best_available_connection(const std::set<std::shared_ptr<PyMoneroRpcConnection>>& excluded_connections) {
@@ -908,6 +923,7 @@ std::vector<std::vector<std::shared_ptr<PyMoneroRpcConnection>>> PyMoneroConnect
 
 void PyMoneroConnectionManager::poll() {
   // do polling
+  std::cout << "PyMoneroConnectionManager::poll()" << std::endl;
   switch (m_poll_type) {
     case PyMoneroConnectionPollType::CURRENT:
       check_connection();
@@ -927,6 +943,7 @@ bool PyMoneroConnectionManager::check_connections(const std::vector<std::shared_
   try {
     // start checking connections in parallel
     boost::asio::thread_pool pool(4);
+    std::cout << "PyMoneroConnectionManager::check_connections(): initiliazed thread pool" << std::endl;
     boost::mutex result_mutex;
     boost::condition_variable result_cv;
     std::vector<std::shared_ptr<PyMoneroRpcConnection>> completed;
@@ -939,9 +956,11 @@ bool PyMoneroConnectionManager::check_connections(const std::vector<std::shared_
       num_tasks++;
 
       boost::asio::post(pool, [this, connection, &result_mutex, &result_cv, &completed]() {
+        std::cout << "checking connection: " << connection->serialize() << std::endl;
         bool change = connection->check_connection(m_timeout);
 
         if (change && connection == get_connection()) {
+          std::cout << "changed connection: " << connection->serialize() << std::endl;
           on_connection_changed(connection);
         }
 
@@ -960,9 +979,11 @@ bool PyMoneroConnectionManager::check_connections(const std::vector<std::shared_
     // wait for responses
     while (received < num_tasks) {
       boost::unique_lock<boost::mutex> lock(result_mutex);
+      std::cout << "Waiting for connection..." << std::endl;
       result_cv.wait(lock, [&]() { return completed.size() > received; });
 
       auto connection = completed[received++];
+      std::cout << "Got connection: " << connection->serialize() << std::endl;
       lock.unlock();
 
       if (connection->is_connected().value_or(false) && !has_connection) {