diff options
Diffstat (limited to 'src/consensus')
-rw-r--r-- | src/consensus/gnunet-service-consensus.c | 15 |
1 files changed, 13 insertions, 2 deletions
diff --git a/src/consensus/gnunet-service-consensus.c b/src/consensus/gnunet-service-consensus.c index 4af7199aa..6b76efb18 100644 --- a/src/consensus/gnunet-service-consensus.c +++ b/src/consensus/gnunet-service-consensus.c | |||
@@ -1133,8 +1133,11 @@ set_result_cb (void *cls, | |||
1133 | // XXX: check first if any changes to the underlying | 1133 | // XXX: check first if any changes to the underlying |
1134 | // set are still pending | 1134 | // set are still pending |
1135 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1135 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1136 | "Finishing setop in Task {%s}\n", | 1136 | "P%u: Finishing setop in Task {%s} (%u/%u)\n", |
1137 | debug_str_task_key (&task->key)); | 1137 | session->local_peer_idx, |
1138 | debug_str_task_key (&task->key), | ||
1139 | (unsigned int) task->step->finished_tasks, | ||
1140 | (unsigned int) task->step->tasks_len); | ||
1138 | if (NULL != output_rfn) | 1141 | if (NULL != output_rfn) |
1139 | { | 1142 | { |
1140 | rfn_commit (output_rfn, task_other_peer (task)); | 1143 | rfn_commit (output_rfn, task_other_peer (task)); |
@@ -1470,6 +1473,7 @@ commit_set (struct ConsensusSession *session, | |||
1470 | peers to wait. */ | 1473 | peers to wait. */ |
1471 | GNUNET_SET_operation_cancel (setop->op); | 1474 | GNUNET_SET_operation_cancel (setop->op); |
1472 | setop->op = NULL; | 1475 | setop->op = NULL; |
1476 | finish_task (task); | ||
1473 | } | 1477 | } |
1474 | #endif | 1478 | #endif |
1475 | } | 1479 | } |
@@ -2378,6 +2382,13 @@ finish_task (struct TaskEntry *task) | |||
2378 | 2382 | ||
2379 | task->step->finished_tasks++; | 2383 | task->step->finished_tasks++; |
2380 | 2384 | ||
2385 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
2386 | "P%u: Finishing setop in Task {%s} (now %u/%u tasks finished in step)\n", | ||
2387 | task->step->session->local_peer_idx, | ||
2388 | debug_str_task_key (&task->key), | ||
2389 | (unsigned int) task->step->finished_tasks, | ||
2390 | (unsigned int) task->step->tasks_len); | ||
2391 | |||
2381 | if (task->step->finished_tasks == task->step->tasks_len) | 2392 | if (task->step->finished_tasks == task->step->tasks_len) |
2382 | finish_step (task->step); | 2393 | finish_step (task->step); |
2383 | } | 2394 | } |