aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/testbed/testbed_api.c2
-rw-r--r--src/transport/gnunet-service-transport_neighbours.c12
-rw-r--r--src/transport/transport_api.c2
3 files changed, 10 insertions, 6 deletions
diff --git a/src/testbed/testbed_api.c b/src/testbed/testbed_api.c
index 55c36c18c..596b2b592 100644
--- a/src/testbed/testbed_api.c
+++ b/src/testbed/testbed_api.c
@@ -484,7 +484,7 @@ handle_opsuccess (struct GNUNET_TESTBED_Controller *c,
484 484
485 485
486/** 486/**
487 * Handler for #GNUNET_MESSAGE_TYPE_TESTBED_PEER_CREATE_SUCCESS message from 487 * Handler for #GNUNET_MESSAGE_TYPE_TESTBED_CREATE_PEER_SUCCESS message from
488 * controller (testbed service) 488 * controller (testbed service)
489 * 489 *
490 * @param c the controller handle 490 * @param c the controller handle
diff --git a/src/transport/gnunet-service-transport_neighbours.c b/src/transport/gnunet-service-transport_neighbours.c
index 9f4982b67..0e53f9b6f 100644
--- a/src/transport/gnunet-service-transport_neighbours.c
+++ b/src/transport/gnunet-service-transport_neighbours.c
@@ -3673,6 +3673,7 @@ GST_neighbours_handle_quota_message (const struct GNUNET_PeerIdentity *peer,
3673{ 3673{
3674 struct NeighbourMapEntry *n; 3674 struct NeighbourMapEntry *n;
3675 const struct GNUNET_ATS_SessionQuotaMessage *sqm; 3675 const struct GNUNET_ATS_SessionQuotaMessage *sqm;
3676 struct GNUNET_BANDWIDTH_Value32NBO last;
3676 3677
3677 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 3678 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
3678 "Received QUOTA message from peer `%s'\n", 3679 "Received QUOTA message from peer `%s'\n",
@@ -3696,10 +3697,13 @@ GST_neighbours_handle_quota_message (const struct GNUNET_PeerIdentity *peer,
3696 /* gone already */ 3697 /* gone already */
3697 return; 3698 return;
3698 } 3699 }
3699 n->neighbour_receive_quota 3700 last = GNUNET_BANDWIDTH_value_max (GNUNET_CONSTANTS_DEFAULT_BW_IN_OUT,
3700 = GNUNET_BANDWIDTH_value_max (GNUNET_CONSTANTS_DEFAULT_BW_IN_OUT, 3701 GNUNET_BANDWIDTH_value_init (ntohl (sqm->quota)));
3701 GNUNET_BANDWIDTH_value_init (ntohl (sqm->quota))); 3702 if (last.value__ != n->neighbour_receive_quota.value__)
3702 send_outbound_quota_to_clients (n); 3703 {
3704 n->neighbour_receive_quota = last;
3705 send_outbound_quota_to_clients (n);
3706 }
3703} 3707}
3704 3708
3705 3709
diff --git a/src/transport/transport_api.c b/src/transport/transport_api.c
index 95eeb8788..29416b03d 100644
--- a/src/transport/transport_api.c
+++ b/src/transport/transport_api.c
@@ -778,7 +778,7 @@ demultiplexer (void *cls,
778 disconnect_and_schedule_reconnect (h); 778 disconnect_and_schedule_reconnect (h);
779 break; 779 break;
780 } 780 }
781 if (bytes_physical >= bytes_msg) 781 if (bytes_physical > bytes_msg)
782 { 782 {
783 LOG (GNUNET_ERROR_TYPE_DEBUG, 783 LOG (GNUNET_ERROR_TYPE_DEBUG,
784 "Overhead for %u byte message was %u\n", 784 "Overhead for %u byte message was %u\n",