diff options
Diffstat (limited to 'src')
-rw-r--r-- | src/transport/gnunet-service-transport.c | 12 | ||||
-rw-r--r-- | src/transport/gnunet-service-transport_neighbours.c | 9 | ||||
-rw-r--r-- | src/transport/transport_api_core.c | 10 |
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 | |||
1341 | GST_clients_broadcast (const struct GNUNET_MessageHeader *msg, | 1341 | GST_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 | } |