transport: add a couple of comments to TCP communicator/service

3 files changed, 8 insertions, 10 deletions

diff --git a/contrib/handbook b/contrib/handbook
-Subproject f88a389426a665df222486b0563e5a91e77a704
+Subproject f9368db2bf8ce9eb6a9e951891142309c9c898d
diff --git a/src/service/transport/gnunet-communicator-tcp.c b/src/service/transport/gnunet-communicator-tcp.c
index b08b571d1..bb6c10166 100644
--- a/src/service/transport/gnunet-communicator-tcp.c
+++ b/src/service/transport/gnunet-communicator-tcp.c
@@ -1321,6 +1321,7 @@ rekey_monotime_cb (void *cls,
     GNUNET_break (0);
     GNUNET_PEERSTORE_iteration_stop (queue->rekey_monotime_get);
     queue->rekey_monotime_get = NULL;
+    // FIXME: Why should we try to gracefully finish here??
     queue_finish (queue);
     return;
   }
@@ -1402,6 +1403,7 @@ do_rekey (struct Queue *queue, const struct TCPRekey *rekey)
         &queue->target.public_key))
   {
     GNUNET_break (0);
+    // FIXME Why should we try to gracefully finish here?
     queue_finish (queue);
     return;
   }
@@ -1483,6 +1485,7 @@ handshake_ack_monotime_cb (void *cls,
     GNUNET_break (0);
     GNUNET_PEERSTORE_iteration_stop (queue->handshake_ack_monotime_get);
     queue->handshake_ack_monotime_get = NULL;
+    // FIXME: Why should we try to gracefully finish here?
     queue_finish (queue);
     return;
   }
@@ -1908,8 +1911,7 @@ try_handle_plaintext (struct Queue *queue)
     if (sizeof(*tca) > queue->pread_off)
     {
       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
-                  "Handling plaintext size of tca greater than pread offset.\n")
-      ;
+                  "Handling plaintext size of tca greater than pread offset.\n");
       return 0;
     }
     if (ntohs (hdr->size) != sizeof(*tca))
@@ -2123,7 +2125,7 @@ queue_read (void *cls)
     if ((EAGAIN != errno) && (EINTR != errno))
     {
       GNUNET_log_strerror (GNUNET_ERROR_TYPE_DEBUG, "recv");
-      queue_finish (queue);
+      queue_destroy (queue);
       return;
     }
     /* try again */
@@ -2140,7 +2142,7 @@ queue_read (void *cls)
                 GNUNET_STRINGS_relative_time_to_string (
                   GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT,
                   GNUNET_YES));
-    queue_finish (queue);
+    queue_destroy (queue);
     return;
   }
   if (0 == rcvd)
@@ -2222,7 +2224,7 @@ queue_read (void *cls)
               GNUNET_STRINGS_relative_time_to_string (
                 GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT,
                 GNUNET_YES));
-  queue_finish (queue);
+  queue_destroy (queue);
 }
 
 
diff --git a/src/service/transport/gnunet-service-transport.c b/src/service/transport/gnunet-service-transport.c
index 344f46f1e..ca191d49d 100644
--- a/src/service/transport/gnunet-service-transport.c
+++ b/src/service/transport/gnunet-service-transport.c
@@ -3898,8 +3898,7 @@ free_queue (struct Queue *queue)
                                 tc->details.communicator.queue_tail,
                                 queue);
   maxxed = (COMMUNICATOR_TOTAL_QUEUE_LIMIT <=
-            tc->details.communicator.
-            total_queue_length);
+            tc->details.communicator.total_queue_length);
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Cleaning up queue with length %u\n",
               queue->queue_length);
@@ -3915,9 +3914,6 @@ free_queue (struct Queue *queue)
     }
     GNUNET_free (qe);
   }
-  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
-              "Cleaning up queue with length %u\n",
-              queue->queue_length);
   GNUNET_assert (0 == queue->queue_length);
   if ((maxxed) && (COMMUNICATOR_TOTAL_QUEUE_LIMIT >
                    tc->details.communicator.total_queue_length))