Added debug logging to SST to find another bug

View changes keep getting stuck while trying to run signed_log_test.

Author: etremel

include/derecho/sst/detail/sst_impl.hpp

@@ -177,6 +177,7 @@ void SST<DerivedSST>::put_with_completion(const std::vector<uint32_t> receiver_r
         // perform a remote RDMA write on the owner of the row
         ce_ctxt[index].set_remote_id(res_vec[index]->remote_id);
         ce_ctxt[index].set_ce_idx(ce_idx);
+        dbg_trace(sst_logger, "Created a CE context for write to row {}: {:p} -> {{ {}, {}, {} }}", index, static_cast<void*>(&ce_ctxt[index]), ce_ctxt[index].ce_idx(), ce_ctxt[index].remote_id(), ce_ctxt[index].is_managed());
         res_vec[index]->post_remote_write_with_completion(&ce_ctxt[index], offset, size);
         posted_write_to[index] = true;
         num_writes_posted++;
@@ -216,6 +217,7 @@ void SST<DerivedSST>::put_with_completion(const std::vector<uint32_t> receiver_r
         if (result && result.value() == 1) {
             polled_successfully_from[index] = true;
         } else {
+            dbg_debug(sst_logger, "put_with_completion marked row {} failed due to not receiving a completion", index);
             failed_node_indexes.push_back(index);
         }
     }
@@ -264,6 +266,7 @@ void SST<DerivedSST>::sync_with_members() const {
     for(auto const& id_index : members_by_id) {
         std::tie(node_id, sst_index) = id_index;
         if(sst_index != my_index && !row_is_frozen[sst_index]) {
+            dbg_debug(sst_logger, "TCP sync with node {}, for row {}", node_id, sst_index);
             sync(node_id);
         }
     }
@@ -279,6 +282,7 @@ void SST<DerivedSST>::sync_with_members(std::vector<uint32_t> row_indices) const
             continue;
         }
         if(!row_is_frozen[row_index]) {
+            dbg_debug(sst_logger, "TCP sync with node {}, for row {}", members[row_index], row_index);
             sync(members[row_index]);
         }
     }

include/derecho/sst/sst.hpp

@@ -181,6 +181,9 @@ class SST {
 
     DerivedSST* derived_this;
 
+    /** Pointer to the logger for the SST module, which is created in sst::lf_initialize() */
+    std::shared_ptr<spdlog::logger> sst_logger;
+
     std::vector<std::thread> background_threads;
     std::atomic<bool> thread_shutdown;
 
@@ -236,6 +239,7 @@ class SST {
 public:
     SST(DerivedSST* derived_class_pointer, const SSTParams& params)
             : derived_this(derived_class_pointer),
+              sst_logger(spdlog::get(LoggerFactory::SST_LOGGER_NAME)),
               thread_shutdown(false),
               poll_cq_timeout_ms(derecho::getConfUInt32(derecho::Conf::DERECHO_SST_POLL_CQ_TIMEOUT_MS)),
               members(params.members),

src/core/git_version.cpp

@@ -13,8 +13,8 @@ namespace derecho {
 const int MAJOR_VERSION = 2;
 const int MINOR_VERSION = 4;
 const int PATCH_VERSION = 1;
-const int COMMITS_AHEAD_OF_VERSION = 8;
+const int COMMITS_AHEAD_OF_VERSION = 9;
 const char* VERSION_STRING = "2.4.1";
-const char* VERSION_STRING_PLUS_COMMITS = "2.4.1+8";
+const char* VERSION_STRING_PLUS_COMMITS = "2.4.1+9";
 
 }