}
}
h->response_proc = NULL;
+#if DEBUG_DATASTORE
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Received status %d/%s\n",
+ status,
+ emsg);
+#endif
cont (h->response_proc_cls,
status,
emsg);
gettext_noop ("Error transmitting message to datastore service.\n"));
return 0;
}
- GNUNET_assert (h->message_size <= size);
- memcpy (buf, &h[1], h->message_size);
+ msize = h->message_size;
+ GNUNET_assert (msize <= size);
+ memcpy (buf, &h[1], msize);
+#if DEBUG_DATASTORE
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Transmitted %u byte message to datastore service, now waiting for status.\n",
+ msize);
+#endif
h->message_size = 0;
GNUNET_CLIENT_receive (h->client,
&with_status_response_handler,
const struct GNUNET_MessageHeader *hdr;
uint16_t msize;
+ GNUNET_assert (cont != NULL);
hdr = (const struct GNUNET_MessageHeader*) &h[1];
msize = ntohs(hdr->size);
+#if DEBUG_DATASTORE
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Transmitting %u byte message of type %u to datastore service\n",
+ msize,
+ ntohs(hdr->type));
+#endif
GNUNET_assert (h->response_proc == NULL);
h->response_proc = cont;
h->response_proc_cls = cont_cls;
struct DataMessage *dm;
size_t msize;
+#if DEBUG_DATASTORE
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Asked to put %u bytes of data\n",
+ size);
+#endif
msize = sizeof(struct DataMessage) + size;
GNUNET_assert (msize <= GNUNET_SERVER_MAX_MESSAGE_SIZE);
dm = (struct DataMessage*) &h[1];
void
GNUNET_DATASTORE_reserve (struct GNUNET_DATASTORE_Handle *h,
uint64_t amount,
- uint64_t entries,
+ uint32_t entries,
GNUNET_DATASTORE_ContinuationWithStatus cont,
void *cont_cls,
struct GNUNET_TIME_Relative timeout)
rm = (struct ReserveMessage*) &h[1];
rm->header.type = htons(GNUNET_MESSAGE_TYPE_DATASTORE_RESERVE);
rm->header.size = htons(sizeof (struct ReserveMessage));
- rm->reserved = htonl(0);
- rm->amount = htonl(amount);
rm->entries = htonl(entries);
+ rm->amount = htonl(amount);
transmit_for_status (h, cont, cont_cls, timeout);
}
{
GNUNET_break (ntohs(msg->size) == sizeof(struct GNUNET_MessageHeader));
h->response_proc = NULL;
+#if DEBUG_DATASTORE
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Received end of result set\n");
+#endif
cont (h->response_proc_cls,
NULL, 0, NULL, 0, 0, 0, zero, 0);
return;
NULL, 0, NULL, 0, 0, 0, zero, 0);
return;
}
+#if DEBUG_DATASTORE
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Received result %llu with type %u and size %u with key %s\n",
+ (unsigned long long) GNUNET_ntohll(dm->uid),
+ ntohl(dm->type),
+ msize,
+ GNUNET_h2s(&dm->key));
+#endif
cont (h->response_proc_cls,
&dm->key,
msize,
GNUNET_DATASTORE_ContinuationWithStatus cont = h->response_proc;
uint16_t msize;
- h->response_proc = NULL;
if (buf == NULL)
{
+ h->response_proc = NULL;
h->message_size = 0;
cont (h->response_proc_cls,
GNUNET_SYSERR,
gettext_noop ("Error transmitting message to datastore service.\n"));
return 0;
}
- GNUNET_assert (h->message_size <= size);
- memcpy (buf, &h[1], h->message_size);
+ msize = h->message_size;
+ GNUNET_assert (msize <= size);
+ memcpy (buf, &h[1], msize);
+#if DEBUG_DATASTORE
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Transmitted %u byte message to datastore service, now waiting for result.\n",
+ msize);
+#endif
h->message_size = 0;
GNUNET_CLIENT_receive (h->client,
&with_result_response_handler,
const struct GNUNET_MessageHeader *hdr;
uint16_t msize;
+ GNUNET_assert (cont != NULL);
hdr = (const struct GNUNET_MessageHeader*) &h[1];
msize = ntohs(hdr->size);
+#if DEBUG_DATASTORE
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Transmitting %u byte message of type %u to datastore service\n",
+ msize,
+ ntohs(hdr->type));
+#endif
GNUNET_assert (h->response_proc == NULL);
h->response_proc = cont;
h->response_proc_cls = cont_cls;