diff options
author | Sree Harsha Totakura <totakura@in.tum.de> | 2014-03-05 16:29:08 +0000 |
---|---|---|
committer | Sree Harsha Totakura <totakura@in.tum.de> | 2014-03-05 16:29:08 +0000 |
commit | 73495317a20fd2b305aa850f17d1a9d998db57f7 (patch) | |
tree | 3d72aca3a67886f8235c4720338f8067a015bf6c /src/testbed | |
parent | 457009981f77605da6812ac8bd6f67fe455f550f (diff) | |
download | gnunet-73495317a20fd2b305aa850f17d1a9d998db57f7.tar.gz gnunet-73495317a20fd2b305aa850f17d1a9d998db57f7.zip |
- Define and use BUFFER_SIZE for the size of the outgoing buffer.
Diffstat (limited to 'src/testbed')
-rw-r--r-- | src/testbed/testbed_logger_api.c | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/testbed/testbed_logger_api.c b/src/testbed/testbed_logger_api.c index 399e26a2f..df1fcf27b 100644 --- a/src/testbed/testbed_logger_api.c +++ b/src/testbed/testbed_logger_api.c | |||
@@ -49,6 +49,10 @@ | |||
49 | */ | 49 | */ |
50 | #define GNUNET_TIME_STD_EXPONENTIAL_BACKOFF_THRESHOLD GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 3) | 50 | #define GNUNET_TIME_STD_EXPONENTIAL_BACKOFF_THRESHOLD GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 3) |
51 | 51 | ||
52 | /** | ||
53 | * The size of the buffer we fill before sending out the message | ||
54 | */ | ||
55 | #define BUFFER_SIZE GNUNET_SERVER_MAX_MESSAGE_SIZE | ||
52 | 56 | ||
53 | /** | 57 | /** |
54 | * The message queue for sending messages to the controller service | 58 | * The message queue for sending messages to the controller service |
@@ -379,10 +383,9 @@ GNUNET_TESTBED_LOGGER_write (struct GNUNET_TESTBED_LOGGER_Handle *h, | |||
379 | 383 | ||
380 | GNUNET_assert (0 != size); | 384 | GNUNET_assert (0 != size); |
381 | GNUNET_assert (NULL != data); | 385 | GNUNET_assert (NULL != data); |
382 | GNUNET_assert (size < (GNUNET_SERVER_MAX_MESSAGE_SIZE | 386 | GNUNET_assert (size < (BUFFER_SIZE - sizeof (struct GNUNET_MessageHeader))); |
383 | - sizeof (struct GNUNET_MessageHeader))); | ||
384 | fit_size = sizeof (struct GNUNET_MessageHeader) + h->bs + size; | 387 | fit_size = sizeof (struct GNUNET_MessageHeader) + h->bs + size; |
385 | if ( GNUNET_SERVER_MAX_MESSAGE_SIZE < fit_size ) | 388 | if ( BUFFER_SIZE < fit_size ) |
386 | dispatch_buffer (h); | 389 | dispatch_buffer (h); |
387 | if (NULL == h->buf) | 390 | if (NULL == h->buf) |
388 | { | 391 | { |