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
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_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,
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