aboutsummaryrefslogtreecommitdiff
path: root/src/ats
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-10-19 13:09:56 +0000
committerChristian Grothoff <christian@grothoff.org>2011-10-19 13:09:56 +0000
commitca31992cb873c9cad826841ebae014ef2d614cf5 (patch)
tree352763a80fb1406277fb2b4dfd04f679b9c98c7d /src/ats
parent035cdff6929e62ba01cfe741eede1f9d7db42e57 (diff)
downloadgnunet-ca31992cb873c9cad826841ebae014ef2d614cf5.tar.gz
gnunet-ca31992cb873c9cad826841ebae014ef2d614cf5.zip
major bugfixes in performance api implementation, some logging
Diffstat (limited to 'src/ats')
-rw-r--r--src/ats/gnunet-service-ats_performance.c2
-rw-r--r--src/ats/gnunet-service-ats_reservations.c11
2 files changed, 11 insertions, 2 deletions
diff --git a/src/ats/gnunet-service-ats_performance.c b/src/ats/gnunet-service-ats_performance.c
index 24450031f..19015a365 100644
--- a/src/ats/gnunet-service-ats_performance.c
+++ b/src/ats/gnunet-service-ats_performance.c
@@ -271,7 +271,7 @@ GAS_handle_preference_change (void *cls, struct GNUNET_SERVER_Client *client,
271 } 271 }
272 msg = (const struct ChangePreferenceMessage *) message; 272 msg = (const struct ChangePreferenceMessage *) message;
273 nump = ntohl (msg->num_preferences); 273 nump = ntohl (msg->num_preferences);
274 if (msize != sizeof (struct ChangePreferenceMessage) * nump * sizeof (struct PreferenceInformation)) 274 if (msize != sizeof (struct ChangePreferenceMessage) + nump * sizeof (struct PreferenceInformation))
275 { 275 {
276 GNUNET_break (0); 276 GNUNET_break (0);
277 GNUNET_SERVER_receive_done (client, GNUNET_SYSERR); 277 GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
diff --git a/src/ats/gnunet-service-ats_reservations.c b/src/ats/gnunet-service-ats_reservations.c
index 96ab1cdb2..bdc1e64c3 100644
--- a/src/ats/gnunet-service-ats_reservations.c
+++ b/src/ats/gnunet-service-ats_reservations.c
@@ -60,16 +60,25 @@ GAS_reservations_reserve (const struct GNUNET_PeerIdentity *peer,
60 tracker = GNUNET_CONTAINER_multihashmap_get (trackers, 60 tracker = GNUNET_CONTAINER_multihashmap_get (trackers,
61 &peer->hashPubKey); 61 &peer->hashPubKey);
62 if (NULL == tracker) 62 if (NULL == tracker)
63 return GNUNET_TIME_UNIT_FOREVER_REL; 63 return GNUNET_TIME_UNIT_ZERO; /* not connected, satisfy now */
64 if (amount >= 0) 64 if (amount >= 0)
65 { 65 {
66 ret = GNUNET_BANDWIDTH_tracker_get_delay (tracker, 66 ret = GNUNET_BANDWIDTH_tracker_get_delay (tracker,
67 amount); 67 amount);
68 if (ret.rel_value > 0) 68 if (ret.rel_value > 0)
69 {
70 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
71 "Delay to satisfy reservation for %d bytes is %llu ms\n",
72 (int) amount,
73 (unsigned long long) ret.rel_value);
69 return ret; 74 return ret;
75 }
70 } 76 }
71 GNUNET_break (GNUNET_NO == /* no == not above limit */ 77 GNUNET_break (GNUNET_NO == /* no == not above limit */
72 GNUNET_BANDWIDTH_tracker_consume (tracker, amount)); 78 GNUNET_BANDWIDTH_tracker_consume (tracker, amount));
79 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
80 "Reserved %d bytes\n",
81 (int) amount);
73 return GNUNET_TIME_UNIT_ZERO; 82 return GNUNET_TIME_UNIT_ZERO;
74} 83}
75 84