aboutsummaryrefslogtreecommitdiff
path: root/src/util/test_scheduler.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2019-10-05 15:09:28 +0200
committerChristian Grothoff <christian@grothoff.org>2019-10-05 15:09:28 +0200
commitc4e9ba925ffd758aaa3feee2ccfc0b76f26fe207 (patch)
treecac3ce030d77b4cbe7c7dc62ed58cfe6d24f73e1 /src/util/test_scheduler.c
parentfbb71d527c7d6babf269a8fefce1db291b9f7068 (diff)
downloadgnunet-c4e9ba925ffd758aaa3feee2ccfc0b76f26fe207.tar.gz
gnunet-c4e9ba925ffd758aaa3feee2ccfc0b76f26fe207.zip
global reindent, now with uncrustify hook enabled
Diffstat (limited to 'src/util/test_scheduler.c')
-rw-r--r--src/util/test_scheduler.c177
1 files changed, 89 insertions, 88 deletions
diff --git a/src/util/test_scheduler.c b/src/util/test_scheduler.c
index 8952225c2..2fe8f6f5c 100644
--- a/src/util/test_scheduler.c
+++ b/src/util/test_scheduler.c
@@ -33,135 +33,135 @@ static struct GNUNET_SCHEDULER_Task *never_run_task;
33 33
34 34
35static void 35static void
36task2(void *cls) 36task2 (void *cls)
37{ 37{
38 int *ok = cls; 38 int *ok = cls;
39 39
40 /* t3 should be ready (albeit with lower priority) */ 40 /* t3 should be ready (albeit with lower priority) */
41 GNUNET_assert(1 == 41 GNUNET_assert (1 ==
42 GNUNET_SCHEDULER_get_load(GNUNET_SCHEDULER_PRIORITY_COUNT)); 42 GNUNET_SCHEDULER_get_load (GNUNET_SCHEDULER_PRIORITY_COUNT));
43 GNUNET_assert(2 == *ok); 43 GNUNET_assert (2 == *ok);
44 (*ok) = 3; 44 (*ok) = 3;
45} 45}
46 46
47 47
48static void 48static void
49task3(void *cls) 49task3 (void *cls)
50{ 50{
51 int *ok = cls; 51 int *ok = cls;
52 52
53 GNUNET_assert(3 == *ok); 53 GNUNET_assert (3 == *ok);
54 (*ok) = 4; 54 (*ok) = 4;
55} 55}
56 56
57 57
58static void 58static void
59taskWrt(void *cls) 59taskWrt (void *cls)
60{ 60{
61 static char c; 61 static char c;
62 int *ok = cls; 62 int *ok = cls;
63 const struct GNUNET_SCHEDULER_TaskContext *tc; 63 const struct GNUNET_SCHEDULER_TaskContext *tc;
64 64
65 tc = GNUNET_SCHEDULER_get_task_context(); 65 tc = GNUNET_SCHEDULER_get_task_context ();
66 GNUNET_assert(6 == *ok); 66 GNUNET_assert (6 == *ok);
67 GNUNET_assert(GNUNET_NETWORK_fdset_handle_isset(tc->write_ready, fds[1])); 67 GNUNET_assert (GNUNET_NETWORK_fdset_handle_isset (tc->write_ready, fds[1]));
68 (*ok) = 7; 68 (*ok) = 7;
69 GNUNET_assert(1 == GNUNET_DISK_file_write(fds[1], &c, 1)); 69 GNUNET_assert (1 == GNUNET_DISK_file_write (fds[1], &c, 1));
70} 70}
71 71
72 72
73static void 73static void
74taskNeverRun(void *cls) 74taskNeverRun (void *cls)
75{ 75{
76 GNUNET_assert(0); 76 GNUNET_assert (0);
77} 77}
78 78
79 79
80static void 80static void
81taskLastRd(void *cls) 81taskLastRd (void *cls)
82{ 82{
83 int *ok = cls; 83 int *ok = cls;
84 84
85 GNUNET_assert(8 == *ok); 85 GNUNET_assert (8 == *ok);
86 (*ok) = 0; 86 (*ok) = 0;
87} 87}
88 88
89 89
90static void 90static void
91taskLastSig(void *cls) 91taskLastSig (void *cls)
92{ 92{
93 int *ok = cls; 93 int *ok = cls;
94 94
95 GNUNET_SCHEDULER_cancel(never_run_task); 95 GNUNET_SCHEDULER_cancel (never_run_task);
96 GNUNET_assert(9 == *ok); 96 GNUNET_assert (9 == *ok);
97 (*ok) = 0; 97 (*ok) = 0;
98} 98}
99 99
100 100
101static void 101static void
102taskLastShutdown(void *cls) 102taskLastShutdown (void *cls)
103{ 103{
104 int *ok = cls; 104 int *ok = cls;
105 105
106 GNUNET_assert(10 == *ok); 106 GNUNET_assert (10 == *ok);
107 (*ok) = 0; 107 (*ok) = 0;
108} 108}
109 109
110 110
111static void 111static void
112taskRd(void *cls) 112taskRd (void *cls)
113{ 113{
114 static char c; 114 static char c;
115 int *ok = cls; 115 int *ok = cls;
116 const struct GNUNET_SCHEDULER_TaskContext *tc; 116 const struct GNUNET_SCHEDULER_TaskContext *tc;
117 117
118 tc = GNUNET_SCHEDULER_get_task_context(); 118 tc = GNUNET_SCHEDULER_get_task_context ();
119 GNUNET_assert(7 == *ok); 119 GNUNET_assert (7 == *ok);
120 GNUNET_assert(GNUNET_NETWORK_fdset_handle_isset(tc->read_ready, fds[0])); 120 GNUNET_assert (GNUNET_NETWORK_fdset_handle_isset (tc->read_ready, fds[0]));
121 GNUNET_assert(1 == GNUNET_DISK_file_read(fds[0], &c, 1)); 121 GNUNET_assert (1 == GNUNET_DISK_file_read (fds[0], &c, 1));
122 (*ok) = 8; 122 (*ok) = 8;
123 GNUNET_SCHEDULER_add_shutdown(&taskLastRd, 123 GNUNET_SCHEDULER_add_shutdown (&taskLastRd,
124 cls); 124 cls);
125 GNUNET_SCHEDULER_shutdown(); 125 GNUNET_SCHEDULER_shutdown ();
126} 126}
127 127
128 128
129static void 129static void
130task4(void *cls) 130task4 (void *cls)
131{ 131{
132 int *ok = cls; 132 int *ok = cls;
133 133
134 GNUNET_assert(4 == *ok); 134 GNUNET_assert (4 == *ok);
135 (*ok) = 6; 135 (*ok) = 6;
136 p = GNUNET_DISK_pipe(GNUNET_NO, GNUNET_NO, GNUNET_NO, GNUNET_NO); 136 p = GNUNET_DISK_pipe (GNUNET_NO, GNUNET_NO, GNUNET_NO, GNUNET_NO);
137 GNUNET_assert(NULL != p); 137 GNUNET_assert (NULL != p);
138 fds[0] = GNUNET_DISK_pipe_handle(p, GNUNET_DISK_PIPE_END_READ); 138 fds[0] = GNUNET_DISK_pipe_handle (p, GNUNET_DISK_PIPE_END_READ);
139 fds[1] = GNUNET_DISK_pipe_handle(p, GNUNET_DISK_PIPE_END_WRITE); 139 fds[1] = GNUNET_DISK_pipe_handle (p, GNUNET_DISK_PIPE_END_WRITE);
140 GNUNET_SCHEDULER_add_read_file(GNUNET_TIME_UNIT_FOREVER_REL, 140 GNUNET_SCHEDULER_add_read_file (GNUNET_TIME_UNIT_FOREVER_REL,
141 fds[0], 141 fds[0],
142 &taskRd, 142 &taskRd,
143 cls);
144 GNUNET_SCHEDULER_add_write_file(GNUNET_TIME_UNIT_FOREVER_REL,
145 fds[1],
146 &taskWrt,
147 cls); 143 cls);
144 GNUNET_SCHEDULER_add_write_file (GNUNET_TIME_UNIT_FOREVER_REL,
145 fds[1],
146 &taskWrt,
147 cls);
148} 148}
149 149
150 150
151static void 151static void
152task1(void *cls) 152task1 (void *cls)
153{ 153{
154 int *ok = cls; 154 int *ok = cls;
155 155
156 GNUNET_assert(1 == *ok); 156 GNUNET_assert (1 == *ok);
157 (*ok) = 2; 157 (*ok) = 2;
158 GNUNET_SCHEDULER_add_now(&task3, cls); 158 GNUNET_SCHEDULER_add_now (&task3, cls);
159 GNUNET_SCHEDULER_add_with_priority(GNUNET_SCHEDULER_PRIORITY_UI, 159 GNUNET_SCHEDULER_add_with_priority (GNUNET_SCHEDULER_PRIORITY_UI,
160 &task2, 160 &task2,
161 cls); 161 cls);
162 GNUNET_SCHEDULER_add_delayed(GNUNET_TIME_UNIT_SECONDS, 162 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
163 &task4, 163 &task4,
164 cls); 164 cls);
165} 165}
166 166
167 167
@@ -170,27 +170,27 @@ task1(void *cls)
170 * checks that "ok" is correct at the end. 170 * checks that "ok" is correct at the end.
171 */ 171 */
172static int 172static int
173check() 173check ()
174{ 174{
175 int ok; 175 int ok;
176 176
177 GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, 177 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
178 "[Check scheduling]\n"); 178 "[Check scheduling]\n");
179 ok = 1; 179 ok = 1;
180 GNUNET_SCHEDULER_run(&task1, &ok); 180 GNUNET_SCHEDULER_run (&task1, &ok);
181 return ok; 181 return ok;
182} 182}
183 183
184 184
185static void 185static void
186taskShutdown(void *cls) 186taskShutdown (void *cls)
187{ 187{
188 int *ok = cls; 188 int *ok = cls;
189 189
190 GNUNET_assert(1 == *ok); 190 GNUNET_assert (1 == *ok);
191 *ok = 10; 191 *ok = 10;
192 GNUNET_SCHEDULER_add_shutdown(&taskLastShutdown, cls); 192 GNUNET_SCHEDULER_add_shutdown (&taskLastShutdown, cls);
193 GNUNET_SCHEDULER_shutdown(); 193 GNUNET_SCHEDULER_shutdown ();
194} 194}
195 195
196 196
@@ -199,32 +199,33 @@ taskShutdown(void *cls)
199 * checks that "ok" is correct at the end. 199 * checks that "ok" is correct at the end.
200 */ 200 */
201static int 201static int
202checkShutdown() 202checkShutdown ()
203{ 203{
204 int ok; 204 int ok;
205 205
206 GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, 206 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
207 "[Check shutdown]\n"); 207 "[Check shutdown]\n");
208 ok = 1; 208 ok = 1;
209 GNUNET_SCHEDULER_run(&taskShutdown, &ok); 209 GNUNET_SCHEDULER_run (&taskShutdown, &ok);
210 return ok; 210 return ok;
211} 211}
212 212
213 213
214static void 214static void
215taskSig(void *cls) 215taskSig (void *cls)
216{ 216{
217 int *ok = cls; 217 int *ok = cls;
218 218
219 GNUNET_assert(1 == *ok); 219 GNUNET_assert (1 == *ok);
220 *ok = 9; 220 *ok = 9;
221 GNUNET_SCHEDULER_add_shutdown(&taskLastSig, cls); 221 GNUNET_SCHEDULER_add_shutdown (&taskLastSig, cls);
222 never_run_task = 222 never_run_task =
223 GNUNET_SCHEDULER_add_delayed(GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 5), 223 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply (
224 &taskNeverRun, 224 GNUNET_TIME_UNIT_SECONDS, 5),
225 NULL); 225 &taskNeverRun,
226 GNUNET_break(0 == kill(getpid(), 226 NULL);
227 GNUNET_TERM_SIG)); 227 GNUNET_break (0 == kill (getpid (),
228 GNUNET_TERM_SIG));
228} 229}
229 230
230 231
@@ -233,26 +234,26 @@ taskSig(void *cls)
233 * checks that "ok" is correct at the end. 234 * checks that "ok" is correct at the end.
234 */ 235 */
235static int 236static int
236checkSignal() 237checkSignal ()
237{ 238{
238 int ok; 239 int ok;
239 240
240 GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, 241 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
241 "[Check signal handling]\n"); 242 "[Check signal handling]\n");
242 ok = 1; 243 ok = 1;
243 GNUNET_SCHEDULER_run(&taskSig, &ok); 244 GNUNET_SCHEDULER_run (&taskSig, &ok);
244 return ok; 245 return ok;
245} 246}
246 247
247 248
248static void 249static void
249taskCancel(void *cls) 250taskCancel (void *cls)
250{ 251{
251 int *ok = cls; 252 int *ok = cls;
252 253
253 GNUNET_assert(1 == *ok); 254 GNUNET_assert (1 == *ok);
254 *ok = 0; 255 *ok = 0;
255 GNUNET_SCHEDULER_cancel(GNUNET_SCHEDULER_add_now(&taskNeverRun, NULL)); 256 GNUNET_SCHEDULER_cancel (GNUNET_SCHEDULER_add_now (&taskNeverRun, NULL));
256} 257}
257 258
258 259
@@ -261,29 +262,29 @@ taskCancel(void *cls)
261 * checks that "ok" is correct at the end. 262 * checks that "ok" is correct at the end.
262 */ 263 */
263static int 264static int
264checkCancel() 265checkCancel ()
265{ 266{
266 int ok; 267 int ok;
267 268
268 GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, 269 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
269 "[Check task cancellation]\n"); 270 "[Check task cancellation]\n");
270 ok = 1; 271 ok = 1;
271 GNUNET_SCHEDULER_run(&taskCancel, &ok); 272 GNUNET_SCHEDULER_run (&taskCancel, &ok);
272 return ok; 273 return ok;
273} 274}
274 275
275 276
276int 277int
277main(int argc, char *argv[]) 278main (int argc, char *argv[])
278{ 279{
279 int ret = 0; 280 int ret = 0;
280 281
281 GNUNET_log_setup("test_scheduler", "WARNING", NULL); 282 GNUNET_log_setup ("test_scheduler", "WARNING", NULL);
282 ret += check(); 283 ret += check ();
283 ret += checkCancel(); 284 ret += checkCancel ();
284 ret += checkSignal(); 285 ret += checkSignal ();
285 ret += checkShutdown(); 286 ret += checkShutdown ();
286 GNUNET_DISK_pipe_close(p); 287 GNUNET_DISK_pipe_close (p);
287 288
288 return ret; 289 return ret;
289} 290}