1 /* anonymity */ ,
0 /* replication */ ,
exp, 1 + prq.priority, MAX_DATASTORE_QUEUE,
- GNUNET_CONSTANTS_SERVICE_TIMEOUT,
&put_migration_continuation, pmc))
{
put_migration_continuation (pmc,
pr->public_data.options)) ? UINT_MAX :
GSF_datastore_queue_size
/* max queue size */ ,
- GNUNET_TIME_UNIT_FOREVER_REL,
&process_local_reply, pr);
if (NULL != pr->qe)
return; /* we're done */
{
GNUNET_break (0);
GNUNET_DATASTORE_remove (GSF_dsh, key, size, data, -1, -1,
- GNUNET_TIME_UNIT_FOREVER_REL, NULL, NULL);
+ NULL, NULL);
pr->qe_start = GNUNET_TIME_absolute_get ();
pr->warn_task =
GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES,
pr->public_data.options)) ? UINT_MAX :
GSF_datastore_queue_size
/* max queue size */ ,
- GNUNET_TIME_UNIT_FOREVER_REL,
&process_local_reply, pr);
if (NULL == pr->qe)
{
public_data.options)) ? UINT_MAX :
GSF_datastore_queue_size
/* max queue size */ ,
- GNUNET_TIME_UNIT_FOREVER_REL,
&process_local_reply, pr);
/* check if we successfully queued another datastore request;
* if so, return, otherwise call our continuation (if we have
public_data.options)) ? UINT_MAX :
GSF_datastore_queue_size
/* max queue size */ ,
- GNUNET_TIME_UNIT_FOREVER_REL,
&process_local_reply, pr);
if (NULL != pr->qe)
return;
prq.priority, 1 /* anonymity */ ,
0 /* replication */ ,
expiration, 1 + prq.priority, MAX_DATASTORE_QUEUE,
- GNUNET_CONSTANTS_SERVICE_TIMEOUT,
&put_migration_continuation, pmc))
{
put_migration_continuation (pmc,