diff options
Diffstat (limited to 'src/namestore/namestore_api.c')
-rw-r--r-- | src/namestore/namestore_api.c | 38 |
1 files changed, 19 insertions, 19 deletions
diff --git a/src/namestore/namestore_api.c b/src/namestore/namestore_api.c index e020b9e42..8deded9c0 100644 --- a/src/namestore/namestore_api.c +++ b/src/namestore/namestore_api.c | |||
@@ -407,8 +407,13 @@ check_lookup_result (void *cls, const struct LabelLookupResponseMessage *msg) | |||
407 | rd_len = ntohs (msg->rd_len); | 407 | rd_len = ntohs (msg->rd_len); |
408 | msg_len = ntohs (msg->gns_header.header.size); | 408 | msg_len = ntohs (msg->gns_header.header.size); |
409 | name_len = ntohs (msg->name_len); | 409 | name_len = ntohs (msg->name_len); |
410 | key_len = ntohl (msg->key_len); | 410 | key_len = ntohs (msg->key_len); |
411 | exp_msg_len = sizeof(*msg) + name_len + rd_len + key_len; | 411 | exp_msg_len = sizeof(*msg) + name_len + rd_len + key_len; |
412 | if (0 != ntohs (msg->reserved)) | ||
413 | { | ||
414 | GNUNET_break (0); | ||
415 | return GNUNET_SYSERR; | ||
416 | } | ||
412 | if (msg_len != exp_msg_len) | 417 | if (msg_len != exp_msg_len) |
413 | { | 418 | { |
414 | GNUNET_break (0); | 419 | GNUNET_break (0); |
@@ -463,7 +468,7 @@ handle_lookup_result (void *cls, const struct LabelLookupResponseMessage *msg) | |||
463 | rd_len = ntohs (msg->rd_len); | 468 | rd_len = ntohs (msg->rd_len); |
464 | rd_count = ntohs (msg->rd_count); | 469 | rd_count = ntohs (msg->rd_count); |
465 | name_len = ntohs (msg->name_len); | 470 | name_len = ntohs (msg->name_len); |
466 | key_len = ntohl (msg->key_len); | 471 | key_len = ntohs (msg->key_len); |
467 | GNUNET_assert (GNUNET_SYSERR != | 472 | GNUNET_assert (GNUNET_SYSERR != |
468 | GNUNET_IDENTITY_read_private_key_from_buffer (&msg[1], | 473 | GNUNET_IDENTITY_read_private_key_from_buffer (&msg[1], |
469 | key_len, | 474 | key_len, |
@@ -527,13 +532,8 @@ check_record_result (void *cls, const struct RecordResultMessage *msg) | |||
527 | (void) cls; | 532 | (void) cls; |
528 | rd_len = ntohs (msg->rd_len); | 533 | rd_len = ntohs (msg->rd_len); |
529 | msg_len = ntohs (msg->gns_header.header.size); | 534 | msg_len = ntohs (msg->gns_header.header.size); |
530 | key_len = ntohl (msg->key_len); | 535 | key_len = ntohs (msg->key_len); |
531 | name_len = ntohs (msg->name_len); | 536 | name_len = ntohs (msg->name_len); |
532 | if (0 != ntohs (msg->reserved)) | ||
533 | { | ||
534 | GNUNET_break (0); | ||
535 | return GNUNET_SYSERR; | ||
536 | } | ||
537 | if (msg_len != sizeof(struct RecordResultMessage) + key_len + name_len | 537 | if (msg_len != sizeof(struct RecordResultMessage) + key_len + name_len |
538 | + rd_len) | 538 | + rd_len) |
539 | { | 539 | { |
@@ -581,7 +581,7 @@ handle_record_result (void *cls, const struct RecordResultMessage *msg) | |||
581 | rd_len = ntohs (msg->rd_len); | 581 | rd_len = ntohs (msg->rd_len); |
582 | rd_count = ntohs (msg->rd_count); | 582 | rd_count = ntohs (msg->rd_count); |
583 | name_len = ntohs (msg->name_len); | 583 | name_len = ntohs (msg->name_len); |
584 | key_len = ntohl (msg->key_len); | 584 | key_len = ntohs (msg->key_len); |
585 | ze = find_zi (h, ntohl (msg->gns_header.r_id)); | 585 | ze = find_zi (h, ntohl (msg->gns_header.r_id)); |
586 | qe = find_qe (h, ntohl (msg->gns_header.r_id)); | 586 | qe = find_qe (h, ntohl (msg->gns_header.r_id)); |
587 | if ((NULL == ze) && (NULL == qe)) | 587 | if ((NULL == ze) && (NULL == qe)) |
@@ -710,7 +710,7 @@ check_zone_to_name_response (void *cls, | |||
710 | (void) cls; | 710 | (void) cls; |
711 | if (GNUNET_EC_NONE != ntohl (msg->ec)) | 711 | if (GNUNET_EC_NONE != ntohl (msg->ec)) |
712 | return GNUNET_OK; | 712 | return GNUNET_OK; |
713 | key_len = ntohl (msg->key_len); | 713 | key_len = ntohs (msg->key_len); |
714 | name_len = ntohs (msg->name_len); | 714 | name_len = ntohs (msg->name_len); |
715 | rd_ser_len = ntohs (msg->rd_len); | 715 | rd_ser_len = ntohs (msg->rd_len); |
716 | if (ntohs (msg->gns_header.header.size) != | 716 | if (ntohs (msg->gns_header.header.size) != |
@@ -762,7 +762,7 @@ handle_zone_to_name_response (void *cls, | |||
762 | return; | 762 | return; |
763 | } | 763 | } |
764 | res = ntohl (msg->ec); | 764 | res = ntohl (msg->ec); |
765 | key_len = ntohl (msg->key_len); | 765 | key_len = ntohs (msg->key_len); |
766 | GNUNET_assert (GNUNET_SYSERR != | 766 | GNUNET_assert (GNUNET_SYSERR != |
767 | GNUNET_IDENTITY_read_private_key_from_buffer (&msg[1], | 767 | GNUNET_IDENTITY_read_private_key_from_buffer (&msg[1], |
768 | key_len, | 768 | key_len, |
@@ -1140,7 +1140,7 @@ GNUNET_NAMESTORE_records_store2 ( | |||
1140 | GNUNET_assert (NULL != msg); | 1140 | GNUNET_assert (NULL != msg); |
1141 | GNUNET_assert (NULL != env); | 1141 | GNUNET_assert (NULL != env); |
1142 | msg->gns_header.r_id = htonl (rid); | 1142 | msg->gns_header.r_id = htonl (rid); |
1143 | msg->key_len = htonl (key_len); | 1143 | msg->key_len = htons (key_len); |
1144 | msg->rd_set_count = htons ((uint16_t) (*rds_sent)); | 1144 | msg->rd_set_count = htons ((uint16_t) (*rds_sent)); |
1145 | GNUNET_IDENTITY_write_private_key_to_buffer (pkey, | 1145 | GNUNET_IDENTITY_write_private_key_to_buffer (pkey, |
1146 | &msg[1], | 1146 | &msg[1], |
@@ -1230,9 +1230,9 @@ records_lookup ( | |||
1230 | &msg[1], | 1230 | &msg[1], |
1231 | key_len); | 1231 | key_len); |
1232 | 1232 | ||
1233 | msg->key_len = htonl (key_len); | 1233 | msg->key_len = htons (key_len); |
1234 | msg->is_edit_request = htonl (is_edit_request); | 1234 | msg->is_edit_request = htons (is_edit_request); |
1235 | msg->label_len = htonl (label_len); | 1235 | msg->label_len = htons (label_len); |
1236 | msg->filter = htons (filter); | 1236 | msg->filter = htons (filter); |
1237 | GNUNET_memcpy (((char*) &msg[1]) + key_len, label, label_len); | 1237 | GNUNET_memcpy (((char*) &msg[1]) + key_len, label, label_len); |
1238 | if (NULL == h->mq) | 1238 | if (NULL == h->mq) |
@@ -1323,8 +1323,8 @@ GNUNET_NAMESTORE_zone_to_name ( | |||
1323 | env = GNUNET_MQ_msg_extra (msg, key_len + pkey_len, | 1323 | env = GNUNET_MQ_msg_extra (msg, key_len + pkey_len, |
1324 | GNUNET_MESSAGE_TYPE_NAMESTORE_ZONE_TO_NAME); | 1324 | GNUNET_MESSAGE_TYPE_NAMESTORE_ZONE_TO_NAME); |
1325 | msg->gns_header.r_id = htonl (rid); | 1325 | msg->gns_header.r_id = htonl (rid); |
1326 | msg->key_len = htonl (key_len); | 1326 | msg->key_len = htons (key_len); |
1327 | msg->pkey_len = htonl (pkey_len); | 1327 | msg->pkey_len = htons (pkey_len); |
1328 | GNUNET_IDENTITY_write_private_key_to_buffer (zone, &msg[1], key_len); | 1328 | GNUNET_IDENTITY_write_private_key_to_buffer (zone, &msg[1], key_len); |
1329 | GNUNET_IDENTITY_write_public_key_to_buffer (value_zone, | 1329 | GNUNET_IDENTITY_write_public_key_to_buffer (value_zone, |
1330 | (char*) &msg[1] + key_len, | 1330 | (char*) &msg[1] + key_len, |
@@ -1375,7 +1375,7 @@ GNUNET_NAMESTORE_zone_iteration_start ( | |||
1375 | key_len, | 1375 | key_len, |
1376 | GNUNET_MESSAGE_TYPE_NAMESTORE_ZONE_ITERATION_START); | 1376 | GNUNET_MESSAGE_TYPE_NAMESTORE_ZONE_ITERATION_START); |
1377 | msg->gns_header.r_id = htonl (rid); | 1377 | msg->gns_header.r_id = htonl (rid); |
1378 | msg->key_len = htonl (key_len); | 1378 | msg->key_len = htons (key_len); |
1379 | if (NULL != zone) | 1379 | if (NULL != zone) |
1380 | GNUNET_IDENTITY_write_private_key_to_buffer (zone, &msg[1], key_len); | 1380 | GNUNET_IDENTITY_write_private_key_to_buffer (zone, &msg[1], key_len); |
1381 | if (NULL == h->mq) | 1381 | if (NULL == h->mq) |
@@ -1424,7 +1424,7 @@ GNUNET_NAMESTORE_zone_iteration_start2 ( | |||
1424 | key_len, | 1424 | key_len, |
1425 | GNUNET_MESSAGE_TYPE_NAMESTORE_ZONE_ITERATION_START); | 1425 | GNUNET_MESSAGE_TYPE_NAMESTORE_ZONE_ITERATION_START); |
1426 | msg->gns_header.r_id = htonl (rid); | 1426 | msg->gns_header.r_id = htonl (rid); |
1427 | msg->key_len = htonl (key_len); | 1427 | msg->key_len = htons (key_len); |
1428 | msg->filter = htons ((uint16_t) filter); | 1428 | msg->filter = htons ((uint16_t) filter); |
1429 | if (NULL != zone) | 1429 | if (NULL != zone) |
1430 | GNUNET_IDENTITY_write_private_key_to_buffer (zone, &msg[1], key_len); | 1430 | GNUNET_IDENTITY_write_private_key_to_buffer (zone, &msg[1], key_len); |