diff options
author | Bart Polot <bart@net.in.tum.de> | 2014-04-10 00:01:16 +0000 |
---|---|---|
committer | Bart Polot <bart@net.in.tum.de> | 2014-04-10 00:01:16 +0000 |
commit | 8bef6edb030e650160ec418f7a2ff4507865d77b (patch) | |
tree | a8d0d88b2a6915eee616a8a0b297228f424c27db /src/mesh | |
parent | 3702741f0ca89fcff4494c89132cd37da2f9c379 (diff) | |
download | gnunet-8bef6edb030e650160ec418f7a2ff4507865d77b.tar.gz gnunet-8bef6edb030e650160ec418f7a2ff4507865d77b.zip |
- log
Diffstat (limited to 'src/mesh')
-rw-r--r-- | src/mesh/gnunet-service-mesh_tunnel.c | 15 |
1 files changed, 13 insertions, 2 deletions
diff --git a/src/mesh/gnunet-service-mesh_tunnel.c b/src/mesh/gnunet-service-mesh_tunnel.c index fbbf75267..9e1975f76 100644 --- a/src/mesh/gnunet-service-mesh_tunnel.c +++ b/src/mesh/gnunet-service-mesh_tunnel.c | |||
@@ -1217,6 +1217,7 @@ destroy_iterator (void *cls, | |||
1217 | { | 1217 | { |
1218 | struct MeshTunnel3 *t = value; | 1218 | struct MeshTunnel3 *t = value; |
1219 | 1219 | ||
1220 | LOG (GNUNET_ERROR_TYPE_DEBUG, "GMT_shutdown destroying tunnel at %p\n", t); | ||
1220 | GMT_destroy (t); | 1221 | GMT_destroy (t); |
1221 | return GNUNET_YES; | 1222 | return GNUNET_YES; |
1222 | } | 1223 | } |
@@ -2105,6 +2106,14 @@ delayed_destroy (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
2105 | struct MeshTunnel3 *t = cls; | 2106 | struct MeshTunnel3 *t = cls; |
2106 | struct MeshTConnection *iter; | 2107 | struct MeshTConnection *iter; |
2107 | 2108 | ||
2109 | LOG (GNUNET_ERROR_TYPE_DEBUG, "delayed destroying tunnel %p\n", t); | ||
2110 | if (0 != (GNUNET_SCHEDULER_REASON_SHUTDOWN & tc->reason)) | ||
2111 | { | ||
2112 | LOG (GNUNET_ERROR_TYPE_WARNING, | ||
2113 | "Not destroying tunnel, due to shutdown. " | ||
2114 | "Tunnel at %p should have been freed by GMT_shutdown\n", t); | ||
2115 | return; | ||
2116 | } | ||
2108 | t->destroy_task = GNUNET_SCHEDULER_NO_TASK; | 2117 | t->destroy_task = GNUNET_SCHEDULER_NO_TASK; |
2109 | t->cstate = MESH_TUNNEL3_SHUTDOWN; | 2118 | t->cstate = MESH_TUNNEL3_SHUTDOWN; |
2110 | 2119 | ||
@@ -2144,6 +2153,8 @@ GMT_destroy_empty (struct MeshTunnel3 *t) | |||
2144 | 2153 | ||
2145 | t->destroy_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES, | 2154 | t->destroy_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES, |
2146 | &delayed_destroy, t); | 2155 | &delayed_destroy, t); |
2156 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Scheduled destroy of %p as %llX\n", | ||
2157 | t, t->destroy_task); | ||
2147 | } | 2158 | } |
2148 | 2159 | ||
2149 | 2160 | ||
@@ -2185,14 +2196,14 @@ GMT_destroy (struct MeshTunnel3 *t) | |||
2185 | if (NULL == t) | 2196 | if (NULL == t) |
2186 | return; | 2197 | return; |
2187 | 2198 | ||
2199 | LOG (GNUNET_ERROR_TYPE_DEBUG, "destroying tunnel %s\n", GMP_2s (t->peer)); | ||
2188 | if (GNUNET_SCHEDULER_NO_TASK != t->destroy_task) | 2200 | if (GNUNET_SCHEDULER_NO_TASK != t->destroy_task) |
2189 | { | 2201 | { |
2202 | LOG (GNUNET_ERROR_TYPE_DEBUG, "cancelling %llX\n", t->destroy_task); | ||
2190 | GNUNET_SCHEDULER_cancel (t->destroy_task); | 2203 | GNUNET_SCHEDULER_cancel (t->destroy_task); |
2191 | t->destroy_task = GNUNET_SCHEDULER_NO_TASK; | 2204 | t->destroy_task = GNUNET_SCHEDULER_NO_TASK; |
2192 | } | 2205 | } |
2193 | 2206 | ||
2194 | LOG (GNUNET_ERROR_TYPE_DEBUG, "destroying tunnel %s\n", GMP_2s (t->peer)); | ||
2195 | |||
2196 | GNUNET_break (GNUNET_YES == | 2207 | GNUNET_break (GNUNET_YES == |
2197 | GNUNET_CONTAINER_multipeermap_remove (tunnels, | 2208 | GNUNET_CONTAINER_multipeermap_remove (tunnels, |
2198 | GMP_get_id (t->peer), t)); | 2209 | GMP_get_id (t->peer), t)); |