diff options
Diffstat (limited to 'src/testbed/testbed_logger_api.c')
-rw-r--r-- | src/testbed/testbed_logger_api.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/testbed/testbed_logger_api.c b/src/testbed/testbed_logger_api.c index c520b1062..562902218 100644 --- a/src/testbed/testbed_logger_api.c +++ b/src/testbed/testbed_logger_api.c | |||
@@ -21,7 +21,7 @@ | |||
21 | /** | 21 | /** |
22 | * @file testbed/testbed_logger_api.c | 22 | * @file testbed/testbed_logger_api.c |
23 | * @brief Client-side routines for communicating with the tesbted logger service | 23 | * @brief Client-side routines for communicating with the tesbted logger service |
24 | * @author Sree Harsha Totakura <sreeharsha@totakura.in> | 24 | * @author Sree Harsha Totakura <sreeharsha@totakura.in> |
25 | */ | 25 | */ |
26 | 26 | ||
27 | #include "platform.h" | 27 | #include "platform.h" |
@@ -158,7 +158,7 @@ static void | |||
158 | cancel_timeout_flush (struct GNUNET_TESTBED_LOGGER_Handle *h) | 158 | cancel_timeout_flush (struct GNUNET_TESTBED_LOGGER_Handle *h) |
159 | { | 159 | { |
160 | GNUNET_SCHEDULER_cancel (h->timeout_flush_task); | 160 | GNUNET_SCHEDULER_cancel (h->timeout_flush_task); |
161 | h->timeout_flush_task = GNUNET_SCHEDULER_NO_TASK; | 161 | h->timeout_flush_task = GNUNET_SCHEDULER_NO_TASK; |
162 | } | 162 | } |
163 | 163 | ||
164 | 164 | ||
@@ -310,7 +310,7 @@ dispatch_buffer (struct GNUNET_TESTBED_LOGGER_Handle *h) | |||
310 | msg = GNUNET_realloc (h->buf, msize); | 310 | msg = GNUNET_realloc (h->buf, msize); |
311 | h->buf = NULL; | 311 | h->buf = NULL; |
312 | memmove (&msg[1], msg, h->bs); | 312 | memmove (&msg[1], msg, h->bs); |
313 | h->bs = 0; | 313 | h->bs = 0; |
314 | msg->type = htons (GNUNET_MESSAGE_TYPE_TESTBED_LOGGER_MSG); | 314 | msg->type = htons (GNUNET_MESSAGE_TYPE_TESTBED_LOGGER_MSG); |
315 | msg->size = htons (msize); | 315 | msg->size = htons (msize); |
316 | queue_message (h, msg); | 316 | queue_message (h, msg); |
@@ -329,7 +329,7 @@ GNUNET_TESTBED_LOGGER_connect (const struct GNUNET_CONFIGURATION_Handle *cfg) | |||
329 | { | 329 | { |
330 | struct GNUNET_TESTBED_LOGGER_Handle *h; | 330 | struct GNUNET_TESTBED_LOGGER_Handle *h; |
331 | struct GNUNET_CLIENT_Connection *client; | 331 | struct GNUNET_CLIENT_Connection *client; |
332 | 332 | ||
333 | client = GNUNET_CLIENT_connect ("testbed-logger", cfg); | 333 | client = GNUNET_CLIENT_connect ("testbed-logger", cfg); |
334 | if (NULL == client) | 334 | if (NULL == client) |
335 | return NULL; | 335 | return NULL; |
@@ -374,7 +374,7 @@ GNUNET_TESTBED_LOGGER_disconnect (struct GNUNET_TESTBED_LOGGER_Handle *h) | |||
374 | void | 374 | void |
375 | GNUNET_TESTBED_LOGGER_write (struct GNUNET_TESTBED_LOGGER_Handle *h, | 375 | GNUNET_TESTBED_LOGGER_write (struct GNUNET_TESTBED_LOGGER_Handle *h, |
376 | const void *data, size_t size) | 376 | const void *data, size_t size) |
377 | { | 377 | { |
378 | size_t fit_size; | 378 | size_t fit_size; |
379 | 379 | ||
380 | GNUNET_assert (0 != size); | 380 | GNUNET_assert (0 != size); |
@@ -445,7 +445,7 @@ GNUNET_TESTBED_LOGGER_flush (struct GNUNET_TESTBED_LOGGER_Handle *h, | |||
445 | h->cb = cb; | 445 | h->cb = cb; |
446 | h->cb_cls = cb_cls; | 446 | h->cb_cls = cb_cls; |
447 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == h->timeout_flush_task); | 447 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == h->timeout_flush_task); |
448 | h->timeout_flush_task = | 448 | h->timeout_flush_task = |
449 | GNUNET_SCHEDULER_add_delayed (timeout, &timeout_flush, h); | 449 | GNUNET_SCHEDULER_add_delayed (timeout, &timeout_flush, h); |
450 | if (NULL == h->buf) | 450 | if (NULL == h->buf) |
451 | { | 451 | { |