From: Bart Polot Date: Fri, 15 Nov 2013 09:53:00 +0000 (+0000) Subject: - reorder shutdown X-Git-Tag: initial-import-from-subversion-38251~6090 X-Git-Url: https://git.librecmc.org/?a=commitdiff_plain;h=a3ff141c22216e68627b13540cd0525b61c74ab5;p=oweals%2Fgnunet.git - reorder shutdown --- diff --git a/src/mesh/gnunet-service-mesh_peer.c b/src/mesh/gnunet-service-mesh_peer.c index 0d0480c32..3768da895 100644 --- a/src/mesh/gnunet-service-mesh_peer.c +++ b/src/mesh/gnunet-service-mesh_peer.c @@ -277,28 +277,29 @@ core_connect (void *cls, const struct GNUNET_PeerIdentity *peer) static void core_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) { - struct MeshPeer *pi; + struct MeshPeer *p; LOG (GNUNET_ERROR_TYPE_DEBUG, "Peer disconnected\n"); - pi = GNUNET_CONTAINER_multipeermap_get (peers, peer); - if (NULL == pi) + p = GNUNET_CONTAINER_multipeermap_get (peers, peer); + if (NULL == p) { GNUNET_break (0); return; } + if (myid == p->id) + LOG (GNUNET_ERROR_TYPE_DEBUG, " (self)\n"); + else + LOG (GNUNET_ERROR_TYPE_DEBUG, " %s\n", GMP_2s (p)); - GNUNET_CONTAINER_multihashmap_iterate (pi->connections, ¬ify_broken, pi); - GNUNET_CONTAINER_multihashmap_destroy (pi->connections); - pi->connections = NULL; - if (NULL != pi->core_transmit) + + GNUNET_CONTAINER_multihashmap_iterate (p->connections, ¬ify_broken, p); + GNUNET_CONTAINER_multihashmap_destroy (p->connections); + p->connections = NULL; + if (NULL != p->core_transmit) { - GNUNET_CORE_notify_transmit_ready_cancel (pi->core_transmit); - pi->core_transmit = NULL; + GNUNET_CORE_notify_transmit_ready_cancel (p->core_transmit); + p->core_transmit = NULL; } - if (myid == pi->id) - { - LOG (GNUNET_ERROR_TYPE_DEBUG, " (self)\n"); - } GNUNET_STATISTICS_update (stats, "# peers", -1, GNUNET_NO); return; @@ -1599,7 +1600,7 @@ GMP_remove_connection (struct MeshPeer *peer, if (NULL == peer || NULL == peer->connections) { GNUNET_break (0); - LOG (GNUNET_ERROR_TYPE_DEBUG, + LOG (GNUNET_ERROR_TYPE_WARNING, "Peer %s is not a neighbor!\n", GMP_2s (peer)); return GNUNET_SYSERR;