aboutsummaryrefslogtreecommitdiff
path: root/src/transport/gnunet-service-transport_neighbours.c
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2014-03-31 09:35:55 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2014-03-31 09:35:55 +0000
commitd729f00eb0d1f0a8a882b168245d4169680388fc (patch)
tree1d73db0fda95a99a44e2c3e5b7af126fd6e85542 /src/transport/gnunet-service-transport_neighbours.c
parent938b8285cc990eb78d7f1511853e7ce7fd4ea399 (diff)
downloadgnunet-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.c16
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,