aboutsummaryrefslogtreecommitdiff
path: root/src/reclaim/gnunet-service-reclaim.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/reclaim/gnunet-service-reclaim.c')
-rw-r--r--src/reclaim/gnunet-service-reclaim.c44
1 files changed, 23 insertions, 21 deletions
diff --git a/src/reclaim/gnunet-service-reclaim.c b/src/reclaim/gnunet-service-reclaim.c
index 4c80d6d24..8b468fc8e 100644
--- a/src/reclaim/gnunet-service-reclaim.c
+++ b/src/reclaim/gnunet-service-reclaim.c
@@ -674,7 +674,7 @@ send_ticket_result (const struct IdpClient *client,
674 buf = (char*) &irm[1]; 674 buf = (char*) &irm[1];
675 if (NULL != ticket) 675 if (NULL != ticket)
676 { 676 {
677 irm->tkt_len = htonl (tkt_len); 677 irm->tkt_len = htons (tkt_len);
678 written = GNUNET_RECLAIM_write_ticket_to_buffer (ticket, buf, tkt_len); 678 written = GNUNET_RECLAIM_write_ticket_to_buffer (ticket, buf, tkt_len);
679 GNUNET_assert (0 <= written); 679 GNUNET_assert (0 <= written);
680 buf += written; 680 buf += written;
@@ -746,8 +746,8 @@ check_issue_ticket_message (void *cls, const struct IssueTicketMessage *im)
746 746
747 size = ntohs (im->header.size); 747 size = ntohs (im->header.size);
748 attrs_len = ntohs (im->attr_len); 748 attrs_len = ntohs (im->attr_len);
749 key_len = ntohl (im->key_len); 749 key_len = ntohs (im->key_len);
750 pkey_len = ntohl (im->pkey_len); 750 pkey_len = ntohs (im->pkey_len);
751 if (size != attrs_len + key_len + pkey_len + sizeof(struct 751 if (size != attrs_len + key_len + pkey_len + sizeof(struct
752 IssueTicketMessage)) 752 IssueTicketMessage))
753 { 753 {
@@ -780,7 +780,7 @@ handle_issue_ticket_message (void *cls, const struct IssueTicketMessage *im)
780 char *buf; 780 char *buf;
781 781
782 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received ISSUE_TICKET message\n"); 782 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received ISSUE_TICKET message\n");
783 key_len = ntohl (im->key_len); 783 key_len = ntohs (im->key_len);
784 buf = (char *) &im[1]; 784 buf = (char *) &im[1];
785 if ((GNUNET_SYSERR == 785 if ((GNUNET_SYSERR ==
786 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len, 786 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len,
@@ -793,7 +793,7 @@ handle_issue_ticket_message (void *cls, const struct IssueTicketMessage *im)
793 return; 793 return;
794 } 794 }
795 buf += read; 795 buf += read;
796 pkey_len = ntohl (im->pkey_len); 796 pkey_len = ntohs (im->pkey_len);
797 if ((GNUNET_SYSERR == 797 if ((GNUNET_SYSERR ==
798 GNUNET_IDENTITY_read_public_key_from_buffer (buf, pkey_len, 798 GNUNET_IDENTITY_read_public_key_from_buffer (buf, pkey_len,
799 &rp, &read)) || 799 &rp, &read)) ||
@@ -898,7 +898,7 @@ handle_revoke_ticket_message (void *cls, const struct RevokeTicketMessage *rm)
898 char *buf; 898 char *buf;
899 899
900 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received REVOKE_TICKET message\n"); 900 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received REVOKE_TICKET message\n");
901 key_len = ntohl (rm->key_len); 901 key_len = ntohs (rm->key_len);
902 buf = (char *) &rm[1]; 902 buf = (char *) &rm[1];
903 if ((GNUNET_SYSERR == 903 if ((GNUNET_SYSERR ==
904 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len, 904 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len,
@@ -911,7 +911,7 @@ handle_revoke_ticket_message (void *cls, const struct RevokeTicketMessage *rm)
911 return; 911 return;
912 } 912 }
913 buf += read; 913 buf += read;
914 tkt_len = ntohl (rm->tkt_len); 914 tkt_len = ntohs (rm->tkt_len);
915 if ((GNUNET_SYSERR == 915 if ((GNUNET_SYSERR ==
916 GNUNET_RECLAIM_read_ticket_from_buffer (buf, tkt_len, 916 GNUNET_RECLAIM_read_ticket_from_buffer (buf, tkt_len,
917 &ticket, &read)) || 917 &ticket, &read)) ||
@@ -974,8 +974,8 @@ consume_result_cb (void *cls,
974 crm->id = htonl (cop->r_id); 974 crm->id = htonl (cop->r_id);
975 crm->attrs_len = htons (attrs_len); 975 crm->attrs_len = htons (attrs_len);
976 crm->presentations_len = htons (pres_len); 976 crm->presentations_len = htons (pres_len);
977 crm->key_len = htonl (key_len); 977 crm->key_len = htons (key_len);
978 crm->result = htonl (success); 978 crm->result = htons (success);
979 data_tmp = (char *) &crm[1]; 979 data_tmp = (char *) &crm[1];
980 written = GNUNET_IDENTITY_write_public_key_to_buffer (identity, 980 written = GNUNET_IDENTITY_write_public_key_to_buffer (identity,
981 data_tmp, 981 data_tmp,
@@ -1033,7 +1033,7 @@ handle_consume_ticket_message (void *cls, const struct ConsumeTicketMessage *cm)
1033 char *buf; 1033 char *buf;
1034 1034
1035 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received CONSUME_TICKET message\n"); 1035 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received CONSUME_TICKET message\n");
1036 key_len = ntohl (cm->key_len); 1036 key_len = ntohs (cm->key_len);
1037 buf = (char *) &cm[1]; 1037 buf = (char *) &cm[1];
1038 if ((GNUNET_SYSERR == 1038 if ((GNUNET_SYSERR ==
1039 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len, 1039 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len,
@@ -1046,7 +1046,7 @@ handle_consume_ticket_message (void *cls, const struct ConsumeTicketMessage *cm)
1046 return; 1046 return;
1047 } 1047 }
1048 buf += read; 1048 buf += read;
1049 tkt_len = ntohl (cm->tkt_len); 1049 tkt_len = ntohs (cm->tkt_len);
1050 if ((GNUNET_SYSERR == 1050 if ((GNUNET_SYSERR ==
1051 GNUNET_RECLAIM_read_ticket_from_buffer (buf, tkt_len, 1051 GNUNET_RECLAIM_read_ticket_from_buffer (buf, tkt_len,
1052 &ticket, &read)) || 1052 &ticket, &read)) ||
@@ -1197,7 +1197,7 @@ handle_attribute_store_message (void *cls,
1197 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received ATTRIBUTE_STORE message\n"); 1197 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received ATTRIBUTE_STORE message\n");
1198 1198
1199 data_len = ntohs (sam->attr_len); 1199 data_len = ntohs (sam->attr_len);
1200 key_len = ntohl (sam->key_len); 1200 key_len = ntohs (sam->key_len);
1201 buf = (char *) &sam[1]; 1201 buf = (char *) &sam[1];
1202 if ((GNUNET_SYSERR == 1202 if ((GNUNET_SYSERR ==
1203 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len, 1203 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len,
@@ -1398,7 +1398,7 @@ handle_credential_store_message (void *cls,
1398 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received CREDENTIAL_STORE message\n"); 1398 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received CREDENTIAL_STORE message\n");
1399 1399
1400 data_len = ntohs (sam->attr_len); 1400 data_len = ntohs (sam->attr_len);
1401 key_len = ntohl (sam->key_len); 1401 key_len = ntohs (sam->key_len);
1402 buf = (char *) &sam[1]; 1402 buf = (char *) &sam[1];
1403 if ((GNUNET_SYSERR == 1403 if ((GNUNET_SYSERR ==
1404 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len, 1404 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len,
@@ -1869,7 +1869,7 @@ handle_attribute_delete_message (void *cls,
1869 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received ATTRIBUTE_DELETE message\n"); 1869 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received ATTRIBUTE_DELETE message\n");
1870 1870
1871 data_len = ntohs (dam->attr_len); 1871 data_len = ntohs (dam->attr_len);
1872 key_len = ntohl (dam->key_len); 1872 key_len = ntohs (dam->key_len);
1873 buf = (char *) &dam[1]; 1873 buf = (char *) &dam[1];
1874 if ((GNUNET_SYSERR == 1874 if ((GNUNET_SYSERR ==
1875 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len, 1875 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len,
@@ -1976,7 +1976,7 @@ handle_credential_delete_message (void *cls,
1976 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received CREDENTIAL_DELETE message\n"); 1976 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received CREDENTIAL_DELETE message\n");
1977 1977
1978 data_len = ntohs (dam->attr_len); 1978 data_len = ntohs (dam->attr_len);
1979 key_len = ntohl (dam->key_len); 1979 key_len = ntohs (dam->key_len);
1980 buf = (char *) &dam[1]; 1980 buf = (char *) &dam[1];
1981 if ((GNUNET_SYSERR == 1981 if ((GNUNET_SYSERR ==
1982 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len, 1982 GNUNET_IDENTITY_read_private_key_from_buffer (buf, key_len,
@@ -2033,7 +2033,7 @@ attr_iter_finished (void *cls)
2033 env = GNUNET_MQ_msg (arm, GNUNET_MESSAGE_TYPE_RECLAIM_ATTRIBUTE_RESULT); 2033 env = GNUNET_MQ_msg (arm, GNUNET_MESSAGE_TYPE_RECLAIM_ATTRIBUTE_RESULT);
2034 arm->id = htonl (ai->request_id); 2034 arm->id = htonl (ai->request_id);
2035 arm->attr_len = htons (0); 2035 arm->attr_len = htons (0);
2036 arm->pkey_len = htonl (0); 2036 arm->pkey_len = htons (0);
2037 GNUNET_MQ_send (ai->client->mq, env); 2037 GNUNET_MQ_send (ai->client->mq, env);
2038 GNUNET_CONTAINER_DLL_remove (ai->client->attr_iter_head, 2038 GNUNET_CONTAINER_DLL_remove (ai->client->attr_iter_head,
2039 ai->client->attr_iter_tail, 2039 ai->client->attr_iter_tail,
@@ -2099,7 +2099,7 @@ attr_iter_cb (void *cls,
2099 arm->id = htonl (ai->request_id); 2099 arm->id = htonl (ai->request_id);
2100 arm->attr_len = htons (rd->data_size); 2100 arm->attr_len = htons (rd->data_size);
2101 data_tmp = (char *) &arm[1]; 2101 data_tmp = (char *) &arm[1];
2102 arm->pkey_len = htonl (key_len); 2102 arm->pkey_len = htons (key_len);
2103 written = GNUNET_IDENTITY_write_public_key_to_buffer (&identity, 2103 written = GNUNET_IDENTITY_write_public_key_to_buffer (&identity,
2104 data_tmp, 2104 data_tmp,
2105 key_len); 2105 key_len);
@@ -2147,7 +2147,7 @@ handle_iteration_start (void *cls,
2147 2147
2148 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 2148 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2149 "Received ATTRIBUTE_ITERATION_START message\n"); 2149 "Received ATTRIBUTE_ITERATION_START message\n");
2150 key_len = ntohl (ais_msg->key_len); 2150 key_len = ntohs (ais_msg->key_len);
2151 if ((GNUNET_SYSERR == 2151 if ((GNUNET_SYSERR ==
2152 GNUNET_IDENTITY_read_private_key_from_buffer (&ais_msg[1], 2152 GNUNET_IDENTITY_read_private_key_from_buffer (&ais_msg[1],
2153 key_len, 2153 key_len,
@@ -2263,6 +2263,7 @@ cred_iter_finished (void *cls)
2263 env = GNUNET_MQ_msg (arm, GNUNET_MESSAGE_TYPE_RECLAIM_CREDENTIAL_RESULT); 2263 env = GNUNET_MQ_msg (arm, GNUNET_MESSAGE_TYPE_RECLAIM_CREDENTIAL_RESULT);
2264 arm->id = htonl (ai->request_id); 2264 arm->id = htonl (ai->request_id);
2265 arm->credential_len = htons (0); 2265 arm->credential_len = htons (0);
2266 arm->key_len = htons (0);
2266 GNUNET_MQ_send (ai->client->mq, env); 2267 GNUNET_MQ_send (ai->client->mq, env);
2267 GNUNET_CONTAINER_DLL_remove (ai->client->cred_iter_head, 2268 GNUNET_CONTAINER_DLL_remove (ai->client->cred_iter_head,
2268 ai->client->cred_iter_tail, 2269 ai->client->cred_iter_tail,
@@ -2327,6 +2328,7 @@ cred_iter_cb (void *cls,
2327 GNUNET_MESSAGE_TYPE_RECLAIM_CREDENTIAL_RESULT); 2328 GNUNET_MESSAGE_TYPE_RECLAIM_CREDENTIAL_RESULT);
2328 arm->id = htonl (ai->request_id); 2329 arm->id = htonl (ai->request_id);
2329 arm->credential_len = htons (rd->data_size); 2330 arm->credential_len = htons (rd->data_size);
2331 arm->key_len = htons (key_len);
2330 data_tmp = (char *) &arm[1]; 2332 data_tmp = (char *) &arm[1];
2331 written = GNUNET_IDENTITY_write_public_key_to_buffer (&identity, 2333 written = GNUNET_IDENTITY_write_public_key_to_buffer (&identity,
2332 data_tmp, 2334 data_tmp,
@@ -2376,7 +2378,7 @@ handle_credential_iteration_start (void *cls,
2376 2378
2377 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 2379 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2378 "Received CREDENTIAL_ITERATION_START message\n"); 2380 "Received CREDENTIAL_ITERATION_START message\n");
2379 key_len = ntohl (ais_msg->key_len); 2381 key_len = ntohs (ais_msg->key_len);
2380 if ((GNUNET_SYSERR == 2382 if ((GNUNET_SYSERR ==
2381 GNUNET_IDENTITY_read_private_key_from_buffer (&ais_msg[1], 2383 GNUNET_IDENTITY_read_private_key_from_buffer (&ais_msg[1],
2382 key_len, 2384 key_len,
@@ -2514,7 +2516,7 @@ ticket_iter_cb (void *cls, struct GNUNET_RECLAIM_Ticket *ticket)
2514 &trm[1], 2516 &trm[1],
2515 tkt_len); 2517 tkt_len);
2516 } 2518 }
2517 trm->tkt_len = htonl (tkt_len); 2519 trm->tkt_len = htons (tkt_len);
2518 trm->id = htonl (ti->r_id); 2520 trm->id = htonl (ti->r_id);
2519 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sending TICKET_RESULT message\n"); 2521 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sending TICKET_RESULT message\n");
2520 GNUNET_MQ_send (ti->client->mq, env); 2522 GNUNET_MQ_send (ti->client->mq, env);
@@ -2560,7 +2562,7 @@ handle_ticket_iteration_start (
2560 2562
2561 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 2563 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2562 "Received TICKET_ITERATION_START message\n"); 2564 "Received TICKET_ITERATION_START message\n");
2563 key_len = ntohl (tis_msg->key_len); 2565 key_len = ntohs (tis_msg->key_len);
2564 if ((GNUNET_SYSERR == 2566 if ((GNUNET_SYSERR ==
2565 GNUNET_IDENTITY_read_private_key_from_buffer (&tis_msg[1], 2567 GNUNET_IDENTITY_read_private_key_from_buffer (&tis_msg[1],
2566 key_len, 2568 key_len,