aboutsummaryrefslogtreecommitdiff
path: root/src/cadet
diff options
context:
space:
mode:
authorBart Polot <bart@net.in.tum.de>2014-07-29 14:53:45 +0000
committerBart Polot <bart@net.in.tum.de>2014-07-29 14:53:45 +0000
commit382bf16eb6e6dbaad808d1330ec40b89922c9c8f (patch)
treed8d5c0b9584d4bb40240096c6a919a0cd75c35c3 /src/cadet
parent5051244c80bd93e1599c5c39aeeefebaeef40d61 (diff)
downloadgnunet-382bf16eb6e6dbaad808d1330ec40b89922c9c8f.tar.gz
gnunet-382bf16eb6e6dbaad808d1330ec40b89922c9c8f.zip
- mark connections as to be destroyed by the _sent continuation
Diffstat (limited to 'src/cadet')
-rw-r--r--src/cadet/gnunet-service-cadet_connection.c4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/cadet/gnunet-service-cadet_connection.c b/src/cadet/gnunet-service-cadet_connection.c
index 64a82371a..06a227db7 100644
--- a/src/cadet/gnunet-service-cadet_connection.c
+++ b/src/cadet/gnunet-service-cadet_connection.c
@@ -1290,6 +1290,7 @@ connection_fwd_timeout (void *cls,
1290 int destroyed; 1290 int destroyed;
1291 1291
1292 t = c->t; 1292 t = c->t;
1293 c->destroy = GNUNET_YES;
1293 destroyed = GNUNET_NO; 1294 destroyed = GNUNET_NO;
1294 neighbor = get_hop (c, GNUNET_NO); 1295 neighbor = get_hop (c, GNUNET_NO);
1295 1296
@@ -1350,6 +1351,7 @@ connection_bck_timeout (void *cls,
1350 int destroyed; 1351 int destroyed;
1351 1352
1352 t = c->t; 1353 t = c->t;
1354 c->destroy = GNUNET_YES;
1353 destroyed = GNUNET_NO; 1355 destroyed = GNUNET_NO;
1354 neighbor = get_hop (c, GNUNET_YES); 1356 neighbor = get_hop (c, GNUNET_YES);
1355 1357
@@ -1885,6 +1887,7 @@ GCC_handle_broken (void* cls,
1885 1887
1886 t = c->t; 1888 t = c->t;
1887 fwd = is_fwd (c, id); 1889 fwd = is_fwd (c, id);
1890 c->destroy = GNUNET_YES;
1888 if (GCC_is_terminal (c, fwd)) 1891 if (GCC_is_terminal (c, fwd))
1889 { 1892 {
1890 struct GNUNET_MessageHeader *out_msg; 1893 struct GNUNET_MessageHeader *out_msg;
@@ -1926,7 +1929,6 @@ GCC_handle_broken (void* cls,
1926 { 1929 {
1927 GNUNET_assert (NULL == GCC_send_prebuilt_message (message, 0, 0, c, fwd, 1930 GNUNET_assert (NULL == GCC_send_prebuilt_message (message, 0, 0, c, fwd,
1928 GNUNET_YES, NULL, NULL)); 1931 GNUNET_YES, NULL, NULL));
1929 c->destroy = GNUNET_YES;
1930 connection_cancel_queues (c, !fwd); 1932 connection_cancel_queues (c, !fwd);
1931 } 1933 }
1932 1934