diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-10-19 13:09:56 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-10-19 13:09:56 +0000 |
commit | ca31992cb873c9cad826841ebae014ef2d614cf5 (patch) | |
tree | 352763a80fb1406277fb2b4dfd04f679b9c98c7d /src/ats | |
parent | 035cdff6929e62ba01cfe741eede1f9d7db42e57 (diff) | |
download | gnunet-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.c | 2 | ||||
-rw-r--r-- | src/ats/gnunet-service-ats_reservations.c | 11 |
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 | ||