gnunet-svn
[Top][All Lists]
Advanced

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

[GNUnet-SVN] r23258 - gnunet/src/mesh


From: gnunet
Subject: [GNUnet-SVN] r23258 - gnunet/src/mesh
Date: Thu, 16 Aug 2012 16:08:58 +0200

Author: bartpolot
Date: 2012-08-16 16:08:58 +0200 (Thu, 16 Aug 2012)
New Revision: 23258

Modified:
   gnunet/src/mesh/gnunet-service-mesh.c
Log:
- more debug, fixes

Modified: gnunet/src/mesh/gnunet-service-mesh.c
===================================================================
--- gnunet/src/mesh/gnunet-service-mesh.c       2012-08-16 14:00:01 UTC (rev 
23257)
+++ gnunet/src/mesh/gnunet-service-mesh.c       2012-08-16 14:08:58 UTC (rev 
23258)
@@ -2040,7 +2040,7 @@
 
 
 /**
- * Notify a the client of a tunnel about how many more
+ * Notify a client of a tunnel about how many more
  * payload packages will we accept on a given tunnel,
  * distinguishing between root and leaf clients.
  *
@@ -3612,7 +3612,7 @@
   if (-1 == child_ack)
   {
     // Node has no children, child_ack AND core buffer are irrelevant.
-    GNUNET_break (-1 != client_ack); // No children AND no clients? Not good!
+    GNUNET_break (-1 != client_ack); // No children AND no clients? Not good! 
// FIXME fc
     return (uint32_t) client_ack;
   }
 
@@ -3814,6 +3814,9 @@
 
       ack = clinfo->bck_pid;
       ack += t->nobuffer ? 1 : INITIAL_WINDOW_SIZE;
+      GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+                  "  sending ack to client %u: %u\n",
+                  t->clients[i]->id, ack);
       send_local_ack(t->clients[i],  t, ack);
       clinfo->bck_ack = ack;
     }
@@ -3835,11 +3838,9 @@
 static void
 tunnel_send_bck_ack (struct MeshTunnel *t, uint16_t type)
 {
-  if (NULL != t->owner)
-  {
-    send_client_tunnel_ack (t->owner, t);
-    return;
-  }
+  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+              "Sending BCK ACK on tunnel %u [%u]\n",
+              t->id.oid, t->id.tid);
   /* Is it after data to_origin retransmission? */
   switch (type)
   {
@@ -3853,12 +3854,13 @@
       }
       if (t->bck_queue_max > t->bck_queue_n * 2)
       {
-        GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Not sending ACK, buffer free\n");
-        return;
+//         GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Not sending ACK, buffer 
free\n");
+//         return;
       }
       break;
     case GNUNET_MESSAGE_TYPE_MESH_ACK:
     case GNUNET_MESSAGE_TYPE_MESH_LOCAL_ACK:
+      // FIXME fc
       break;
     default:
       GNUNET_break (0);
@@ -7061,7 +7063,7 @@
   t = tunnel_get_by_local_id (c, tid);
   if (NULL == t)
   {
-    GNUNET_break (0);
+    GNUNET_break (0); // FIXME fc
     GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
     return;
   }




reply via email to

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