diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2013-03-26 12:37:56 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2013-03-26 12:37:56 +0000 |
commit | 6d265f06780b414d0347a6274213bb7032232cc6 (patch) | |
tree | 4122e671285fb2599dde2c8d1fe00c0737130291 /src/ats | |
parent | 4fec0b51eb45106fe3a24d1e59df915cdf027e86 (diff) | |
download | gnunet-6d265f06780b414d0347a6274213bb7032232cc6.tar.gz gnunet-6d265f06780b414d0347a6274213bb7032232cc6.zip |
test
Diffstat (limited to 'src/ats')
-rw-r--r-- | src/ats/Makefile.am | 10 | ||||
-rw-r--r-- | src/ats/gnunet-service-ats_addresses.c | 17 | ||||
-rw-r--r-- | src/ats/test_ats_api_performance_monitor.c | 24 |
3 files changed, 24 insertions, 27 deletions
diff --git a/src/ats/Makefile.am b/src/ats/Makefile.am index d8c74d7ee..109a752dc 100644 --- a/src/ats/Makefile.am +++ b/src/ats/Makefile.am | |||
@@ -76,6 +76,7 @@ check_PROGRAMS = \ | |||
76 | test_ats_simplistic_pref_aging \ | 76 | test_ats_simplistic_pref_aging \ |
77 | test_ats_api_performance_list_addresses \ | 77 | test_ats_api_performance_list_addresses \ |
78 | test_ats_api_performance_monitor \ | 78 | test_ats_api_performance_monitor \ |
79 | test_ats_api_performance_address_info \ | ||
79 | $(GN_MLP_TEST) $(GN_MLP_PERF) $(GN_MLP_TEST_UPDATE) | 80 | $(GN_MLP_TEST) $(GN_MLP_PERF) $(GN_MLP_TEST_UPDATE) |
80 | # $(GN_MLP_TEST_AVG) | 81 | # $(GN_MLP_TEST_AVG) |
81 | # test_ats_api_scheduling_get_type | 82 | # test_ats_api_scheduling_get_type |
@@ -175,6 +176,15 @@ test_ats_api_performance_monitor_LDADD = \ | |||
175 | $(top_builddir)/src/ats/libgnunetats.la | 176 | $(top_builddir)/src/ats/libgnunetats.la |
176 | 177 | ||
177 | 178 | ||
179 | test_ats_api_performance_address_info_SOURCES = \ | ||
180 | test_ats_api_performance_address_info.c | ||
181 | test_ats_api_performance_address_info_LDADD = \ | ||
182 | $(top_builddir)/src/util/libgnunetutil.la \ | ||
183 | $(top_builddir)/src/testing/libgnunettesting.la \ | ||
184 | $(top_builddir)/src/hello/libgnunethello.la \ | ||
185 | $(top_builddir)/src/ats/libgnunetats.la | ||
186 | |||
187 | |||
178 | test_ats_simplistic_SOURCES = \ | 188 | test_ats_simplistic_SOURCES = \ |
179 | test_ats_simplistic.c test_ats_api_common.c | 189 | test_ats_simplistic.c test_ats_api_common.c |
180 | test_ats_simplistic_LDADD = \ | 190 | test_ats_simplistic_LDADD = \ |
diff --git a/src/ats/gnunet-service-ats_addresses.c b/src/ats/gnunet-service-ats_addresses.c index 3dcb6aad2..1af07a53e 100644 --- a/src/ats/gnunet-service-ats_addresses.c +++ b/src/ats/gnunet-service-ats_addresses.c | |||
@@ -1264,13 +1264,23 @@ bandwidth_changed_cb (void *cls, struct ATS_Address *address) | |||
1264 | { | 1264 | { |
1265 | struct GAS_Addresses_Handle *handle = cls; | 1265 | struct GAS_Addresses_Handle *handle = cls; |
1266 | struct GAS_Addresses_Suggestion_Requests *cur; | 1266 | struct GAS_Addresses_Suggestion_Requests *cur; |
1267 | struct GNUNET_ATS_Information *ats; | ||
1268 | unsigned int ats_count; | ||
1267 | 1269 | ||
1268 | GNUNET_assert (handle != NULL); | 1270 | GNUNET_assert (handle != NULL); |
1269 | GNUNET_assert (address != NULL); | 1271 | GNUNET_assert (address != NULL); |
1270 | 1272 | ||
1271 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Bandwidth assignment changed for peer %s \n", GNUNET_i2s(&address->peer)); | 1273 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Bandwidth assignment changed for peer %s \n", GNUNET_i2s(&address->peer)); |
1272 | struct GNUNET_ATS_Information *ats; | 1274 | |
1273 | unsigned int ats_count; | 1275 | |
1276 | ats_count = assemble_ats_information (address, &ats); | ||
1277 | GAS_performance_notify_all_clients (&address->peer, | ||
1278 | address->plugin, | ||
1279 | address->addr, address->addr_len, | ||
1280 | address->session_id, | ||
1281 | ats, ats_count, | ||
1282 | address->assigned_bw_out, | ||
1283 | address->assigned_bw_in); | ||
1274 | 1284 | ||
1275 | cur = handle->r_head; | 1285 | cur = handle->r_head; |
1276 | while (NULL != cur) | 1286 | while (NULL != cur) |
@@ -1283,13 +1293,14 @@ bandwidth_changed_cb (void *cls, struct ATS_Address *address) | |||
1283 | { | 1293 | { |
1284 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1294 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1285 | "Nobody is interested in peer `%s' :(\n",GNUNET_i2s (&address->peer)); | 1295 | "Nobody is interested in peer `%s' :(\n",GNUNET_i2s (&address->peer)); |
1296 | GNUNET_free (ats); | ||
1286 | return; | 1297 | return; |
1287 | } | 1298 | } |
1288 | 1299 | ||
1289 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1300 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1290 | "Sending bandwidth update for peer `%s'\n",GNUNET_i2s (&address->peer)); | 1301 | "Sending bandwidth update for peer `%s'\n",GNUNET_i2s (&address->peer)); |
1291 | 1302 | ||
1292 | ats_count = assemble_ats_information (address, &ats); | 1303 | |
1293 | GAS_scheduling_transmit_address_suggestion (&address->peer, | 1304 | GAS_scheduling_transmit_address_suggestion (&address->peer, |
1294 | address->plugin, | 1305 | address->plugin, |
1295 | address->addr, address->addr_len, | 1306 | address->addr, address->addr_len, |
diff --git a/src/ats/test_ats_api_performance_monitor.c b/src/ats/test_ats_api_performance_monitor.c index 95c65c68f..5ba6cd6bd 100644 --- a/src/ats/test_ats_api_performance_monitor.c +++ b/src/ats/test_ats_api_performance_monitor.c | |||
@@ -142,30 +142,6 @@ end_badly (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
142 | end_now (1); | 142 | end_now (1); |
143 | } | 143 | } |
144 | 144 | ||
145 | static void | ||
146 | next_stage (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | ||
147 | { | ||
148 | static int stage_counter = 0; | ||
149 | |||
150 | stage_task = GNUNET_SCHEDULER_NO_TASK; | ||
151 | if (0 == stage_counter) | ||
152 | { | ||
153 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stop performance monitoring\n"); | ||
154 | |||
155 | stage_task = GNUNET_SCHEDULER_add_delayed (SHUTDOWN_CORRECT, &next_stage, NULL); | ||
156 | stage_counter++; | ||
157 | return; | ||
158 | } | ||
159 | if (1 == stage_counter) | ||
160 | { | ||
161 | |||
162 | } | ||
163 | else | ||
164 | { | ||
165 | end_now (1); | ||
166 | } | ||
167 | } | ||
168 | |||
169 | static void end (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | 145 | static void end (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) |
170 | { | 146 | { |
171 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Success\n"); | 147 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Success\n"); |