gnunet-svn
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[taler-exchange] branch master updated: -more logging, less hanging ;-)


From: gnunet
Subject: [taler-exchange] branch master updated: -more logging, less hanging ;-)
Date: Sat, 11 Dec 2021 14:03:10 +0100

This is an automated email from the git hooks/post-receive script.

grothoff pushed a commit to branch master
in repository exchange.

The following commit(s) were added to refs/heads/master by this push:
     new 4eb95884 -more logging, less hanging ;-)
4eb95884 is described below

commit 4eb958846fdd91f3f912665bd0c0295e8eebcf1d
Author: Christian Grothoff <christian@grothoff.org>
AuthorDate: Sat Dec 11 14:03:08 2021 +0100

    -more logging, less hanging ;-)
---
 src/exchange/taler-exchange-wirewatch.c | 31 +++++++++++++++++++++++++++++--
 1 file changed, 29 insertions(+), 2 deletions(-)

diff --git a/src/exchange/taler-exchange-wirewatch.c 
b/src/exchange/taler-exchange-wirewatch.c
index eb044994..6b63de76 100644
--- a/src/exchange/taler-exchange-wirewatch.c
+++ b/src/exchange/taler-exchange-wirewatch.c
@@ -410,6 +410,11 @@ shard_completed (struct WireAccount *wa)
     GNUNET_assert (NULL != wa_pos);
   }
   GNUNET_assert (NULL == task);
+  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+              "Will look for more transfers in %s\n",
+              GNUNET_STRINGS_relative_time_to_string (
+                GNUNET_TIME_absolute_get_remaining (wa_pos->delayed_until),
+                GNUNET_YES));
   task = GNUNET_SCHEDULER_add_at (wa_pos->delayed_until,
                                   &find_transfers,
                                   NULL);
@@ -527,6 +532,11 @@ history_cb (void *cls,
                   (unsigned int) ec,
                   http_status);
     }
+    else
+    {
+      GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+                  "History response complete\n");
+    }
     if (wa->started_transaction)
     {
       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
@@ -544,6 +554,10 @@ history_cb (void *cls,
         GNUNET_SCHEDULER_shutdown ();
         return GNUNET_OK;
       }
+      else
+      {
+        shard_completed (wa);
+      }
     }
     return GNUNET_OK; /* will be ignored anyway */
   }
@@ -700,12 +714,22 @@ find_transfers (void *cls)
       return;
     case GNUNET_DB_STATUS_SOFT_ERROR:
       /* try again */
+      GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+                  "Serialization error tying to obtain shard, will try again 
in %s!\n",
+                  GNUNET_STRINGS_relative_time_to_string (
+                    wirewatch_idle_sleep_interval,
+                    GNUNET_YES));
       task = GNUNET_SCHEDULER_add_delayed (wirewatch_idle_sleep_interval,
                                            &find_transfers,
                                            NULL);
       return;
     case GNUNET_DB_STATUS_SUCCESS_NO_RESULTS:
       GNUNET_break (0);
+      GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+                  "No shard available, will try again in %s!\n",
+                  GNUNET_STRINGS_relative_time_to_string (
+                    wirewatch_idle_sleep_interval,
+                    GNUNET_YES));
       task = GNUNET_SCHEDULER_add_delayed (wirewatch_idle_sleep_interval,
                                            &find_transfers,
                                            NULL);
@@ -715,8 +739,11 @@ find_transfers (void *cls)
       wa_pos->shard_end = end;
       wa_pos->batch_start = start;
       GNUNET_log (GNUNET_ERROR_TYPE_INFO,
-                  "Starting with shard at %llu\n",
-                  (unsigned long long) start);
+                  "Starting with shard at [%llu,%llu) locked for %s\n",
+                  (unsigned long long) start,
+                  (unsigned long long) end,
+                  GNUNET_STRINGS_relative_time_to_string (delay,
+                                                          GNUNET_YES));
       break;
     }
   }

-- 
To stop receiving notification emails like this one, please contact
gnunet@gnunet.org.



reply via email to

[Prev in Thread] Current Thread [Next in Thread]