diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2014-03-31 09:35:55 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2014-03-31 09:35:55 +0000 |
commit | d729f00eb0d1f0a8a882b168245d4169680388fc (patch) | |
tree | 1d73db0fda95a99a44e2c3e5b7af126fd6e85542 /src/transport/gnunet-service-transport_neighbours.c | |
parent | 938b8285cc990eb78d7f1511853e7ce7fd4ea399 (diff) | |
download | gnunet-d729f00eb0d1f0a8a882b168245d4169680388fc.tar.gz gnunet-d729f00eb0d1f0a8a882b168245d4169680388fc.zip |
fix duplicate connect notifications
Diffstat (limited to 'src/transport/gnunet-service-transport_neighbours.c')
-rw-r--r-- | src/transport/gnunet-service-transport_neighbours.c | 16 |
1 files changed, 10 insertions, 6 deletions
diff --git a/src/transport/gnunet-service-transport_neighbours.c b/src/transport/gnunet-service-transport_neighbours.c index 081105a3b..6a413874a 100644 --- a/src/transport/gnunet-service-transport_neighbours.c +++ b/src/transport/gnunet-service-transport_neighbours.c | |||
@@ -3426,17 +3426,21 @@ GST_neighbours_handle_session_ack (const struct GNUNET_MessageHeader *message, | |||
3426 | } | 3426 | } |
3427 | 3427 | ||
3428 | /* We are connected */ | 3428 | /* We are connected */ |
3429 | set_state_and_timeout (n, GNUNET_TRANSPORT_PS_CONNECTED, GNUNET_TIME_relative_to_absolute (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT)); | 3429 | if (GNUNET_NO == GST_neighbours_test_connected(&n->id)) |
3430 | { | ||
3431 | /* Notify about connection */ | ||
3432 | connect_notify_cb (callback_cls, &n->id, | ||
3433 | n->primary_address.bandwidth_in, | ||
3434 | n->primary_address.bandwidth_out); | ||
3435 | } | ||
3436 | |||
3437 | set_state_and_timeout (n, GNUNET_TRANSPORT_PS_CONNECTED, | ||
3438 | GNUNET_TIME_relative_to_absolute (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT)); | ||
3430 | GNUNET_STATISTICS_set (GST_stats, | 3439 | GNUNET_STATISTICS_set (GST_stats, |
3431 | gettext_noop ("# peers connected"), | 3440 | gettext_noop ("# peers connected"), |
3432 | ++neighbours_connected, | 3441 | ++neighbours_connected, |
3433 | GNUNET_NO); | 3442 | GNUNET_NO); |
3434 | 3443 | ||
3435 | /* Notify about connection */ | ||
3436 | connect_notify_cb (callback_cls, &n->id, | ||
3437 | n->primary_address.bandwidth_in, | ||
3438 | n->primary_address.bandwidth_out); | ||
3439 | |||
3440 | /* Add session to ATS since no session was given (NULL) and we may have | 3444 | /* Add session to ATS since no session was given (NULL) and we may have |
3441 | * obtained a new session */ | 3445 | * obtained a new session */ |
3442 | GST_ats_add_address (n->primary_address.address, n->primary_address.session, | 3446 | GST_ats_add_address (n->primary_address.address, n->primary_address.session, |