diff options
author | Bart Polot <bart@net.in.tum.de> | 2014-07-29 14:53:45 +0000 |
---|---|---|
committer | Bart Polot <bart@net.in.tum.de> | 2014-07-29 14:53:45 +0000 |
commit | 382bf16eb6e6dbaad808d1330ec40b89922c9c8f (patch) | |
tree | d8d5c0b9584d4bb40240096c6a919a0cd75c35c3 /src/cadet | |
parent | 5051244c80bd93e1599c5c39aeeefebaeef40d61 (diff) | |
download | gnunet-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.c | 4 |
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 | ||