{
struct GNUNET_DATASTORE_Handle *h = cls;
- if (h->retry_time.value < GNUNET_CONSTANTS_SERVICE_RETRY.value)
+ if (h->retry_time.rel_value < GNUNET_CONSTANTS_SERVICE_RETRY.rel_value)
h->retry_time = GNUNET_CONSTANTS_SERVICE_RETRY;
else
h->retry_time = GNUNET_TIME_relative_multiply (h->retry_time, 2);
- if (h->retry_time.value > GNUNET_CONSTANTS_SERVICE_TIMEOUT.value)
+ if (h->retry_time.rel_value > GNUNET_CONSTANTS_SERVICE_TIMEOUT.rel_value)
h->retry_time = GNUNET_CONSTANTS_SERVICE_TIMEOUT;
h->reconnect_task = GNUNET_SCHEDULER_NO_TASK;
h->client = GNUNET_CLIENT_connect (h->sched, "datastore", h->cfg);
gettext_noop ("# status messages received"),
1,
GNUNET_NO);
- h->retry_time.value = 0;
+ h->retry_time.rel_value = 0;
process_queue (h);
if (rc.cont != NULL)
rc.cont (rc.cont_cls,
"Asked to update entry %llu raising priority by %u and expiration to %llu\n",
uid,
(unsigned int) priority,
- (unsigned long long) expiration.value);
+ (unsigned long long) expiration.abs_value);
#endif
qc.sc.cont = cont;
qc.sc.cont_cls = cont_cls;
rc.iter (rc.iter_cls,
NULL, 0, NULL, 0, 0, 0,
GNUNET_TIME_UNIT_ZERO_ABS, 0);
- h->retry_time.value = 0;
+ h->retry_time.rel_value = 0;
h->result_count = 0;
process_queue (h);
return;
ntohl(dm->size),
GNUNET_h2s(&dm->key));
#endif
- h->retry_time.value = 0;
+ h->retry_time.rel_value = 0;
rc.iter (rc.iter_cls,
&dm->key,
ntohl(dm->size),
#if DEBUG_DATASTORE
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Asked to get random entry in %llu ms\n",
- (unsigned long long) timeout.value);
+ (unsigned long long) timeout.abs_value);
#endif
qc.rc.iter = iter;
qc.rc.iter_cls = iter_cls;
#if DEBUG_DATASTORE
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Asked to get zero-anonymity entry in %llu ms\n",
- (unsigned long long) timeout.value);
+ (unsigned long long) timeout.abs_value);
#endif
qc.rc.iter = iter;
qc.rc.iter_cls = iter_cls;