diff options
Diffstat (limited to 'src/consensus/gnunet-service-consensus.c')
-rw-r--r-- | src/consensus/gnunet-service-consensus.c | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/consensus/gnunet-service-consensus.c b/src/consensus/gnunet-service-consensus.c index 44b6dc21b..c56741c67 100644 --- a/src/consensus/gnunet-service-consensus.c +++ b/src/consensus/gnunet-service-consensus.c | |||
@@ -487,6 +487,11 @@ struct ConsensusSession | |||
487 | * State of our early stopping scheme. | 487 | * State of our early stopping scheme. |
488 | */ | 488 | */ |
489 | int early_stopping; | 489 | int early_stopping; |
490 | |||
491 | /** | ||
492 | * Our set size from the first round. | ||
493 | */ | ||
494 | uint64_t first_size; | ||
490 | }; | 495 | }; |
491 | 496 | ||
492 | /** | 497 | /** |
@@ -1061,6 +1066,10 @@ set_result_cb (void *cls, | |||
1061 | { | 1066 | { |
1062 | rfn_commit (output_rfn, task_other_peer (task)); | 1067 | rfn_commit (output_rfn, task_other_peer (task)); |
1063 | } | 1068 | } |
1069 | if (PHASE_KIND_ALL_TO_ALL == task->key->phase) | ||
1070 | { | ||
1071 | session->first_size = current_size; | ||
1072 | } | ||
1064 | finish_task (task); | 1073 | finish_task (task); |
1065 | break; | 1074 | break; |
1066 | case GNUNET_SET_STATUS_FAILURE: | 1075 | case GNUNET_SET_STATUS_FAILURE: |