gnunet-svn
[Top][All Lists]
Advanced

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

[GNUnet-SVN] r32453 - msh/src


From: gnunet
Subject: [GNUnet-SVN] r32453 - msh/src
Date: Fri, 21 Feb 2014 18:05:08 +0100

Author: harsha
Date: 2014-02-21 18:05:07 +0100 (Fri, 21 Feb 2014)
New Revision: 32453

Modified:
   msh/src/mshd.c
Log:
Clearup and pending connections before reduction phase.


Modified: msh/src/mshd.c
===================================================================
--- msh/src/mshd.c      2014-02-21 15:13:46 UTC (rev 32452)
+++ msh/src/mshd.c      2014-02-21 17:05:07 UTC (rev 32453)
@@ -841,6 +841,7 @@
 schedule_next_round ()
 {
   struct ChildProc *chld;
+  struct ReadContext *rc;
   struct GNUNET_DISK_PipeHandle *pipe;
   struct GNUNET_DISK_FileHandle *read_end;
   struct GNUNET_DISK_FileHandle *write_end;
@@ -857,6 +858,13 @@
     rtask = GNUNET_SCHEDULER_add_now (&run_round, NULL);
     return;
   }
+  while (NULL != (rc = rhead))
+  {
+    GNUNET_CONTAINER_DLL_remove (rhead, rtail, rc);
+    GNUNET_CONNECTION_receive_cancel (rc->conn);
+    GNUNET_CONNECTION_destroy (rc->conn);
+    GNUNET_free (rc);
+  }
   if (MPI_SUCCESS != MPI_Barrier (MPI_COMM_WORLD))
   {
     GNUNET_break (0);
@@ -864,7 +872,6 @@
   }
   LOG_DEBUG ("Verification phase complete; commencing reduction phase\n");
   GNUNET_break (GNUNET_OK == reduce_ntree ());
-  addressmap_print (addrmap);
   pid = (intmax_t) getpid ();
   GNUNET_assert (0 < asprintf (&unixpath, "/%ju.sock", pid));
   hostsfile = GNUNET_DISK_mktemp ("MSHD_HOSTS");




reply via email to

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