aboutsummaryrefslogtreecommitdiff
path: root/src/core/test_core_quota_compliance.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/test_core_quota_compliance.c')
-rw-r--r--src/core/test_core_quota_compliance.c33
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
65static struct GNUNET_SCHEDULER_Task *measure_task; 65static struct GNUNET_SCHEDULER_Task *measure_task;
66 66
67static struct GNUNET_SCHEDULER_Task *connect_task;
68
69 67
70struct PeerContext 68struct 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
197static void
198try_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