[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");
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r32453 - msh/src,
gnunet <=