aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/transport/gnunet-service-transport.c12
-rw-r--r--src/transport/gnunet-service-transport_neighbours.c9
-rw-r--r--src/transport/transport_api_core.c10
3 files changed, 17 insertions, 14 deletions
diff --git a/src/transport/gnunet-service-transport.c b/src/transport/gnunet-service-transport.c
index d3d2a86a3..c621ea686 100644
--- a/src/transport/gnunet-service-transport.c
+++ b/src/transport/gnunet-service-transport.c
@@ -1341,7 +1341,6 @@ void
1341GST_clients_broadcast (const struct GNUNET_MessageHeader *msg, 1341GST_clients_broadcast (const struct GNUNET_MessageHeader *msg,
1342 int may_drop) 1342 int may_drop)
1343{ 1343{
1344 struct TransportClient *tc;
1345 int done; 1344 int done;
1346 1345
1347 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 1346 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
@@ -1349,7 +1348,9 @@ GST_clients_broadcast (const struct GNUNET_MessageHeader *msg,
1349 (unsigned int) ntohs (msg->type), 1348 (unsigned int) ntohs (msg->type),
1350 (unsigned int) ntohs (msg->size)); 1349 (unsigned int) ntohs (msg->size));
1351 done = GNUNET_NO; 1350 done = GNUNET_NO;
1352 for (tc = clients_head; NULL != tc; tc = tc->next) 1351 for (struct TransportClient *tc = clients_head;
1352 NULL != tc;
1353 tc = tc->next)
1353 { 1354 {
1354 if ( (GNUNET_YES == may_drop) && 1355 if ( (GNUNET_YES == may_drop) &&
1355 (CT_CORE != tc->type) ) 1356 (CT_CORE != tc->type) )
@@ -1382,13 +1383,14 @@ GST_clients_broadcast_peer_notification (const struct GNUNET_PeerIdentity *peer,
1382{ 1383{
1383 struct GNUNET_MQ_Envelope *env; 1384 struct GNUNET_MQ_Envelope *env;
1384 struct PeerIterateResponseMessage *msg; 1385 struct PeerIterateResponseMessage *msg;
1385 struct TransportClient *tc; 1386
1386
1387 msg = compose_address_iterate_response_message (peer, 1387 msg = compose_address_iterate_response_message (peer,
1388 address); 1388 address);
1389 msg->state = htonl (state); 1389 msg->state = htonl (state);
1390 msg->state_timeout = GNUNET_TIME_absolute_hton (state_timeout); 1390 msg->state_timeout = GNUNET_TIME_absolute_hton (state_timeout);
1391 for (tc = clients_head; NULL != tc; tc = tc->next) 1391 for (struct TransportClient *tc = clients_head;
1392 NULL != tc;
1393 tc = tc->next)
1392 { 1394 {
1393 if (CT_MONITOR != tc->type) 1395 if (CT_MONITOR != tc->type)
1394 continue; 1396 continue;
diff --git a/src/transport/gnunet-service-transport_neighbours.c b/src/transport/gnunet-service-transport_neighbours.c
index 72c425591..3472e8ee0 100644
--- a/src/transport/gnunet-service-transport_neighbours.c
+++ b/src/transport/gnunet-service-transport_neighbours.c
@@ -713,7 +713,7 @@ set_state_and_timeout (struct NeighbourMapEntry *n,
713 struct GNUNET_TIME_Absolute timeout) 713 struct GNUNET_TIME_Absolute timeout)
714{ 714{
715 if (GNUNET_TRANSPORT_is_connected (s) && 715 if (GNUNET_TRANSPORT_is_connected (s) &&
716 ! GNUNET_TRANSPORT_is_connected (n->state) ) 716 (! GNUNET_TRANSPORT_is_connected (n->state)) )
717 { 717 {
718 neighbours_connect_notification (n); 718 neighbours_connect_notification (n);
719 GNUNET_STATISTICS_set (GST_stats, 719 GNUNET_STATISTICS_set (GST_stats,
@@ -721,8 +721,8 @@ set_state_and_timeout (struct NeighbourMapEntry *n,
721 ++neighbours_connected, 721 ++neighbours_connected,
722 GNUNET_NO); 722 GNUNET_NO);
723 } 723 }
724 if (! GNUNET_TRANSPORT_is_connected (s) && 724 if ((! GNUNET_TRANSPORT_is_connected (s)) &&
725 GNUNET_TRANSPORT_is_connected (n->state) ) 725 GNUNET_TRANSPORT_is_connected (n->state) )
726 { 726 {
727 GNUNET_STATISTICS_set (GST_stats, 727 GNUNET_STATISTICS_set (GST_stats,
728 gettext_noop ("# peers connected"), 728 gettext_noop ("# peers connected"),
@@ -948,7 +948,8 @@ free_neighbour (struct NeighbourMapEntry *n)
948 } 948 }
949 GNUNET_assert (GNUNET_YES == 949 GNUNET_assert (GNUNET_YES ==
950 GNUNET_CONTAINER_multipeermap_remove (neighbours, 950 GNUNET_CONTAINER_multipeermap_remove (neighbours,
951 &n->id, n)); 951 &n->id,
952 n));
952 953
953 /* Cancel address requests for this peer */ 954 /* Cancel address requests for this peer */
954 if (NULL != n->suggest_handle) 955 if (NULL != n->suggest_handle)
diff --git a/src/transport/transport_api_core.c b/src/transport/transport_api_core.c
index 75287b5e7..aa6da0098 100644
--- a/src/transport/transport_api_core.c
+++ b/src/transport/transport_api_core.c
@@ -747,18 +747,18 @@ handle_set_quota (void *cls,
747 struct GNUNET_TRANSPORT_CoreHandle *h = cls; 747 struct GNUNET_TRANSPORT_CoreHandle *h = cls;
748 struct Neighbour *n; 748 struct Neighbour *n;
749 749
750 LOG (GNUNET_ERROR_TYPE_DEBUG,
751 "Receiving SET_QUOTA message for `%s' with quota %u\n",
752 GNUNET_i2s (&qm->peer),
753 ntohl (qm->quota.value__));
750 n = neighbour_find (h, 754 n = neighbour_find (h,
751 &qm->peer); 755 &qm->peer);
752 if (NULL == n) 756 if (NULL == n)
753 { 757 {
754 GNUNET_break (0); 758 GNUNET_break (0); /* FIXME: julius reports this assertion fails sometimes? */
755 disconnect_and_schedule_reconnect (h); 759 disconnect_and_schedule_reconnect (h);
756 return; 760 return;
757 } 761 }
758 LOG (GNUNET_ERROR_TYPE_DEBUG,
759 "Receiving SET_QUOTA message for `%s' with quota %u\n",
760 GNUNET_i2s (&qm->peer),
761 ntohl (qm->quota.value__));
762 GNUNET_BANDWIDTH_tracker_update_quota (&n->out_tracker, 762 GNUNET_BANDWIDTH_tracker_update_quota (&n->out_tracker,
763 qm->quota); 763 qm->quota);
764} 764}