diff options
Diffstat (limited to 'src/conversation/test_conversation_api_reject.c')
-rw-r--r-- | src/conversation/test_conversation_api_reject.c | 346 |
1 files changed, 173 insertions, 173 deletions
diff --git a/src/conversation/test_conversation_api_reject.c b/src/conversation/test_conversation_api_reject.c index 2d7a56e3d..53f700890 100644 --- a/src/conversation/test_conversation_api_reject.c +++ b/src/conversation/test_conversation_api_reject.c | |||
@@ -33,7 +33,7 @@ | |||
33 | #include "gnunet_identity_service.h" | 33 | #include "gnunet_identity_service.h" |
34 | #include "gnunet_namestore_service.h" | 34 | #include "gnunet_namestore_service.h" |
35 | 35 | ||
36 | #define TIMEOUT GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 25) | 36 | #define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 25) |
37 | 37 | ||
38 | static int ok = 1; | 38 | static int ok = 1; |
39 | 39 | ||
@@ -57,36 +57,36 @@ static char *gns_caller_id; | |||
57 | 57 | ||
58 | 58 | ||
59 | static int | 59 | static int |
60 | enable_speaker(void *cls) | 60 | enable_speaker (void *cls) |
61 | { | 61 | { |
62 | (void)cls; | 62 | (void) cls; |
63 | GNUNET_break(0); | 63 | GNUNET_break (0); |
64 | return GNUNET_SYSERR; | 64 | return GNUNET_SYSERR; |
65 | } | 65 | } |
66 | 66 | ||
67 | 67 | ||
68 | static void | 68 | static void |
69 | disable_speaker(void *cls) | 69 | disable_speaker (void *cls) |
70 | { | 70 | { |
71 | (void)cls; | 71 | (void) cls; |
72 | GNUNET_break(0); | 72 | GNUNET_break (0); |
73 | } | 73 | } |
74 | 74 | ||
75 | 75 | ||
76 | static void | 76 | static void |
77 | play(void *cls, size_t data_size, const void *data) | 77 | play (void *cls, size_t data_size, const void *data) |
78 | { | 78 | { |
79 | (void)cls; | 79 | (void) cls; |
80 | (void)data_size; | 80 | (void) data_size; |
81 | (void)data; | 81 | (void) data; |
82 | GNUNET_break(0); | 82 | GNUNET_break (0); |
83 | } | 83 | } |
84 | 84 | ||
85 | 85 | ||
86 | static void | 86 | static void |
87 | destroy_speaker(void *cls) | 87 | destroy_speaker (void *cls) |
88 | { | 88 | { |
89 | (void)cls; | 89 | (void) cls; |
90 | } | 90 | } |
91 | 91 | ||
92 | 92 | ||
@@ -98,30 +98,30 @@ static struct GNUNET_SPEAKER_Handle call_speaker = { &enable_speaker, | |||
98 | 98 | ||
99 | 99 | ||
100 | static int | 100 | static int |
101 | enable_mic(void *cls, | 101 | enable_mic (void *cls, |
102 | GNUNET_MICROPHONE_RecordedDataCallback rdc, | 102 | GNUNET_MICROPHONE_RecordedDataCallback rdc, |
103 | void *rdc_cls) | 103 | void *rdc_cls) |
104 | { | 104 | { |
105 | (void)cls; | 105 | (void) cls; |
106 | (void)rdc; | 106 | (void) rdc; |
107 | (void)rdc_cls; | 107 | (void) rdc_cls; |
108 | GNUNET_break(0); | 108 | GNUNET_break (0); |
109 | return GNUNET_SYSERR; | 109 | return GNUNET_SYSERR; |
110 | } | 110 | } |
111 | 111 | ||
112 | 112 | ||
113 | static void | 113 | static void |
114 | disable_mic(void *cls) | 114 | disable_mic (void *cls) |
115 | { | 115 | { |
116 | (void)cls; | 116 | (void) cls; |
117 | GNUNET_break(0); | 117 | GNUNET_break (0); |
118 | } | 118 | } |
119 | 119 | ||
120 | 120 | ||
121 | static void | 121 | static void |
122 | destroy_mic(void *cls) | 122 | destroy_mic (void *cls) |
123 | { | 123 | { |
124 | (void)cls; | 124 | (void) cls; |
125 | } | 125 | } |
126 | 126 | ||
127 | 127 | ||
@@ -137,219 +137,219 @@ static struct GNUNET_MICROPHONE_Handle call_mic = { &enable_mic, | |||
137 | * @param cls closure | 137 | * @param cls closure |
138 | */ | 138 | */ |
139 | static void | 139 | static void |
140 | end_test(void *cls) | 140 | end_test (void *cls) |
141 | { | 141 | { |
142 | (void)cls; | 142 | (void) cls; |
143 | GNUNET_SCHEDULER_shutdown(); | 143 | GNUNET_SCHEDULER_shutdown (); |
144 | if (NULL != op) | 144 | if (NULL != op) |
145 | { | 145 | { |
146 | GNUNET_IDENTITY_cancel(op); | 146 | GNUNET_IDENTITY_cancel (op); |
147 | op = NULL; | 147 | op = NULL; |
148 | } | 148 | } |
149 | if (NULL != call) | 149 | if (NULL != call) |
150 | { | 150 | { |
151 | GNUNET_CONVERSATION_call_stop(call); | 151 | GNUNET_CONVERSATION_call_stop (call); |
152 | call = NULL; | 152 | call = NULL; |
153 | } | 153 | } |
154 | if (NULL != phone) | 154 | if (NULL != phone) |
155 | { | 155 | { |
156 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from PHONE service.\n"); | 156 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from PHONE service.\n"); |
157 | GNUNET_CONVERSATION_phone_destroy(phone); | 157 | GNUNET_CONVERSATION_phone_destroy (phone); |
158 | phone = NULL; | 158 | phone = NULL; |
159 | } | 159 | } |
160 | if (NULL != id) | 160 | if (NULL != id) |
161 | { | 161 | { |
162 | GNUNET_IDENTITY_disconnect(id); | 162 | GNUNET_IDENTITY_disconnect (id); |
163 | id = NULL; | 163 | id = NULL; |
164 | } | 164 | } |
165 | if (NULL != qe) | 165 | if (NULL != qe) |
166 | { | 166 | { |
167 | GNUNET_NAMESTORE_cancel(qe); | 167 | GNUNET_NAMESTORE_cancel (qe); |
168 | qe = NULL; | 168 | qe = NULL; |
169 | } | 169 | } |
170 | if (NULL != ns) | 170 | if (NULL != ns) |
171 | { | 171 | { |
172 | GNUNET_NAMESTORE_disconnect(ns); | 172 | GNUNET_NAMESTORE_disconnect (ns); |
173 | ns = NULL; | 173 | ns = NULL; |
174 | } | 174 | } |
175 | } | 175 | } |
176 | 176 | ||
177 | 177 | ||
178 | static void | 178 | static void |
179 | phone_event_handler(void *cls, | 179 | phone_event_handler (void *cls, |
180 | enum GNUNET_CONVERSATION_PhoneEventCode code, | 180 | enum GNUNET_CONVERSATION_PhoneEventCode code, |
181 | struct GNUNET_CONVERSATION_Caller *caller, | 181 | struct GNUNET_CONVERSATION_Caller *caller, |
182 | const struct GNUNET_CRYPTO_EcdsaPublicKey *caller_id) | 182 | const struct GNUNET_CRYPTO_EcdsaPublicKey *caller_id) |
183 | { | 183 | { |
184 | static enum GNUNET_CONVERSATION_PhoneEventCode expect = | 184 | static enum GNUNET_CONVERSATION_PhoneEventCode expect = |
185 | GNUNET_CONVERSATION_EC_PHONE_RING; | 185 | GNUNET_CONVERSATION_EC_PHONE_RING; |
186 | 186 | ||
187 | (void)cls; | 187 | (void) cls; |
188 | (void)caller_id; | 188 | (void) caller_id; |
189 | GNUNET_break(code == expect); | 189 | GNUNET_break (code == expect); |
190 | switch (code) | 190 | switch (code) |
191 | { | 191 | { |
192 | case GNUNET_CONVERSATION_EC_PHONE_RING: | 192 | case GNUNET_CONVERSATION_EC_PHONE_RING: |
193 | GNUNET_CONVERSATION_caller_hang_up(caller); | 193 | GNUNET_CONVERSATION_caller_hang_up (caller); |
194 | break; | 194 | break; |
195 | 195 | ||
196 | default: | 196 | default: |
197 | fprintf(stderr, "Unexpected phone code: %d\n", code); | 197 | fprintf (stderr, "Unexpected phone code: %d\n", code); |
198 | break; | 198 | break; |
199 | } | 199 | } |
200 | } | 200 | } |
201 | 201 | ||
202 | 202 | ||
203 | static void | 203 | static void |
204 | call_event_handler(void *cls, enum GNUNET_CONVERSATION_CallEventCode code) | 204 | call_event_handler (void *cls, enum GNUNET_CONVERSATION_CallEventCode code) |
205 | { | 205 | { |
206 | static enum GNUNET_CONVERSATION_CallEventCode expect = | 206 | static enum GNUNET_CONVERSATION_CallEventCode expect = |
207 | GNUNET_CONVERSATION_EC_CALL_RINGING; | 207 | GNUNET_CONVERSATION_EC_CALL_RINGING; |
208 | 208 | ||
209 | (void)cls; | 209 | (void) cls; |
210 | GNUNET_break(code == expect); | 210 | GNUNET_break (code == expect); |
211 | switch (code) | 211 | switch (code) |
212 | { | 212 | { |
213 | case GNUNET_CONVERSATION_EC_CALL_RINGING: | 213 | case GNUNET_CONVERSATION_EC_CALL_RINGING: |
214 | expect = GNUNET_CONVERSATION_EC_CALL_HUNG_UP; | 214 | expect = GNUNET_CONVERSATION_EC_CALL_HUNG_UP; |
215 | break; | 215 | break; |
216 | 216 | ||
217 | case GNUNET_CONVERSATION_EC_CALL_HUNG_UP: | 217 | case GNUNET_CONVERSATION_EC_CALL_HUNG_UP: |
218 | call = NULL; | 218 | call = NULL; |
219 | ok = 0; | 219 | ok = 0; |
220 | GNUNET_SCHEDULER_shutdown(); | 220 | GNUNET_SCHEDULER_shutdown (); |
221 | expect = -1; | 221 | expect = -1; |
222 | break; | 222 | break; |
223 | 223 | ||
224 | case GNUNET_CONVERSATION_EC_CALL_PICKED_UP: | 224 | case GNUNET_CONVERSATION_EC_CALL_PICKED_UP: |
225 | case GNUNET_CONVERSATION_EC_CALL_GNS_FAIL: | 225 | case GNUNET_CONVERSATION_EC_CALL_GNS_FAIL: |
226 | case GNUNET_CONVERSATION_EC_CALL_SUSPENDED: | 226 | case GNUNET_CONVERSATION_EC_CALL_SUSPENDED: |
227 | case GNUNET_CONVERSATION_EC_CALL_RESUMED: | 227 | case GNUNET_CONVERSATION_EC_CALL_RESUMED: |
228 | fprintf(stderr, "Unexpected call code: %d\n", code); | 228 | fprintf (stderr, "Unexpected call code: %d\n", code); |
229 | break; | 229 | break; |
230 | 230 | ||
231 | case GNUNET_CONVERSATION_EC_CALL_ERROR: | 231 | case GNUNET_CONVERSATION_EC_CALL_ERROR: |
232 | fprintf(stderr, "Unexpected call code: %d\n", code); | 232 | fprintf (stderr, "Unexpected call code: %d\n", code); |
233 | call = NULL; | 233 | call = NULL; |
234 | break; | 234 | break; |
235 | } | 235 | } |
236 | } | 236 | } |
237 | 237 | ||
238 | 238 | ||
239 | static void | 239 | static void |
240 | caller_ego_create_cont(void *cls, | 240 | caller_ego_create_cont (void *cls, |
241 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *pk, | 241 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *pk, |
242 | const char *emsg) | 242 | const char *emsg) |
243 | { | 243 | { |
244 | (void)cls; | 244 | (void) cls; |
245 | op = NULL; | 245 | op = NULL; |
246 | GNUNET_assert(NULL == emsg); | 246 | GNUNET_assert (NULL == emsg); |
247 | } | 247 | } |
248 | 248 | ||
249 | 249 | ||
250 | static void | 250 | static void |
251 | namestore_put_cont(void *cls, int32_t success, const char *emsg) | 251 | namestore_put_cont (void *cls, int32_t success, const char *emsg) |
252 | { | 252 | { |
253 | (void)cls; | 253 | (void) cls; |
254 | qe = NULL; | 254 | qe = NULL; |
255 | GNUNET_assert(GNUNET_YES == success); | 255 | GNUNET_assert (GNUNET_YES == success); |
256 | GNUNET_assert(NULL == emsg); | 256 | GNUNET_assert (NULL == emsg); |
257 | GNUNET_assert(NULL == op); | 257 | GNUNET_assert (NULL == op); |
258 | op = GNUNET_IDENTITY_create(id, "caller-ego", &caller_ego_create_cont, NULL); | 258 | op = GNUNET_IDENTITY_create (id, "caller-ego", &caller_ego_create_cont, NULL); |
259 | } | 259 | } |
260 | 260 | ||
261 | 261 | ||
262 | static void | 262 | static void |
263 | identity_cb(void *cls, | 263 | identity_cb (void *cls, |
264 | struct GNUNET_IDENTITY_Ego *ego, | 264 | struct GNUNET_IDENTITY_Ego *ego, |
265 | void **ctx, | 265 | void **ctx, |
266 | const char *name) | 266 | const char *name) |
267 | { | 267 | { |
268 | struct GNUNET_GNSRECORD_Data rd; | 268 | struct GNUNET_GNSRECORD_Data rd; |
269 | struct GNUNET_CRYPTO_EcdsaPublicKey pub; | 269 | struct GNUNET_CRYPTO_EcdsaPublicKey pub; |
270 | 270 | ||
271 | (void)cls; | 271 | (void) cls; |
272 | (void)ctx; | 272 | (void) ctx; |
273 | if (NULL == name) | 273 | if (NULL == name) |
274 | return; | 274 | return; |
275 | if (NULL == ego) | 275 | if (NULL == ego) |
276 | return; | 276 | return; |
277 | if (0 == strcmp(name, "phone-ego")) | 277 | if (0 == strcmp (name, "phone-ego")) |
278 | { | 278 | { |
279 | GNUNET_IDENTITY_ego_get_public_key(ego, &pub); | 279 | GNUNET_IDENTITY_ego_get_public_key (ego, &pub); |
280 | GNUNET_asprintf(&gns_name, | 280 | GNUNET_asprintf (&gns_name, |
281 | "phone.%s", | 281 | "phone.%s", |
282 | GNUNET_GNSRECORD_pkey_to_zkey(&pub)); | 282 | GNUNET_GNSRECORD_pkey_to_zkey (&pub)); |
283 | phone = | 283 | phone = |
284 | GNUNET_CONVERSATION_phone_create(cfg, ego, &phone_event_handler, NULL); | 284 | GNUNET_CONVERSATION_phone_create (cfg, ego, &phone_event_handler, NULL); |
285 | GNUNET_assert(NULL != phone); | 285 | GNUNET_assert (NULL != phone); |
286 | memset(&rd, 0, sizeof(rd)); | 286 | memset (&rd, 0, sizeof(rd)); |
287 | GNUNET_CONVERSATION_phone_get_record(phone, &rd); | 287 | GNUNET_CONVERSATION_phone_get_record (phone, &rd); |
288 | GNUNET_assert(rd.record_type == GNUNET_GNSRECORD_TYPE_PHONE); | 288 | GNUNET_assert (rd.record_type == GNUNET_GNSRECORD_TYPE_PHONE); |
289 | rd.expiration_time = UINT64_MAX; | 289 | rd.expiration_time = UINT64_MAX; |
290 | qe = | 290 | qe = |
291 | GNUNET_NAMESTORE_records_store(ns, | 291 | GNUNET_NAMESTORE_records_store (ns, |
292 | GNUNET_IDENTITY_ego_get_private_key(ego), | 292 | GNUNET_IDENTITY_ego_get_private_key (ego), |
293 | "phone" /* GNS label */, | 293 | "phone" /* GNS label */, |
294 | 1, | 294 | 1, |
295 | &rd, | 295 | &rd, |
296 | &namestore_put_cont, | 296 | &namestore_put_cont, |
297 | NULL); | 297 | NULL); |
298 | return; | 298 | return; |
299 | } | 299 | } |
300 | if (0 == strcmp(name, "caller-ego")) | 300 | if (0 == strcmp (name, "caller-ego")) |
301 | { | 301 | { |
302 | GNUNET_IDENTITY_ego_get_public_key(ego, &pub); | 302 | GNUNET_IDENTITY_ego_get_public_key (ego, &pub); |
303 | GNUNET_asprintf(&gns_caller_id, | 303 | GNUNET_asprintf (&gns_caller_id, |
304 | "%s", | 304 | "%s", |
305 | GNUNET_GNSRECORD_pkey_to_zkey(&pub)); | 305 | GNUNET_GNSRECORD_pkey_to_zkey (&pub)); |
306 | call = GNUNET_CONVERSATION_call_start(cfg, | 306 | call = GNUNET_CONVERSATION_call_start (cfg, |
307 | ego, | 307 | ego, |
308 | gns_name, | 308 | gns_name, |
309 | &call_speaker, | 309 | &call_speaker, |
310 | &call_mic, | 310 | &call_mic, |
311 | &call_event_handler, | 311 | &call_event_handler, |
312 | NULL); | 312 | NULL); |
313 | return; | 313 | return; |
314 | } | 314 | } |
315 | } | 315 | } |
316 | 316 | ||
317 | 317 | ||
318 | static void | 318 | static void |
319 | phone_ego_create_cont(void *cls, | 319 | phone_ego_create_cont (void *cls, |
320 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *pk, | 320 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *pk, |
321 | const char *emsg) | 321 | const char *emsg) |
322 | { | 322 | { |
323 | (void)cls; | 323 | (void) cls; |
324 | op = NULL; | 324 | op = NULL; |
325 | GNUNET_assert(NULL == emsg); | 325 | GNUNET_assert (NULL == emsg); |
326 | } | 326 | } |
327 | 327 | ||
328 | 328 | ||
329 | static void | 329 | static void |
330 | run(void *cls, | 330 | run (void *cls, |
331 | const struct GNUNET_CONFIGURATION_Handle *c, | 331 | const struct GNUNET_CONFIGURATION_Handle *c, |
332 | struct GNUNET_TESTING_Peer *peer) | 332 | struct GNUNET_TESTING_Peer *peer) |
333 | { | 333 | { |
334 | (void)cls; | 334 | (void) cls; |
335 | (void)peer; | 335 | (void) peer; |
336 | cfg = c; | 336 | cfg = c; |
337 | GNUNET_SCHEDULER_add_delayed(TIMEOUT, &end_test, NULL); | 337 | GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_test, NULL); |
338 | id = GNUNET_IDENTITY_connect(cfg, &identity_cb, NULL); | 338 | id = GNUNET_IDENTITY_connect (cfg, &identity_cb, NULL); |
339 | op = GNUNET_IDENTITY_create(id, "phone-ego", &phone_ego_create_cont, NULL); | 339 | op = GNUNET_IDENTITY_create (id, "phone-ego", &phone_ego_create_cont, NULL); |
340 | ns = GNUNET_NAMESTORE_connect(cfg); | 340 | ns = GNUNET_NAMESTORE_connect (cfg); |
341 | } | 341 | } |
342 | 342 | ||
343 | 343 | ||
344 | int | 344 | int |
345 | main(int argc, char *argv[]) | 345 | main (int argc, char *argv[]) |
346 | { | 346 | { |
347 | (void)argc; | 347 | (void) argc; |
348 | (void)argv; | 348 | (void) argv; |
349 | if (0 != GNUNET_TESTING_peer_run("test_conversation_api", | 349 | if (0 != GNUNET_TESTING_peer_run ("test_conversation_api", |
350 | "test_conversation.conf", | 350 | "test_conversation.conf", |
351 | &run, | 351 | &run, |
352 | NULL)) | 352 | NULL)) |
353 | return 1; | 353 | return 1; |
354 | return ok; | 354 | return ok; |
355 | } | 355 | } |