[GNUnet-SVN] r15701 - gnunet/src/util

[gnunet]

Author: grothoff
Date: 2011-06-17 17:02:17 +0200 (Fri, 17 Jun 2011)
New Revision: 15701

Modified:
   gnunet/src/util/server_nc.c
Log:
cleanup

Modified: gnunet/src/util/server_nc.c
===================================================================
--- gnunet/src/util/server_nc.c 2011-06-17 14:52:05 UTC (rev 15700)
+++ gnunet/src/util/server_nc.c 2011-06-17 15:02:17 UTC (rev 15701)
@@ -28,6 +28,7 @@
 #include "platform.h"
 #include "gnunet_common.h"
 #include "gnunet_connection_lib.h"
+#include "gnunet_container_lib.h"
 #include "gnunet_scheduler_lib.h"
 #include "gnunet_server_lib.h"
 #include "gnunet_time_lib.h"
@@ -42,11 +43,16 @@
 {
 
   /**
-   * This is a linked list.
+   * This is a doubly-linked list.
    */ 
   struct PendingMessageList *next;
 
   /**
+   * This is a doubly-linked list.
+   */ 
+  struct PendingMessageList *prev;
+
+  /**
    * Message to transmit (allocated at the end of this
    * struct, do not free)
    */
@@ -175,7 +181,9 @@
     prev->next = pos->next;
   while (NULL != (pml = pos->pending_head))
     {
-      pos->pending_head = pml->next;
+      GNUNET_CONTAINER_DLL_remove (pos->pending_head,
+                                  pos->pending_tail,
+                                  pml);
       GNUNET_free (pml);
     }
   GNUNET_SERVER_client_drop (client);
@@ -231,7 +239,9 @@
       GNUNET_SERVER_receive_done (pos->client, GNUNET_NO);
       while (NULL != (pml = pos->pending_head))
        {
-         pos->pending_head = pml->next;
+         GNUNET_CONTAINER_DLL_remove (pos->pending_head,
+                                      pos->pending_tail,
+                                      pml);
          GNUNET_free (pml);
        }
       GNUNET_free (pos);
@@ -297,15 +307,14 @@
       return 0;
     }
   ret = 0;
-  while (cl->pending_head != NULL)
+  while (NULL != (pml = cl->pending_head) )
     {
-      pml = cl->pending_head;
       msize = ntohs (pml->msg->size);
       if (size < msize)
        break;
-      cl->pending_head = pml->next;
-      if (pml->next == NULL)
-       cl->pending_tail = NULL;
+      GNUNET_CONTAINER_DLL_remove (cl->pending_head,
+                                  cl->pending_tail,
+                                  pml);
 #if DEBUG_SERVER_NC
       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                  "Copying message of type %u and size %u from pending queue to 
transmission buffer\n",
@@ -318,7 +327,7 @@
       GNUNET_free (pml);
       cl->num_pending--;
     }
-  if (cl->pending_head != NULL)    
+  if (pml != NULL)    
     {
 #if DEBUG_SERVER_NC
       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
@@ -326,7 +335,7 @@
                  cl->num_pending);
 #endif
       cl->th = GNUNET_SERVER_notify_transmit_ready (cl->client,
-                                                   ntohs 
(cl->pending_head->msg->size),
+                                                   ntohs (pml->msg->size),
                                                    
GNUNET_TIME_UNIT_FOREVER_REL,
                                                    &transmit_message,
                                                    cl);
@@ -383,11 +392,9 @@
 #endif
   memcpy (&pml[1], msg, size);
   /* append */
-  if (client->pending_tail != NULL)
-    client->pending_tail->next = pml;
-  else
-    client->pending_head = pml;
-  client->pending_tail = pml;
+  GNUNET_CONTAINER_DLL_insert_tail (client->pending_head,
+                                   client->pending_tail,
+                                   pml);
   if (client->th == NULL)
     client->th = GNUNET_SERVER_notify_transmit_ready (client->client,
                                                      ntohs 
(client->pending_head->msg->size),