diff options
| -rw-r--r-- | include/framework/DynamicExtension.h | 25 |
1 files changed, 14 insertions, 11 deletions
diff --git a/include/framework/DynamicExtension.h b/include/framework/DynamicExtension.h index 21d0261..f2bbacc 100644 --- a/include/framework/DynamicExtension.h +++ b/include/framework/DynamicExtension.h @@ -224,8 +224,10 @@ private: _Epoch *new_epoch = m_epochs[new_epoch_num]; _Epoch *old_epoch = m_epochs[m_current_epoch.load()]; - // Update the new Epoch to contain the buffers - // from the old one that it doesn't currently have + /* + * Update the new Epoch to contain the buffers from the old one + * that it doesn't currently have + */ size_t old_buffer_cnt = new_epoch->clear_buffers(); for (size_t i=old_buffer_cnt; i<old_epoch->get_buffers().size(); i++) { new_epoch->add_buffer(old_epoch->get_buffers()[i]); @@ -275,7 +277,6 @@ private: * number will hit zero and the function will * proceed. */ - while (!epoch->retirable()) ; @@ -323,7 +324,6 @@ private: ((DynamicExtension *) args->extension)->advance_epoch(); - // FIXME: this might break things... not sure delete args; } @@ -334,10 +334,10 @@ private: auto vers = args->epoch->get_structure(); void *parms = args->query_parms; - // Get the buffer query states + /* Get the buffer query states */ std::vector<void *> buffer_states = buffers.get_query_states(parms); - // Get the shard query states + /* Get the shard query states */ std::vector<std::pair<ShardID, Shard*>> shards; std::vector<void *> states = vers->get_query_states(shards, parms); @@ -370,7 +370,6 @@ private: Q::delete_query_state(states[i]); } - // FIXME: this might break things... not sure delete args; } @@ -430,8 +429,10 @@ private: std::vector<Wrapped<R>> processed_records; processed_records.reserve(records.size()); - // For delete tagging, we just need to check the delete bit on each - // record. + /* + * For delete tagging, we just need to check the delete bit + * on each record. + */ if constexpr (D == DeletePolicy::TAGGING) { for (auto &rec : records) { if (rec.is_deleted()) { @@ -444,8 +445,10 @@ private: return processed_records; } - // For tombstone deletes, we need to search for the corresponding - // tombstone for each record. + /* + * For tombstone deletes, we need to search for the corresponding + * tombstone for each record. + */ for (auto &rec : records) { if (rec.is_tombstone()) { continue; |