diff options
Diffstat (limited to 'src/dht/dht_api.c')
-rw-r--r-- | src/dht/dht_api.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/dht/dht_api.c b/src/dht/dht_api.c index e045a8b75..f94d1f67a 100644 --- a/src/dht/dht_api.c +++ b/src/dht/dht_api.c | |||
@@ -599,6 +599,7 @@ transmit_pending (void *cls, | |||
599 | struct PendingMessage *head; | 599 | struct PendingMessage *head; |
600 | size_t tsize; | 600 | size_t tsize; |
601 | 601 | ||
602 | |||
602 | handle->th = NULL; | 603 | handle->th = NULL; |
603 | if (NULL == buf) | 604 | if (NULL == buf) |
604 | { | 605 | { |
@@ -635,6 +636,7 @@ transmit_pending (void *cls, | |||
635 | { | 636 | { |
636 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Starting to process replies from DHT\n"); | 637 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Starting to process replies from DHT\n"); |
637 | handle->in_receive = GNUNET_YES; | 638 | handle->in_receive = GNUNET_YES; |
639 | |||
638 | GNUNET_CLIENT_receive (handle->client, &service_message_handler, handle, | 640 | GNUNET_CLIENT_receive (handle->client, &service_message_handler, handle, |
639 | GNUNET_TIME_UNIT_FOREVER_REL); | 641 | GNUNET_TIME_UNIT_FOREVER_REL); |
640 | } | 642 | } |
@@ -900,6 +902,7 @@ service_message_handler (void *cls, const struct GNUNET_MessageHeader *msg) | |||
900 | uint16_t msize; | 902 | uint16_t msize; |
901 | int ret; | 903 | int ret; |
902 | 904 | ||
905 | |||
903 | if (NULL == msg) | 906 | if (NULL == msg) |
904 | { | 907 | { |
905 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 908 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
@@ -1148,6 +1151,7 @@ GNUNET_DHT_put (struct GNUNET_DHT_Handle *handle, | |||
1148 | struct PendingMessage *pending; | 1151 | struct PendingMessage *pending; |
1149 | struct GNUNET_DHT_PutHandle *ph; | 1152 | struct GNUNET_DHT_PutHandle *ph; |
1150 | 1153 | ||
1154 | |||
1151 | msize = sizeof (struct GNUNET_DHT_ClientPutMessage) + size; | 1155 | msize = sizeof (struct GNUNET_DHT_ClientPutMessage) + size; |
1152 | if ((msize >= GNUNET_SERVER_MAX_MESSAGE_SIZE) || | 1156 | if ((msize >= GNUNET_SERVER_MAX_MESSAGE_SIZE) || |
1153 | (size >= GNUNET_SERVER_MAX_MESSAGE_SIZE)) | 1157 | (size >= GNUNET_SERVER_MAX_MESSAGE_SIZE)) |