diff options
author | Christian Grothoff <christian@grothoff.org> | 2013-10-06 20:55:28 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2013-10-06 20:55:28 +0000 |
commit | 61c39c60565b386e0e12ea669556b030e8cd7180 (patch) | |
tree | 59109aeab8297bdc996faca8c4e38ec7426c36cf /src/namestore/namestore_api.c | |
parent | 780eb09dd8040ecf8649d40ddf8314464e0fc48e (diff) | |
download | gnunet-61c39c60565b386e0e12ea669556b030e8cd7180.tar.gz gnunet-61c39c60565b386e0e12ea669556b030e8cd7180.zip |
-remove trailing whitespace
Diffstat (limited to 'src/namestore/namestore_api.c')
-rw-r--r-- | src/namestore/namestore_api.c | 116 |
1 files changed, 58 insertions, 58 deletions
diff --git a/src/namestore/namestore_api.c b/src/namestore/namestore_api.c index a1d17835f..3df6f8210 100644 --- a/src/namestore/namestore_api.c +++ b/src/namestore/namestore_api.c | |||
@@ -272,11 +272,11 @@ handle_lookup_block_response (struct GNUNET_NAMESTORE_QueueEntry *qe, | |||
272 | size_t size) | 272 | size_t size) |
273 | { | 273 | { |
274 | struct GNUNET_NAMESTORE_Block *block; | 274 | struct GNUNET_NAMESTORE_Block *block; |
275 | char buf[size + sizeof (struct GNUNET_NAMESTORE_Block) | 275 | char buf[size + sizeof (struct GNUNET_NAMESTORE_Block) |
276 | - sizeof (struct LookupBlockResponseMessage)]; | 276 | - sizeof (struct LookupBlockResponseMessage)]; |
277 | 277 | ||
278 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 278 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
279 | "Received `%s'\n", | 279 | "Received `%s'\n", |
280 | "LOOKUP_BLOCK_RESPONSE"); | 280 | "LOOKUP_BLOCK_RESPONSE"); |
281 | if (0 == GNUNET_TIME_absolute_ntoh (msg->expire).abs_value_us) | 281 | if (0 == GNUNET_TIME_absolute_ntoh (msg->expire).abs_value_us) |
282 | { | 282 | { |
@@ -290,7 +290,7 @@ handle_lookup_block_response (struct GNUNET_NAMESTORE_QueueEntry *qe, | |||
290 | block->signature = msg->signature; | 290 | block->signature = msg->signature; |
291 | block->derived_key = msg->derived_key; | 291 | block->derived_key = msg->derived_key; |
292 | block->purpose.purpose = htonl (GNUNET_SIGNATURE_PURPOSE_GNS_RECORD_SIGN); | 292 | block->purpose.purpose = htonl (GNUNET_SIGNATURE_PURPOSE_GNS_RECORD_SIGN); |
293 | block->purpose.size = htonl (size - sizeof (struct LookupBlockResponseMessage) + | 293 | block->purpose.size = htonl (size - sizeof (struct LookupBlockResponseMessage) + |
294 | sizeof (struct GNUNET_TIME_AbsoluteNBO) + | 294 | sizeof (struct GNUNET_TIME_AbsoluteNBO) + |
295 | sizeof (struct GNUNET_CRYPTO_EccSignaturePurpose)); | 295 | sizeof (struct GNUNET_CRYPTO_EccSignaturePurpose)); |
296 | block->expiration_time = msg->expire; | 296 | block->expiration_time = msg->expire; |
@@ -332,11 +332,11 @@ handle_block_cache_response (struct GNUNET_NAMESTORE_QueueEntry *qe, | |||
332 | "BLOCK_CACHE_RESPONSE"); | 332 | "BLOCK_CACHE_RESPONSE"); |
333 | res = ntohl (msg->op_result); | 333 | res = ntohl (msg->op_result); |
334 | /* TODO: add actual error message from namestore to response... */ | 334 | /* TODO: add actual error message from namestore to response... */ |
335 | if (NULL != qe->cont) | 335 | if (NULL != qe->cont) |
336 | qe->cont (qe->cont_cls, | 336 | qe->cont (qe->cont_cls, |
337 | res, | 337 | res, |
338 | (GNUNET_OK == res) ? | 338 | (GNUNET_OK == res) ? |
339 | NULL | 339 | NULL |
340 | : _("Namestore failed to cache block")); | 340 | : _("Namestore failed to cache block")); |
341 | return GNUNET_OK; | 341 | return GNUNET_OK; |
342 | } | 342 | } |
@@ -358,8 +358,8 @@ handle_record_store_response (struct GNUNET_NAMESTORE_QueueEntry *qe, | |||
358 | { | 358 | { |
359 | int res; | 359 | int res; |
360 | const char *emsg; | 360 | const char *emsg; |
361 | 361 | ||
362 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 362 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
363 | "Received `%s'\n", | 363 | "Received `%s'\n", |
364 | "RECORD_STORE_RESPONSE"); | 364 | "RECORD_STORE_RESPONSE"); |
365 | /* TODO: add actual error message from namestore to response... */ | 365 | /* TODO: add actual error message from namestore to response... */ |
@@ -368,7 +368,7 @@ handle_record_store_response (struct GNUNET_NAMESTORE_QueueEntry *qe, | |||
368 | emsg = _("Namestore failed to store record\n"); | 368 | emsg = _("Namestore failed to store record\n"); |
369 | else | 369 | else |
370 | emsg = NULL; | 370 | emsg = NULL; |
371 | if (NULL != qe->cont) | 371 | if (NULL != qe->cont) |
372 | qe->cont (qe->cont_cls, res, emsg); | 372 | qe->cont (qe->cont_cls, res, emsg); |
373 | return GNUNET_OK; | 373 | return GNUNET_OK; |
374 | } | 374 | } |
@@ -397,7 +397,7 @@ handle_record_result (struct GNUNET_NAMESTORE_QueueEntry *qe, | |||
397 | unsigned int rd_count; | 397 | unsigned int rd_count; |
398 | 398 | ||
399 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 399 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
400 | "Received `%s'\n", | 400 | "Received `%s'\n", |
401 | "RECORD_RESULT"); | 401 | "RECORD_RESULT"); |
402 | rd_len = ntohs (msg->rd_len); | 402 | rd_len = ntohs (msg->rd_len); |
403 | rd_count = ntohs (msg->rd_count); | 403 | rd_count = ntohs (msg->rd_count); |
@@ -429,11 +429,11 @@ handle_record_result (struct GNUNET_NAMESTORE_QueueEntry *qe, | |||
429 | if (0 == name_len) | 429 | if (0 == name_len) |
430 | name = NULL; | 430 | name = NULL; |
431 | if (NULL != qe->proc) | 431 | if (NULL != qe->proc) |
432 | qe->proc (qe->proc_cls, | 432 | qe->proc (qe->proc_cls, |
433 | &msg->private_key, | 433 | &msg->private_key, |
434 | name, | 434 | name, |
435 | rd_count, | 435 | rd_count, |
436 | (rd_count > 0) ? rd : NULL); | 436 | (rd_count > 0) ? rd : NULL); |
437 | } | 437 | } |
438 | return GNUNET_OK; | 438 | return GNUNET_OK; |
439 | } | 439 | } |
@@ -461,7 +461,7 @@ handle_zone_to_name_response (struct GNUNET_NAMESTORE_QueueEntry *qe, | |||
461 | const char *name_tmp; | 461 | const char *name_tmp; |
462 | const char *rd_tmp; | 462 | const char *rd_tmp; |
463 | 463 | ||
464 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 464 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
465 | "Received `%s'\n", | 465 | "Received `%s'\n", |
466 | "ZONE_TO_NAME_RESPONSE"); | 466 | "ZONE_TO_NAME_RESPONSE"); |
467 | res = ntohs (msg->res); | 467 | res = ntohs (msg->res); |
@@ -472,11 +472,11 @@ handle_zone_to_name_response (struct GNUNET_NAMESTORE_QueueEntry *qe, | |||
472 | "An error occured during zone to name operation\n"); | 472 | "An error occured during zone to name operation\n"); |
473 | break; | 473 | break; |
474 | case GNUNET_NO: | 474 | case GNUNET_NO: |
475 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 475 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
476 | "Namestore has no result for zone to name mapping \n"); | 476 | "Namestore has no result for zone to name mapping \n"); |
477 | break; | 477 | break; |
478 | case GNUNET_YES: | 478 | case GNUNET_YES: |
479 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 479 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
480 | "Namestore has result for zone to name mapping \n"); | 480 | "Namestore has result for zone to name mapping \n"); |
481 | name_len = ntohs (msg->name_len); | 481 | name_len = ntohs (msg->name_len); |
482 | rd_count = ntohs (msg->rd_count); | 482 | rd_count = ntohs (msg->rd_count); |
@@ -499,10 +499,10 @@ handle_zone_to_name_response (struct GNUNET_NAMESTORE_QueueEntry *qe, | |||
499 | } | 499 | } |
500 | /* normal end, call continuation with result */ | 500 | /* normal end, call continuation with result */ |
501 | if (NULL != qe->proc) | 501 | if (NULL != qe->proc) |
502 | qe->proc (qe->proc_cls, | 502 | qe->proc (qe->proc_cls, |
503 | &msg->zone, | 503 | &msg->zone, |
504 | name_tmp, | 504 | name_tmp, |
505 | rd_count, rd); | 505 | rd_count, rd); |
506 | /* return is important here: break would call continuation with error! */ | 506 | /* return is important here: break would call continuation with error! */ |
507 | return GNUNET_OK; | 507 | return GNUNET_OK; |
508 | } | 508 | } |
@@ -530,11 +530,11 @@ handle_zone_to_name_response (struct GNUNET_NAMESTORE_QueueEntry *qe, | |||
530 | static int | 530 | static int |
531 | manage_record_operations (struct GNUNET_NAMESTORE_QueueEntry *qe, | 531 | manage_record_operations (struct GNUNET_NAMESTORE_QueueEntry *qe, |
532 | const struct GNUNET_MessageHeader *msg, | 532 | const struct GNUNET_MessageHeader *msg, |
533 | uint16_t type, | 533 | uint16_t type, |
534 | size_t size) | 534 | size_t size) |
535 | { | 535 | { |
536 | /* handle different message type */ | 536 | /* handle different message type */ |
537 | switch (type) | 537 | switch (type) |
538 | { | 538 | { |
539 | case GNUNET_MESSAGE_TYPE_NAMESTORE_LOOKUP_BLOCK_RESPONSE: | 539 | case GNUNET_MESSAGE_TYPE_NAMESTORE_LOOKUP_BLOCK_RESPONSE: |
540 | if (size < sizeof (struct LookupBlockResponseMessage)) | 540 | if (size < sizeof (struct LookupBlockResponseMessage)) |
@@ -601,7 +601,7 @@ handle_zone_iteration_response (struct GNUNET_NAMESTORE_ZoneIterator *ze, | |||
601 | const char *name_tmp; | 601 | const char *name_tmp; |
602 | const char *rd_ser_tmp; | 602 | const char *rd_ser_tmp; |
603 | 603 | ||
604 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 604 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
605 | "Received `%s'\n", | 605 | "Received `%s'\n", |
606 | "ZONE_ITERATION_RESPONSE"); | 606 | "ZONE_ITERATION_RESPONSE"); |
607 | msg_len = ntohs (msg->gns_header.header.size); | 607 | msg_len = ntohs (msg->gns_header.header.size); |
@@ -614,8 +614,8 @@ handle_zone_iteration_response (struct GNUNET_NAMESTORE_ZoneIterator *ze, | |||
614 | GNUNET_break (0); | 614 | GNUNET_break (0); |
615 | return GNUNET_SYSERR; | 615 | return GNUNET_SYSERR; |
616 | } | 616 | } |
617 | if ( (0 == name_len) && | 617 | if ( (0 == name_len) && |
618 | (0 == (memcmp (&msg->private_key, | 618 | (0 == (memcmp (&msg->private_key, |
619 | &priv_dummy, | 619 | &priv_dummy, |
620 | sizeof (priv_dummy)))) ) | 620 | sizeof (priv_dummy)))) ) |
621 | { | 621 | { |
@@ -635,18 +635,18 @@ handle_zone_iteration_response (struct GNUNET_NAMESTORE_ZoneIterator *ze, | |||
635 | { | 635 | { |
636 | struct GNUNET_NAMESTORE_RecordData rd[rd_count]; | 636 | struct GNUNET_NAMESTORE_RecordData rd[rd_count]; |
637 | 637 | ||
638 | if (GNUNET_OK != GNUNET_NAMESTORE_records_deserialize (rd_len, | 638 | if (GNUNET_OK != GNUNET_NAMESTORE_records_deserialize (rd_len, |
639 | rd_ser_tmp, | 639 | rd_ser_tmp, |
640 | rd_count, | 640 | rd_count, |
641 | rd)) | 641 | rd)) |
642 | { | 642 | { |
643 | GNUNET_break (0); | 643 | GNUNET_break (0); |
644 | return GNUNET_SYSERR; | 644 | return GNUNET_SYSERR; |
645 | } | 645 | } |
646 | if (NULL != ze->proc) | 646 | if (NULL != ze->proc) |
647 | ze->proc (ze->proc_cls, | 647 | ze->proc (ze->proc_cls, |
648 | &msg->private_key, | 648 | &msg->private_key, |
649 | name_tmp, | 649 | name_tmp, |
650 | rd_count, rd); | 650 | rd_count, rd); |
651 | return GNUNET_YES; | 651 | return GNUNET_YES; |
652 | } | 652 | } |
@@ -669,7 +669,7 @@ manage_zone_operations (struct GNUNET_NAMESTORE_ZoneIterator *ze, | |||
669 | int type, size_t size) | 669 | int type, size_t size) |
670 | { | 670 | { |
671 | /* handle different message type */ | 671 | /* handle different message type */ |
672 | switch (type) | 672 | switch (type) |
673 | { | 673 | { |
674 | case GNUNET_MESSAGE_TYPE_NAMESTORE_RECORD_RESULT: | 674 | case GNUNET_MESSAGE_TYPE_NAMESTORE_RECORD_RESULT: |
675 | if (size < sizeof (struct RecordResultMessage)) | 675 | if (size < sizeof (struct RecordResultMessage)) |
@@ -678,7 +678,7 @@ manage_zone_operations (struct GNUNET_NAMESTORE_ZoneIterator *ze, | |||
678 | return GNUNET_SYSERR; | 678 | return GNUNET_SYSERR; |
679 | } | 679 | } |
680 | return handle_zone_iteration_response (ze, | 680 | return handle_zone_iteration_response (ze, |
681 | (const struct RecordResultMessage *) msg, | 681 | (const struct RecordResultMessage *) msg, |
682 | size); | 682 | size); |
683 | default: | 683 | default: |
684 | GNUNET_break (0); | 684 | GNUNET_break (0); |
@@ -695,7 +695,7 @@ manage_zone_operations (struct GNUNET_NAMESTORE_ZoneIterator *ze, | |||
695 | * @param msg message received, NULL on timeout or fatal error | 695 | * @param msg message received, NULL on timeout or fatal error |
696 | */ | 696 | */ |
697 | static void | 697 | static void |
698 | process_namestore_message (void *cls, | 698 | process_namestore_message (void *cls, |
699 | const struct GNUNET_MessageHeader *msg) | 699 | const struct GNUNET_MessageHeader *msg) |
700 | { | 700 | { |
701 | struct GNUNET_NAMESTORE_Handle *h = cls; | 701 | struct GNUNET_NAMESTORE_Handle *h = cls; |
@@ -717,7 +717,7 @@ process_namestore_message (void *cls, | |||
717 | if (size < sizeof (struct GNUNET_NAMESTORE_Header)) | 717 | if (size < sizeof (struct GNUNET_NAMESTORE_Header)) |
718 | { | 718 | { |
719 | GNUNET_break_op (0); | 719 | GNUNET_break_op (0); |
720 | GNUNET_CLIENT_receive (h->client, | 720 | GNUNET_CLIENT_receive (h->client, |
721 | &process_namestore_message, h, | 721 | &process_namestore_message, h, |
722 | GNUNET_TIME_UNIT_FOREVER_REL); | 722 | GNUNET_TIME_UNIT_FOREVER_REL); |
723 | return; | 723 | return; |
@@ -726,9 +726,9 @@ process_namestore_message (void *cls, | |||
726 | r_id = ntohl (gm->r_id); | 726 | r_id = ntohl (gm->r_id); |
727 | 727 | ||
728 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 728 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
729 | "Received message type %u size %u op %u\n", | 729 | "Received message type %u size %u op %u\n", |
730 | (unsigned int) type, | 730 | (unsigned int) type, |
731 | (unsigned int) size, | 731 | (unsigned int) size, |
732 | (unsigned int) r_id); | 732 | (unsigned int) r_id); |
733 | 733 | ||
734 | /* Is it a record related operation ? */ | 734 | /* Is it a record related operation ? */ |
@@ -738,7 +738,7 @@ process_namestore_message (void *cls, | |||
738 | if (NULL != qe) | 738 | if (NULL != qe) |
739 | { | 739 | { |
740 | ret = manage_record_operations (qe, msg, type, size); | 740 | ret = manage_record_operations (qe, msg, type, size); |
741 | if (GNUNET_SYSERR == ret) | 741 | if (GNUNET_SYSERR == ret) |
742 | { | 742 | { |
743 | /* protocol error, need to reconnect */ | 743 | /* protocol error, need to reconnect */ |
744 | h->reconnect = GNUNET_YES; | 744 | h->reconnect = GNUNET_YES; |
@@ -802,8 +802,8 @@ do_transmit (struct GNUNET_NAMESTORE_Handle *h); | |||
802 | * @return number of bytes copied into @a buf | 802 | * @return number of bytes copied into @a buf |
803 | */ | 803 | */ |
804 | static size_t | 804 | static size_t |
805 | transmit_message_to_namestore (void *cls, | 805 | transmit_message_to_namestore (void *cls, |
806 | size_t size, | 806 | size_t size, |
807 | void *buf) | 807 | void *buf) |
808 | { | 808 | { |
809 | struct GNUNET_NAMESTORE_Handle *h = cls; | 809 | struct GNUNET_NAMESTORE_Handle *h = cls; |
@@ -819,14 +819,14 @@ transmit_message_to_namestore (void *cls, | |||
819 | } | 819 | } |
820 | ret = 0; | 820 | ret = 0; |
821 | cbuf = buf; | 821 | cbuf = buf; |
822 | while ( (NULL != (p = h->pending_head)) && | 822 | while ( (NULL != (p = h->pending_head)) && |
823 | (p->size <= size) ) | 823 | (p->size <= size) ) |
824 | { | 824 | { |
825 | memcpy (&cbuf[ret], &p[1], p->size); | 825 | memcpy (&cbuf[ret], &p[1], p->size); |
826 | ret += p->size; | 826 | ret += p->size; |
827 | size -= p->size; | 827 | size -= p->size; |
828 | GNUNET_CONTAINER_DLL_remove (h->pending_head, | 828 | GNUNET_CONTAINER_DLL_remove (h->pending_head, |
829 | h->pending_tail, | 829 | h->pending_tail, |
830 | p); | 830 | p); |
831 | if (GNUNET_NO == h->is_receiving) | 831 | if (GNUNET_NO == h->is_receiving) |
832 | { | 832 | { |
@@ -889,7 +889,7 @@ reconnect (struct GNUNET_NAMESTORE_Handle *h) | |||
889 | * @param tc scheduler context | 889 | * @param tc scheduler context |
890 | */ | 890 | */ |
891 | static void | 891 | static void |
892 | reconnect_task (void *cls, | 892 | reconnect_task (void *cls, |
893 | const struct GNUNET_SCHEDULER_TaskContext *tc) | 893 | const struct GNUNET_SCHEDULER_TaskContext *tc) |
894 | { | 894 | { |
895 | struct GNUNET_NAMESTORE_Handle *h = cls; | 895 | struct GNUNET_NAMESTORE_Handle *h = cls; |
@@ -1010,7 +1010,7 @@ GNUNET_NAMESTORE_disconnect (struct GNUNET_NAMESTORE_Handle *h) | |||
1010 | 1010 | ||
1011 | /** | 1011 | /** |
1012 | * Store an item in the namestore. If the item is already present, | 1012 | * Store an item in the namestore. If the item is already present, |
1013 | * it is replaced with the new record. | 1013 | * it is replaced with the new record. |
1014 | * | 1014 | * |
1015 | * @param h handle to the namestore | 1015 | * @param h handle to the namestore |
1016 | * @param block block to store | 1016 | * @param block block to store |
@@ -1032,8 +1032,8 @@ GNUNET_NAMESTORE_block_cache (struct GNUNET_NAMESTORE_Handle *h, | |||
1032 | size_t msg_size; | 1032 | size_t msg_size; |
1033 | 1033 | ||
1034 | GNUNET_assert (NULL != h); | 1034 | GNUNET_assert (NULL != h); |
1035 | blen = ntohl (block->purpose.size) | 1035 | blen = ntohl (block->purpose.size) |
1036 | - sizeof (struct GNUNET_TIME_AbsoluteNBO) | 1036 | - sizeof (struct GNUNET_TIME_AbsoluteNBO) |
1037 | - sizeof (struct GNUNET_CRYPTO_EccSignaturePurpose); | 1037 | - sizeof (struct GNUNET_CRYPTO_EccSignaturePurpose); |
1038 | rid = get_op_id (h); | 1038 | rid = get_op_id (h); |
1039 | qe = GNUNET_new (struct GNUNET_NAMESTORE_QueueEntry); | 1039 | qe = GNUNET_new (struct GNUNET_NAMESTORE_QueueEntry); |
@@ -1055,9 +1055,9 @@ GNUNET_NAMESTORE_block_cache (struct GNUNET_NAMESTORE_Handle *h, | |||
1055 | msg->signature = block->signature; | 1055 | msg->signature = block->signature; |
1056 | msg->derived_key = block->derived_key; | 1056 | msg->derived_key = block->derived_key; |
1057 | memcpy (&msg[1], &block[1], blen); | 1057 | memcpy (&msg[1], &block[1], blen); |
1058 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 1058 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
1059 | "Sending `%s' message with size %u and expiration %s\n", | 1059 | "Sending `%s' message with size %u and expiration %s\n", |
1060 | "NAMESTORE_BLOCK_CACHE", | 1060 | "NAMESTORE_BLOCK_CACHE", |
1061 | (unsigned int) msg_size, | 1061 | (unsigned int) msg_size, |
1062 | GNUNET_STRINGS_absolute_time_to_string (GNUNET_TIME_absolute_ntoh (msg->expire))); | 1062 | GNUNET_STRINGS_absolute_time_to_string (GNUNET_TIME_absolute_ntoh (msg->expire))); |
1063 | GNUNET_CONTAINER_DLL_insert_tail (h->pending_head, h->pending_tail, pe); | 1063 | GNUNET_CONTAINER_DLL_insert_tail (h->pending_head, h->pending_tail, pe); |
@@ -1134,12 +1134,12 @@ GNUNET_NAMESTORE_records_store (struct GNUNET_NAMESTORE_Handle *h, | |||
1134 | name_tmp = (char *) &msg[1]; | 1134 | name_tmp = (char *) &msg[1]; |
1135 | memcpy (name_tmp, label, name_len); | 1135 | memcpy (name_tmp, label, name_len); |
1136 | rd_ser = &name_tmp[name_len]; | 1136 | rd_ser = &name_tmp[name_len]; |
1137 | GNUNET_break (rd_ser_len == | 1137 | GNUNET_break (rd_ser_len == |
1138 | GNUNET_NAMESTORE_records_serialize (rd_count, rd, | 1138 | GNUNET_NAMESTORE_records_serialize (rd_count, rd, |
1139 | rd_ser_len, | 1139 | rd_ser_len, |
1140 | rd_ser)); | 1140 | rd_ser)); |
1141 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 1141 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
1142 | "Sending `%s' message for name `%s' with size %u and %u records\n", | 1142 | "Sending `%s' message for name `%s' with size %u and %u records\n", |
1143 | "NAMESTORE_RECORD_STORE", label, msg_size, | 1143 | "NAMESTORE_RECORD_STORE", label, msg_size, |
1144 | rd_count); | 1144 | rd_count); |
1145 | GNUNET_CONTAINER_DLL_insert_tail (h->pending_head, h->pending_tail, pe); | 1145 | GNUNET_CONTAINER_DLL_insert_tail (h->pending_head, h->pending_tail, pe); |
@@ -1150,7 +1150,7 @@ GNUNET_NAMESTORE_records_store (struct GNUNET_NAMESTORE_Handle *h, | |||
1150 | 1150 | ||
1151 | /** | 1151 | /** |
1152 | * Get a result for a particular key from the namestore. The processor | 1152 | * Get a result for a particular key from the namestore. The processor |
1153 | * will only be called once. | 1153 | * will only be called once. |
1154 | * | 1154 | * |
1155 | * @param h handle to the namestore | 1155 | * @param h handle to the namestore |
1156 | * @param derived_hash hash of zone key combined with name to lookup | 1156 | * @param derived_hash hash of zone key combined with name to lookup |
@@ -1160,7 +1160,7 @@ GNUNET_NAMESTORE_records_store (struct GNUNET_NAMESTORE_Handle *h, | |||
1160 | * @return a handle that can be used to cancel | 1160 | * @return a handle that can be used to cancel |
1161 | */ | 1161 | */ |
1162 | struct GNUNET_NAMESTORE_QueueEntry * | 1162 | struct GNUNET_NAMESTORE_QueueEntry * |
1163 | GNUNET_NAMESTORE_lookup_block (struct GNUNET_NAMESTORE_Handle *h, | 1163 | GNUNET_NAMESTORE_lookup_block (struct GNUNET_NAMESTORE_Handle *h, |
1164 | const struct GNUNET_HashCode *derived_hash, | 1164 | const struct GNUNET_HashCode *derived_hash, |
1165 | GNUNET_NAMESTORE_BlockProcessor proc, void *proc_cls) | 1165 | GNUNET_NAMESTORE_BlockProcessor proc, void *proc_cls) |
1166 | { | 1166 | { |
@@ -1328,7 +1328,7 @@ GNUNET_NAMESTORE_zone_iterator_next (struct GNUNET_NAMESTORE_ZoneIterator *it) | |||
1328 | msg->gns_header.header.size = htons (msg_size); | 1328 | msg->gns_header.header.size = htons (msg_size); |
1329 | msg->gns_header.r_id = htonl (it->op_id); | 1329 | msg->gns_header.r_id = htonl (it->op_id); |
1330 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 1330 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
1331 | "Sending `%s' message\n", | 1331 | "Sending `%s' message\n", |
1332 | "ZONE_ITERATION_NEXT"); | 1332 | "ZONE_ITERATION_NEXT"); |
1333 | GNUNET_CONTAINER_DLL_insert_tail (h->pending_head, h->pending_tail, pe); | 1333 | GNUNET_CONTAINER_DLL_insert_tail (h->pending_head, h->pending_tail, pe); |
1334 | do_transmit (h); | 1334 | do_transmit (h); |
@@ -1360,8 +1360,8 @@ GNUNET_NAMESTORE_zone_iteration_stop (struct GNUNET_NAMESTORE_ZoneIterator *it) | |||
1360 | msg->gns_header.header.type = htons (GNUNET_MESSAGE_TYPE_NAMESTORE_ZONE_ITERATION_STOP); | 1360 | msg->gns_header.header.type = htons (GNUNET_MESSAGE_TYPE_NAMESTORE_ZONE_ITERATION_STOP); |
1361 | msg->gns_header.header.size = htons (msg_size); | 1361 | msg->gns_header.header.size = htons (msg_size); |
1362 | msg->gns_header.r_id = htonl (it->op_id); | 1362 | msg->gns_header.r_id = htonl (it->op_id); |
1363 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1363 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1364 | "Sending `%s' message\n", | 1364 | "Sending `%s' message\n", |
1365 | "ZONE_ITERATION_STOP"); | 1365 | "ZONE_ITERATION_STOP"); |
1366 | GNUNET_CONTAINER_DLL_insert_tail (h->pending_head, h->pending_tail, pe); | 1366 | GNUNET_CONTAINER_DLL_insert_tail (h->pending_head, h->pending_tail, pe); |
1367 | do_transmit (h); | 1367 | do_transmit (h); |