aboutsummaryrefslogtreecommitdiff
path: root/src/ats/test_ats_api_scheduling_init.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/ats/test_ats_api_scheduling_init.c')
-rw-r--r--src/ats/test_ats_api_scheduling_init.c176
1 files changed, 0 insertions, 176 deletions
diff --git a/src/ats/test_ats_api_scheduling_init.c b/src/ats/test_ats_api_scheduling_init.c
deleted file mode 100644
index 29446d913..000000000
--- a/src/ats/test_ats_api_scheduling_init.c
+++ /dev/null
@@ -1,176 +0,0 @@
1/*
2 This file is part of GNUnet.
3 Copyright (C) 2010,2011 Christian Grothoff (and other contributing authors)
4
5 GNUnet is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published
7 by the Free Software Foundation; either version 3, or (at your
8 option) any later version.
9
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 General Public License for more details.
14
15 You should have received a copy of the GNU General Public License
16 along with GNUnet; see the file COPYING. If not, write to the
17 Free Software Foundation, Inc., 59 Temple Place - Suite 330,
18 Boston, MA 02111-1307, USA.
19*/
20/**
21 * @file ats/test_ats_api_scheduling_init.c
22 * @brief test automatic transport selection scheduling API init/shutdown
23 * @author Christian Grothoff
24 * @author Matthias Wachs
25 *
26 */
27#include "platform.h"
28#include "gnunet_ats_service.h"
29#include "gnunet_testing_lib.h"
30#include "ats.h"
31#include "test_ats_api_common.h"
32/**
33 * Timeout task
34 */
35static struct GNUNET_SCHEDULER_Task * die_task;
36
37/**
38 * Initial statistics get request handle
39 */
40struct GNUNET_STATISTICS_GetHandle *initial_get;
41
42/**
43 * Statistics handle
44 */
45struct GNUNET_STATISTICS_Handle *stats;
46
47/**
48 * Scheduling handle
49 */
50static struct GNUNET_ATS_SchedulingHandle *sched_ats;
51
52/**
53 * Return value
54 */
55static int ret;
56
57
58static void end (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc);
59
60static int
61stat_cb(void *cls, const char *subsystem,
62 const char *name, uint64_t value,
63 int is_persistent)
64{
65
66 GNUNET_log (GNUNET_ERROR_TYPE_INFO, "ATS statistics: `%s' `%s' %llu\n",
67 subsystem,name, value);
68 if (0 == value)
69 {
70 GNUNET_SCHEDULER_add_now (&end, NULL);
71 }
72 return GNUNET_OK;
73}
74
75static int
76dummy_stat (void *cls, const char *subsystem, const char *name, uint64_t value,
77 int is_persistent)
78{
79 GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Got dummy stat %s%s:%s = %llu\n",
80 is_persistent ? "!" : " ", subsystem, name, value);
81 return GNUNET_OK;
82}
83
84static void
85end (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
86{
87 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Shutting down\n");
88
89 if (die_task != NULL)
90 {
91 GNUNET_SCHEDULER_cancel (die_task);
92 die_task = NULL;
93 }
94
95 if (NULL != sched_ats)
96 {
97 GNUNET_ATS_scheduling_done (sched_ats);
98 sched_ats = NULL;
99 }
100
101 GNUNET_STATISTICS_watch_cancel (stats, "ats", "# addresses", &stat_cb, NULL);
102 if (NULL != stats)
103 {
104 GNUNET_STATISTICS_destroy (stats, GNUNET_NO);
105 stats = NULL;
106 }
107 ret = 0;
108}
109
110static void
111end_badly (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
112{
113 die_task = NULL;
114 end ( NULL, NULL);
115 ret = GNUNET_SYSERR;
116}
117
118
119static void
120address_suggest_cb (void *cls,
121 const struct GNUNET_PeerIdentity *peer,
122 const struct GNUNET_HELLO_Address *address,
123 struct Session *session,
124 struct GNUNET_BANDWIDTH_Value32NBO bandwidth_out,
125 struct GNUNET_BANDWIDTH_Value32NBO bandwidth_in)
126{
127 GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Did not expect suggestion callback!\n");
128 GNUNET_SCHEDULER_add_now (&end_badly, NULL);
129}
130
131
132static void
133got_initial_value (void *cls, int success)
134{
135 struct GNUNET_CONFIGURATION_Handle *cfg = cls;
136
137 GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Got initial value\n");
138
139 /* Connect to ATS scheduling */
140 sched_ats = GNUNET_ATS_scheduling_init (cfg, &address_suggest_cb, NULL);
141 GNUNET_CONFIGURATION_destroy (cfg);
142 if (sched_ats == NULL)
143 {
144 GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Could not connect to ATS scheduling!\n");
145 GNUNET_SCHEDULER_add_now (&end_badly, NULL);
146 return;
147 }
148}
149
150static void
151run (void *cls,
152 const struct GNUNET_CONFIGURATION_Handle *cfg,
153 struct GNUNET_TESTING_Peer *peer)
154{
155 die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_badly, NULL);
156 stats = GNUNET_STATISTICS_create ("ats", cfg);
157 GNUNET_STATISTICS_watch (stats, "ats", "# addresses", &stat_cb, NULL);
158
159 initial_get = GNUNET_STATISTICS_get (stats, "ats", "# addresses", TIMEOUT,
160 &got_initial_value, &dummy_stat,
161 GNUNET_CONFIGURATION_dup (cfg));
162}
163
164
165int
166main (int argc, char *argv[])
167{
168 ret = 0;
169 if (0 != GNUNET_TESTING_peer_run ("test-ats-api",
170 "test_ats_api.conf",
171 &run, NULL))
172 return 1;
173 return ret;
174}
175
176/* end of file test_ats_api_scheduling_init.c */