diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2013-09-30 12:06:55 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2013-09-30 12:06:55 +0000 |
commit | 3257a3d0944ccd13350f280108f6e4cc7b556cd9 (patch) | |
tree | 59f327d86c99fb7bf1ee25aff5c4466bde1683d9 | |
parent | d1a54856de19952c88d8b5c0cafba4f7371adcaf (diff) | |
download | gnunet-3257a3d0944ccd13350f280108f6e4cc7b556cd9.tar.gz gnunet-3257a3d0944ccd13350f280108f6e4cc7b556cd9.zip |
debug on freebsd
-rw-r--r-- | src/ats/ats_api_performance.c | 6 | ||||
-rw-r--r-- | src/ats/ats_api_scheduling.c | 5 |
2 files changed, 4 insertions, 7 deletions
diff --git a/src/ats/ats_api_performance.c b/src/ats/ats_api_performance.c index acbc18e58..838acca2f 100644 --- a/src/ats/ats_api_performance.c +++ b/src/ats/ats_api_performance.c | |||
@@ -308,10 +308,6 @@ transmit_message_to_ats (void *cls, size_t size, void *buf) | |||
308 | ret += p->size; | 308 | ret += p->size; |
309 | size -= p->size; | 309 | size -= p->size; |
310 | GNUNET_CONTAINER_DLL_remove (ph->pending_head, ph->pending_tail, p); | 310 | GNUNET_CONTAINER_DLL_remove (ph->pending_head, ph->pending_tail, p); |
311 | if (GNUNET_YES == p->is_init) | ||
312 | GNUNET_CLIENT_receive (ph->client, &process_ats_message, ph, | ||
313 | GNUNET_TIME_UNIT_FOREVER_REL); | ||
314 | |||
315 | GNUNET_free (p); | 311 | GNUNET_free (p); |
316 | } | 312 | } |
317 | do_transmit (ph); | 313 | do_transmit (ph); |
@@ -623,6 +619,8 @@ reconnect (struct GNUNET_ATS_PerformanceHandle *ph) | |||
623 | GNUNET_assert (NULL == ph->client); | 619 | GNUNET_assert (NULL == ph->client); |
624 | ph->client = GNUNET_CLIENT_connect ("ats", ph->cfg); | 620 | ph->client = GNUNET_CLIENT_connect ("ats", ph->cfg); |
625 | GNUNET_assert (NULL != ph->client); | 621 | GNUNET_assert (NULL != ph->client); |
622 | GNUNET_CLIENT_receive (ph->client, &process_ats_message, ph, | ||
623 | GNUNET_TIME_UNIT_FOREVER_REL); | ||
626 | if ((NULL == (p = ph->pending_head)) || (GNUNET_YES != p->is_init)) | 624 | if ((NULL == (p = ph->pending_head)) || (GNUNET_YES != p->is_init)) |
627 | { | 625 | { |
628 | p = GNUNET_malloc (sizeof (struct PendingMessage) + | 626 | p = GNUNET_malloc (sizeof (struct PendingMessage) + |
diff --git a/src/ats/ats_api_scheduling.c b/src/ats/ats_api_scheduling.c index 8a9791811..1ef6ce095 100644 --- a/src/ats/ats_api_scheduling.c +++ b/src/ats/ats_api_scheduling.c | |||
@@ -290,9 +290,6 @@ transmit_message_to_ats (void *cls, size_t size, void *buf) | |||
290 | ret += p->size; | 290 | ret += p->size; |
291 | size -= p->size; | 291 | size -= p->size; |
292 | GNUNET_CONTAINER_DLL_remove (sh->pending_head, sh->pending_tail, p); | 292 | GNUNET_CONTAINER_DLL_remove (sh->pending_head, sh->pending_tail, p); |
293 | if (GNUNET_YES == p->is_init) | ||
294 | GNUNET_CLIENT_receive (sh->client, &process_ats_message, sh, | ||
295 | GNUNET_TIME_UNIT_FOREVER_REL); | ||
296 | GNUNET_free (p); | 293 | GNUNET_free (p); |
297 | } | 294 | } |
298 | do_transmit (sh); | 295 | do_transmit (sh); |
@@ -683,6 +680,8 @@ reconnect (struct GNUNET_ATS_SchedulingHandle *sh) | |||
683 | GNUNET_assert (NULL == sh->client); | 680 | GNUNET_assert (NULL == sh->client); |
684 | sh->client = GNUNET_CLIENT_connect ("ats", sh->cfg); | 681 | sh->client = GNUNET_CLIENT_connect ("ats", sh->cfg); |
685 | GNUNET_assert (NULL != sh->client); | 682 | GNUNET_assert (NULL != sh->client); |
683 | GNUNET_CLIENT_receive (sh->client, &process_ats_message, sh, | ||
684 | GNUNET_TIME_UNIT_FOREVER_REL); | ||
686 | if ((NULL == (p = sh->pending_head)) || (GNUNET_YES != p->is_init)) | 685 | if ((NULL == (p = sh->pending_head)) || (GNUNET_YES != p->is_init)) |
687 | { | 686 | { |
688 | p = GNUNET_malloc (sizeof (struct PendingMessage) + | 687 | p = GNUNET_malloc (sizeof (struct PendingMessage) + |