better logging of message processing errors in mq handling

1 files changed, 15 insertions, 3 deletions

diff --git a/src/util/mst.c b/src/util/mst.c
index 0d90c5d10..4c2a74212 100644
--- a/src/util/mst.c
+++ b/src/util/mst.c
@@ -1,6 +1,6 @@
 /*
      This file is part of GNUnet.
-     Copyright (C) 2010, 2016 GNUnet e.V.
+     Copyright (C) 2010, 2016, 2017 GNUnet e.V.
 
      GNUnet is free software; you can redistribute it and/or modify
      it under the terms of the GNU General Public License as published
@@ -229,9 +229,15 @@ do_align:
     if (one_shot == GNUNET_YES)
       one_shot = GNUNET_SYSERR;
     mst->off += want;
-  if (GNUNET_SYSERR == mst->cb (mst->cb_cls,
-                                hdr))
+    if (GNUNET_SYSERR == mst->cb (mst->cb_cls,
+                                  hdr))
+    {
+      GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+                  "Failure processing message of type %u and size %u\n",
+                  ntohs (hdr->type),
+                  ntohs (hdr->size));
       return GNUNET_SYSERR;
+    }
     if (mst->off == mst->pos)
     {
       /* reset to beginning of buffer, it's free right now! */
@@ -273,7 +279,13 @@ do_align:
         one_shot = GNUNET_SYSERR;
       if (GNUNET_SYSERR == mst->cb (mst->cb_cls,
                                     hdr))
+      {
+        GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+                    "Failure processing message of type %u and size %u\n",
+                    ntohs (hdr->type),
+                    ntohs (hdr->size));
         return GNUNET_SYSERR;
+      }
       buf += want;
       size -= want;
     }