aboutsummaryrefslogtreecommitdiff
path: root/src/dht/dht_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/dht/dht_api.c')
-rw-r--r--src/dht/dht_api.c4
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))