gnunet-svn
[Top][All Lists]
Advanced

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

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


From: gnunet
Subject: [GNUnet-SVN] r21804 - gnunet/src/mesh
Date: Fri, 8 Jun 2012 15:19:21 +0200

Author: bartpolot
Date: 2012-06-08 15:19:21 +0200 (Fri, 08 Jun 2012)
New Revision: 21804

Modified:
   gnunet/src/mesh/gnunet-service-mesh_new.c
Log:
- remove old queue code

Modified: gnunet/src/mesh/gnunet-service-mesh_new.c
===================================================================
--- gnunet/src/mesh/gnunet-service-mesh_new.c   2012-06-08 13:04:58 UTC (rev 
21803)
+++ gnunet/src/mesh/gnunet-service-mesh_new.c   2012-06-08 13:19:21 UTC (rev 
21804)
@@ -229,43 +229,6 @@
 
 
 /**
- * Data scheduled to transmit (to local client or remote peer)
- */
-struct MeshQueue
-{
-    /**
-     * Double linked list
-     */
-  struct MeshQueue *next;
-  struct MeshQueue *prev;
-
-    /**
-     * Target of the data (NULL if target is client)
-     */
-  struct MeshPeerInfo *peer;
-
-    /**
-     * Client to send the data to (NULL if target is peer)
-     */
-  struct MeshClient *client;
-
-    /**
-     * Size of the message to transmit
-     */
-  unsigned int size;
-
-    /**
-     * How old is the data?
-     */
-  struct GNUNET_TIME_Absolute timestamp;
-
-    /**
-     * Data itself
-     */
-  struct GNUNET_MessageHeader *data;
-};
-
-/**
  * Globally unique tunnel identification (owner + number)
  * DO NOT USE OVER THE NETWORK
  */
@@ -363,12 +326,6 @@
      */
   unsigned int nignore;
 
-    /**
-     * Messages ready to transmit
-     */
-  struct MeshQueue *queue_head;
-  struct MeshQueue *queue_tail;
-
   /**
    * Tunnel paths
    */
@@ -2339,8 +2296,6 @@
 tunnel_destroy (struct MeshTunnel *t)
 {
   struct MeshClient *c;
-  struct MeshQueue *q;
-  struct MeshQueue *qn;
   GNUNET_HashCode hash;
   unsigned int i;
   int r;
@@ -2409,16 +2364,7 @@
                                            t);
     GNUNET_CONTAINER_multihashmap_destroy (t->peers);
   }
-  q = t->queue_head;
-  while (NULL != q)
-  {
-    if (NULL != q->data)
-      GNUNET_free (q->data);
-    qn = q->next;
-    GNUNET_free (q);
-    q = qn;
-    /* TODO cancel core transmit ready in case it was active */
-  }
+
   tree_destroy (t->tree);
   if (NULL != t->dht_get_type)
     GNUNET_DHT_get_stop (t->dht_get_type);




reply via email to

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