diff options
Diffstat (limited to 'src/core/test_core_quota_compliance.c')
-rw-r--r-- | src/core/test_core_quota_compliance.c | 33 |
1 files changed, 7 insertions, 26 deletions
diff --git a/src/core/test_core_quota_compliance.c b/src/core/test_core_quota_compliance.c index ce62dbe3b..32edb50c7 100644 --- a/src/core/test_core_quota_compliance.c +++ b/src/core/test_core_quota_compliance.c | |||
@@ -64,8 +64,6 @@ static struct GNUNET_SCHEDULER_Task *err_task; | |||
64 | 64 | ||
65 | static struct GNUNET_SCHEDULER_Task *measure_task; | 65 | static struct GNUNET_SCHEDULER_Task *measure_task; |
66 | 66 | ||
67 | static struct GNUNET_SCHEDULER_Task *connect_task; | ||
68 | |||
69 | 67 | ||
70 | struct PeerContext | 68 | struct PeerContext |
71 | { | 69 | { |
@@ -160,11 +158,6 @@ terminate_task (void *cls, | |||
160 | err_task = NULL; | 158 | err_task = NULL; |
161 | terminate_peer (&p1); | 159 | terminate_peer (&p1); |
162 | terminate_peer (&p2); | 160 | terminate_peer (&p2); |
163 | if (NULL != connect_task) | ||
164 | { | ||
165 | GNUNET_SCHEDULER_cancel (connect_task); | ||
166 | connect_task = NULL; | ||
167 | } | ||
168 | } | 161 | } |
169 | 162 | ||
170 | 163 | ||
@@ -185,27 +178,10 @@ terminate_task_error (void *cls, | |||
185 | GNUNET_SCHEDULER_cancel (measure_task); | 178 | GNUNET_SCHEDULER_cancel (measure_task); |
186 | measure_task = NULL; | 179 | measure_task = NULL; |
187 | } | 180 | } |
188 | if (NULL != connect_task) | ||
189 | { | ||
190 | GNUNET_SCHEDULER_cancel (connect_task); | ||
191 | connect_task = NULL; | ||
192 | } | ||
193 | ok = 42; | 181 | ok = 42; |
194 | } | 182 | } |
195 | 183 | ||
196 | 184 | ||
197 | static void | ||
198 | try_connect (void *cls, | ||
199 | const struct GNUNET_SCHEDULER_TaskContext *tc) | ||
200 | { | ||
201 | connect_task = | ||
202 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, &try_connect, | ||
203 | NULL); | ||
204 | GNUNET_TRANSPORT_try_connect (p1.th, &p2.id, NULL, NULL); /*FIXME TRY_CONNECT change */ | ||
205 | GNUNET_TRANSPORT_try_connect (p2.th, &p1.id, NULL, NULL); /*FIXME TRY_CONNECT change */ | ||
206 | } | ||
207 | |||
208 | |||
209 | /** | 185 | /** |
210 | * Callback function to process statistic values. | 186 | * Callback function to process statistic values. |
211 | * | 187 | * |
@@ -553,9 +529,14 @@ init_notify (void *cls, | |||
553 | OKPP; | 529 | OKPP; |
554 | GNUNET_assert (cls == &p2); | 530 | GNUNET_assert (cls == &p2); |
555 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 531 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
556 | "Asking core (1) to connect to peer `%4s'\n", | 532 | "Asking core (1) to connect to peer `%s' and vice-versa\n", |
557 | GNUNET_i2s (&p2.id)); | 533 | GNUNET_i2s (&p2.id)); |
558 | connect_task = GNUNET_SCHEDULER_add_now (&try_connect, NULL); | 534 | p1.ats_sh = GNUNET_ATS_connectivity_suggest (p1.ats, |
535 | &p2.id, | ||
536 | 1); | ||
537 | p2.ats_sh = GNUNET_ATS_connectivity_suggest (p2.ats, | ||
538 | &p1.id, | ||
539 | 1); | ||
559 | } | 540 | } |
560 | } | 541 | } |
561 | 542 | ||