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 /src/ats/ats_api_scheduling.c | |
parent | d1a54856de19952c88d8b5c0cafba4f7371adcaf (diff) | |
download | gnunet-3257a3d0944ccd13350f280108f6e4cc7b556cd9.tar.gz gnunet-3257a3d0944ccd13350f280108f6e4cc7b556cd9.zip |
debug on freebsd
Diffstat (limited to 'src/ats/ats_api_scheduling.c')
-rw-r--r-- | src/ats/ats_api_scheduling.c | 5 |
1 files changed, 2 insertions, 3 deletions
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) + |