aboutsummaryrefslogtreecommitdiff
path: root/src/gns/gnunet-service-gns.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2018-05-16 21:35:37 +0200
committerChristian Grothoff <christian@grothoff.org>2018-05-16 21:36:38 +0200
commit215e607f63847c77bd26d4c97eae8c7d6ca7f4a0 (patch)
treec8747261f2e4777a7a20cc735661bd3ba25404f3 /src/gns/gnunet-service-gns.c
parent96f4f72bcd0b0314a29783b64a31a76e9c62bf86 (diff)
downloadgnunet-215e607f63847c77bd26d4c97eae8c7d6ca7f4a0.tar.gz
gnunet-215e607f63847c77bd26d4c97eae8c7d6ca7f4a0.zip
optimize setting upload length if available
Diffstat (limited to 'src/gns/gnunet-service-gns.c')
-rw-r--r--src/gns/gnunet-service-gns.c19
1 files changed, 10 insertions, 9 deletions
diff --git a/src/gns/gnunet-service-gns.c b/src/gns/gnunet-service-gns.c
index c376ddfcc..cffae824d 100644
--- a/src/gns/gnunet-service-gns.c
+++ b/src/gns/gnunet-service-gns.c
@@ -296,7 +296,6 @@ client_disconnect_cb (void *cls,
296 clh); 296 clh);
297 GNUNET_free (clh); 297 GNUNET_free (clh);
298 } 298 }
299
300 GNUNET_free (gc); 299 GNUNET_free (gc);
301} 300}
302 301
@@ -340,26 +339,29 @@ send_lookup_response (void* cls,
340 const struct GNUNET_GNSRECORD_Data *rd) 339 const struct GNUNET_GNSRECORD_Data *rd)
341{ 340{
342 struct ClientLookupHandle *clh = cls; 341 struct ClientLookupHandle *clh = cls;
343 struct GNUNET_MQ_Envelope *env; 342 struct GnsClient *gc = clh->gc;
343 struct GNUNET_MQ_Envelope *env;
344 struct LookupResultMessage *rmsg; 344 struct LookupResultMessage *rmsg;
345 size_t len; 345 size_t len;
346 346
347 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 347 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
348 "Sending LOOKUP_RESULT message with %u results\n", 348 "Sending LOOKUP_RESULT message with %u results\n",
349 (unsigned int) rd_count); 349 (unsigned int) rd_count);
350 350 len = GNUNET_GNSRECORD_records_get_size (rd_count,
351 len = GNUNET_GNSRECORD_records_get_size (rd_count, rd); 351 rd);
352 env = GNUNET_MQ_msg_extra (rmsg, 352 env = GNUNET_MQ_msg_extra (rmsg,
353 len, 353 len,
354 GNUNET_MESSAGE_TYPE_GNS_LOOKUP_RESULT); 354 GNUNET_MESSAGE_TYPE_GNS_LOOKUP_RESULT);
355 rmsg->id = clh->request_id; 355 rmsg->id = clh->request_id;
356 rmsg->rd_count = htonl (rd_count); 356 rmsg->rd_count = htonl (rd_count);
357 GNUNET_GNSRECORD_records_serialize (rd_count, rd, len, 357 GNUNET_GNSRECORD_records_serialize (rd_count,
358 rd,
359 len,
358 (char*) &rmsg[1]); 360 (char*) &rmsg[1]);
359 GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq(clh->gc->client), 361 GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (gc->client),
360 env); 362 env);
361 GNUNET_CONTAINER_DLL_remove (clh->gc->clh_head, 363 GNUNET_CONTAINER_DLL_remove (gc->clh_head,
362 clh->gc->clh_tail, 364 gc->clh_tail,
363 clh); 365 clh);
364 GNUNET_free (clh); 366 GNUNET_free (clh);
365 GNUNET_STATISTICS_update (statistics, 367 GNUNET_STATISTICS_update (statistics,
@@ -428,7 +430,6 @@ handle_lookup (void *cls,
428 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 430 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
429 "Received LOOKUP `%s' message\n", 431 "Received LOOKUP `%s' message\n",
430 name); 432 name);
431
432 clh = GNUNET_new (struct ClientLookupHandle); 433 clh = GNUNET_new (struct ClientLookupHandle);
433 GNUNET_CONTAINER_DLL_insert (gc->clh_head, 434 GNUNET_CONTAINER_DLL_insert (gc->clh_head,
434 gc->clh_tail, 435 gc->clh_tail,