diff options
| author | Douglas Rumbaugh <dbr4@psu.edu> | 2025-02-11 17:53:44 -0500 |
|---|---|---|
| committer | Douglas Rumbaugh <dbr4@psu.edu> | 2025-02-11 17:53:44 -0500 |
| commit | 125e243cad99aa29444759e15053fd148ff0e3ba (patch) | |
| tree | b6c61fd3276cf56ea1fd5e90a7149e3d7f424e5d /include/framework/reconstruction/BackgroundTieringPolicy.h | |
| parent | 85afe4ef04f327862460570fb0aa4c30afcf7cc7 (diff) | |
| download | dynamic-extension-125e243cad99aa29444759e15053fd148ff0e3ba.tar.gz | |
more updates
Diffstat (limited to 'include/framework/reconstruction/BackgroundTieringPolicy.h')
| -rw-r--r-- | include/framework/reconstruction/BackgroundTieringPolicy.h | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/include/framework/reconstruction/BackgroundTieringPolicy.h b/include/framework/reconstruction/BackgroundTieringPolicy.h index 5a82695..a1bbddc 100644 --- a/include/framework/reconstruction/BackgroundTieringPolicy.h +++ b/include/framework/reconstruction/BackgroundTieringPolicy.h @@ -45,6 +45,7 @@ public: for (level_index i = target_level; i > source_level; i--) { if (lock_mngr.take_lock(i-1)) { + fprintf(stderr, "[I] Taking lock on %ld (%ld)\n", i-1, version->get_id()); ReconstructionVector recon; size_t target_reccnt = (i < (level_index)levels.size()) ? levels[i]->get_record_count() : 0; @@ -56,6 +57,8 @@ public: recon.add_reconstruction(shards, i, total_reccnt, ReconstructionType::Compact); reconstructions.push_back(recon); + } else { + fprintf(stderr, "[I] Failed to get lock on %ld (%ld)\n", i-1, version->get_id()); } } |