gnunet-svn
[Top][All Lists]
Advanced

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

[GNUnet-SVN] r17429 - gnunet/src/transport


From: gnunet
Subject: [GNUnet-SVN] r17429 - gnunet/src/transport
Date: Wed, 12 Oct 2011 18:01:18 +0200

Author: wachs
Date: 2011-10-12 18:01:18 +0200 (Wed, 12 Oct 2011)
New Revision: 17429

Modified:
   gnunet/src/transport/plugin_transport_udp.c
Log:


Modified: gnunet/src/transport/plugin_transport_udp.c
===================================================================
--- gnunet/src/transport/plugin_transport_udp.c 2011-10-12 15:53:48 UTC (rev 
17428)
+++ gnunet/src/transport/plugin_transport_udp.c 2011-10-12 16:01:18 UTC (rev 
17429)
@@ -803,9 +803,9 @@
   LOG (GNUNET_ERROR_TYPE_ERROR,
                    "Session %X (`%s') is now invalid\n", s, GNUNET_a2s 
(s->sock_addr,s->addrlen));
 
-//  s->plugin->env->session_end(s->plugin->env->cls, &s->target, s);
-//  GNUNET_assert (GNUNET_YES == 
GNUNET_CONTAINER_multihashmap_remove(s->plugin->inbound_sessions, 
&s->target.hashPubKey, s));
-//  GNUNET_free (s);
+  s->plugin->env->session_end(s->plugin->env->cls, &s->target, s);
+  GNUNET_assert (GNUNET_YES == 
GNUNET_CONTAINER_multihashmap_remove(s->plugin->inbound_sessions, 
&s->target.hashPubKey, s));
+  GNUNET_free (s);
 }
 
 
@@ -901,18 +901,16 @@
                                                       s,
                                                      
GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE));
   }
-  //s->valid_until = GNUNET_TIME_absolute_add(GNUNET_TIME_absolute_get(), 
GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT);
-  struct GNUNET_TIME_Relative delay = 
GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 10);
-  s->valid_until = GNUNET_TIME_absolute_add(GNUNET_TIME_absolute_get(), delay);
+  s->valid_until = GNUNET_TIME_absolute_add(GNUNET_TIME_absolute_get(), 
GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT);
   if (s->invalidation_task != GNUNET_SCHEDULER_NO_TASK)
   {
     GNUNET_SCHEDULER_cancel(s->invalidation_task);
     s->invalidation_task = GNUNET_SCHEDULER_NO_TASK;
-    LOG (GNUNET_ERROR_TYPE_ERROR,
+    LOG (GNUNET_ERROR_TYPE_DEBUG,
                 "Rescheduling %X' `%s'\n",
                 s, udp_address_to_string(NULL, arg, args));
   }
-  s->invalidation_task = GNUNET_SCHEDULER_add_delayed(delay, 
&invalidation_task, s);
+  s->invalidation_task = 
GNUNET_SCHEDULER_add_delayed(GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT, 
&invalidation_task, s);
   /* iterate over all embedded messages */
   si.sender = msg->sender;
   si.arg = arg;




reply via email to

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