Refactoring gnunet_time
authorMatthias Wachs <wachs@net.in.tum.de>
Wed, 27 Oct 2010 09:26:58 +0000 (09:26 +0000)
committerMatthias Wachs <wachs@net.in.tum.de>
Wed, 27 Oct 2010 09:26:58 +0000 (09:26 +0000)
src/arm/arm_api.c
src/arm/gnunet-service-arm.c
src/arm/gnunet-service-arm_interceptor.c
src/arm/test_exponential_backoff.c

index 66747a624acde3d7190926e1044ad00df255301d..dda5561ac05c4c83236dd9202a887654d272b7aa 100644 (file)
@@ -636,7 +636,7 @@ GNUNET_ARM_start_service (struct GNUNET_ARM_Handle *h,
 #if DEBUG_ARM
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               _("Asked to start service `%s' within %llu ms\n"), service_name,
-             (unsigned long long) timeout.value);
+             (unsigned long long) timeout.rel_value);
 #endif
   if (0 == strcasecmp ("arm", service_name))
     {
@@ -706,7 +706,7 @@ GNUNET_ARM_stop_service (struct GNUNET_ARM_Handle *h,
 
   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
               _("Stopping service `%s' within %llu ms\n"), service_name,
-             (unsigned long long) timeout.value);
+             (unsigned long long) timeout.rel_value);
   if (h->client == NULL)
     {
       client = GNUNET_CLIENT_connect (h->sched, "arm", h->cfg);
index 4ee19ef3d06cb1ba39e29c565abcbb3dbd0f39dd..2eb21a0682ca3db8e836e47d8cf75d116946ec55 100644 (file)
@@ -776,7 +776,7 @@ delayed_restart_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
       if ( (pos->pid == 0) && 
           (GNUNET_YES != in_shutdown) )
        {
-         if (GNUNET_TIME_absolute_get_remaining (pos->restartAt).value == 0)
+         if (GNUNET_TIME_absolute_get_remaining (pos->restartAt).rel_value == 0)
            {
              GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                          _("Restarting service `%s'.\n"), pos->name);
@@ -792,12 +792,12 @@ delayed_restart_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
        }
       pos = pos->next;
     }  
-  if (lowestRestartDelay.value != GNUNET_TIME_UNIT_FOREVER_REL.value)
+  if (lowestRestartDelay.rel_value != GNUNET_TIME_UNIT_FOREVER_REL.rel_value)
     {
 #if DEBUG_ARM
       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                  "Will restart process in %llums\n",
-                 (unsigned long long) lowestRestartDelay.value);
+                 (unsigned long long) lowestRestartDelay.rel_value);
 #endif
       child_restart_task
        = GNUNET_SCHEDULER_add_delayed (sched,
@@ -902,7 +902,7 @@ maint_child_death (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
          /* schedule restart */
          pos->restartAt
            = GNUNET_TIME_relative_to_absolute (pos->backoff);
-         if (pos->backoff.value < EXPONENTIAL_BACKOFF_THRESHOLD)
+         if (pos->backoff.rel_value < EXPONENTIAL_BACKOFF_THRESHOLD)
            pos->backoff 
              = GNUNET_TIME_relative_multiply (pos->backoff, 2);
          if (GNUNET_SCHEDULER_NO_TASK != child_restart_task)
index bc0c260a4f9c803379a1b409ad953c0e2c83c4e3..cddde57fbc3d9c4d6d34a2b639149dc6368232f7 100644 (file)
@@ -503,7 +503,7 @@ receiveFromService (void *cls,
                      GNUNET_a2s (fc->listen_info->service_addr,
                                  fc->listen_info->service_addr_len),
                      (unsigned long long) GNUNET_TIME_relative_min (fc->back_off,
-                                                                    rem).value);
+                                                                    rem).abs_value);
 #endif
          rem = GNUNET_TIME_absolute_get_remaining (fc->timeout);
          GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == fc->start_task);
@@ -597,7 +597,7 @@ forwardToService (void *cls,
                      GNUNET_a2s (fc->listen_info->service_addr,
                                  fc->listen_info->service_addr_len),
                      (unsigned long long) GNUNET_TIME_relative_min (fc->back_off,
-                                                                    rem).value);
+                                                                    rem).abs_value);
 #endif
          rem = GNUNET_TIME_absolute_get_remaining (fc->timeout);
          GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == fc->start_task);
@@ -728,7 +728,7 @@ start_forwarding (void *cls,
       return;
     }
   rem = GNUNET_TIME_absolute_get_remaining (fc->timeout);
-  if (rem.value == 0)
+  if (rem.rel_value == 0)
     {
       GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  _("Unable to forward to service `%s': timeout before connect\n"),
@@ -765,7 +765,7 @@ start_forwarding (void *cls,
                  GNUNET_a2s (fc->listen_info->service_addr,
                              fc->listen_info->service_addr_len),
                  (unsigned long long) GNUNET_TIME_relative_min (fc->back_off,
-                                                                rem).value);
+                                                                rem).abs_value);
 #endif
       GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == fc->start_task);
       fc->start_task
index e71d96b48ef7ac00bd4c6f1eda723d515786c386..dd32f6a5dd48fb5d4db5e3f3de86a4bd62ae4d41 100644 (file)
@@ -361,12 +361,12 @@ kill_task (void *cbData,
 #if LOG_BACKOFF
       fprintf(killLogFilePtr, 
              "Waited for: %llu ms\n", 
-             (unsigned long long) waitedFor.value);
+             (unsigned long long) waitedFor.abs_value);
 #endif
     }
   else
     {
-      waitedFor.value = 0;
+      waitedFor.rel_value = 0;
     }
   /* Connect to the doNothing task */
   doNothingConnection = GNUNET_CLIENT_connect (sched, "do-nothing", cfg);