Skip to content

Commit c8eaf97

Browse files
committed
Fix push duration timer
1 parent 8f10e21 commit c8eaf97

3 files changed

Lines changed: 4 additions & 3 deletions

File tree

mt-kahypar/dynamic/dynamic_io.h

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -224,6 +224,7 @@ inline std::vector<HypernodeID> parseIDs(const std::string& line) {
224224
<< std::chrono::duration_cast<std::chrono::milliseconds>(context.dynamic.rebalance_duration_sum_pull).count() << ", "
225225
<< context.dynamic.km1_gain_localFM << ", "
226226
<< std::chrono::duration_cast<std::chrono::milliseconds>(context.dynamic.localFM_duration_sum).count() << ", "
227+
<< std::chrono::duration_cast<std::chrono::milliseconds>(context.dynamic.update_after_localFM_duration_sum).count() << ", "
227228
<< std::chrono::duration_cast<std::chrono::milliseconds>(context.dynamic.processing_duration_sum).count() << ", "
228229
<< std::chrono::duration_cast<std::chrono::milliseconds>(context.dynamic.sorting_duration_sum).count() << ", "
229230
<< std::chrono::duration_cast<std::chrono::milliseconds>(context.dynamic.gain_cache_update_duration_sum).count() << ", "
@@ -245,7 +246,7 @@ inline std::vector<HypernodeID> parseIDs(const std::string& line) {
245246
if (!file.is_open()) {
246247
throw std::runtime_error("Could not open file: " + filename);
247248
}
248-
file << "change, km1, imbalance, time, km1_gain_vcycle, vcycle_duration_sum, km1_gain_rebalance_push, rebalance_push_duration_sum, km1_gain_rebalance_pull, rebalance_pull_duration_sum, km1_gain_localFM, localFM_duration_sum, processing_duration_sum, sorting_duration_sum, gain_cache_update_duration_sum, move_count" << std::endl;
249+
file << "change, km1, imbalance, time, km1_gain_vcycle, vcycle_duration_sum, km1_gain_rebalance_push, rebalance_push_duration_sum, km1_gain_rebalance_pull, rebalance_pull_duration_sum, km1_gain_localFM, localFM_duration_sum, update_after_localFM_duration_sum, processing_duration_sum, sorting_duration_sum, gain_cache_update_duration_sum, move_count" << std::endl;
249250
file.close();
250251
}
251252

mt-kahypar/dynamic/strategies/localFM_rebalance_vcycle.h

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -170,9 +170,8 @@ namespace mt_kahypar::dyn {
170170
}
171171

172172
_rebalancer.updateGainForMoves(context.dynamic.local_fm_round->moves);
173-
174173
auto rebalancer_duration = std::chrono::high_resolution_clock::now() - start;
175-
context.dynamic.rebalance_duration_sum_push += rebalancer_duration;
174+
context.dynamic.update_after_localFM_duration_sum += rebalancer_duration;
176175
context.dynamic.move_count += context.dynamic.local_fm_round->moves.size();
177176

178177
ASSERT(_rebalancer.checkBlockQueues());

mt-kahypar/partition/context.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -340,6 +340,7 @@ struct DynamicParameters {
340340
std::chrono::high_resolution_clock::duration rebalance_duration_sum_push = std::chrono::high_resolution_clock::duration::zero();
341341
std::int64_t km1_gain_localFM = 0;
342342
std::chrono::high_resolution_clock::duration localFM_duration_sum = std::chrono::high_resolution_clock::duration::zero();
343+
std::chrono::high_resolution_clock::duration update_after_localFM_duration_sum = std::chrono::high_resolution_clock::duration::zero();
343344
std::chrono::high_resolution_clock::duration processing_duration_sum = std::chrono::high_resolution_clock::duration::zero();
344345
std::chrono::high_resolution_clock::duration sorting_duration_sum = std::chrono::high_resolution_clock::duration::zero();
345346
std::chrono::high_resolution_clock::duration gain_cache_update_duration_sum = std::chrono::high_resolution_clock::duration::zero();

0 commit comments

Comments
 (0)