aboutsummaryrefslogtreecommitdiff
path: root/src/namestore/namestore_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/namestore/namestore_api.c')
-rw-r--r--src/namestore/namestore_api.c116
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,
530static int 530static int
531manage_record_operations (struct GNUNET_NAMESTORE_QueueEntry *qe, 531manage_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 */
697static void 697static void
698process_namestore_message (void *cls, 698process_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 */
804static size_t 804static size_t
805transmit_message_to_namestore (void *cls, 805transmit_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 */
891static void 891static void
892reconnect_task (void *cls, 892reconnect_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 */
1162struct GNUNET_NAMESTORE_QueueEntry * 1162struct GNUNET_NAMESTORE_QueueEntry *
1163GNUNET_NAMESTORE_lookup_block (struct GNUNET_NAMESTORE_Handle *h, 1163GNUNET_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);