aboutsummaryrefslogtreecommitdiff
path: root/src/testbed/test_testbed_api_controllerlink.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/testbed/test_testbed_api_controllerlink.c
parentfbb71d527c7d6babf269a8fefce1db291b9f7068 (diff)
downloadgnunet-c4e9ba925ffd758aaa3feee2ccfc0b76f26fe207.tar.gz
gnunet-c4e9ba925ffd758aaa3feee2ccfc0b76f26fe207.zip
global reindent, now with uncrustify hook enabled
Diffstat (limited to 'src/testbed/test_testbed_api_controllerlink.c')
-rw-r--r--src/testbed/test_testbed_api_controllerlink.c786
1 files changed, 394 insertions, 392 deletions
diff --git a/src/testbed/test_testbed_api_controllerlink.c b/src/testbed/test_testbed_api_controllerlink.c
index ffcbebf00..55ec184ea 100644
--- a/src/testbed/test_testbed_api_controllerlink.c
+++ b/src/testbed/test_testbed_api_controllerlink.c
@@ -45,17 +45,18 @@
45/** 45/**
46 * Generic logging shortcut 46 * Generic logging shortcut
47 */ 47 */
48#define LOG(kind, ...) GNUNET_log(kind, __VA_ARGS__) 48#define LOG(kind, ...) GNUNET_log (kind, __VA_ARGS__)
49 49
50/** 50/**
51 * Debug logging shorthand 51 * Debug logging shorthand
52 */ 52 */
53#define LOG_DEBUG(...) LOG(GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__) 53#define LOG_DEBUG(...) LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__)
54 54
55/** 55/**
56 * Different stages in testing 56 * Different stages in testing
57 */ 57 */
58enum Stage { 58enum Stage
59{
59 /** 60 /**
60 * Initial stage 61 * Initial stage
61 */ 62 */
@@ -292,17 +293,17 @@ static enum Stage result;
292 */ 293 */
293#define FAIL_TEST(cond) \ 294#define FAIL_TEST(cond) \
294 do \ 295 do \
295 { \ 296 { \
296 if (!(cond)) \ 297 if (! (cond)) \
297 { \ 298 { \
298 GNUNET_break(0); \ 299 GNUNET_break (0); \
299 if (NULL != abort_task) \ 300 if (NULL != abort_task) \
300 GNUNET_SCHEDULER_cancel (abort_task); \ 301 GNUNET_SCHEDULER_cancel (abort_task); \
301 abort_task = NULL; \ 302 abort_task = NULL; \
302 GNUNET_SCHEDULER_shutdown(); \ 303 GNUNET_SCHEDULER_shutdown (); \
303 return; \ 304 return; \
304 } \ 305 } \
305 } while (0) 306 } while (0)
306 307
307 308
308/** 309/**
@@ -311,40 +312,40 @@ static enum Stage result;
311 * @param cls NULL 312 * @param cls NULL
312 */ 313 */
313static void 314static void
314do_shutdown(void *cls) 315do_shutdown (void *cls)
315{ 316{
316 if (NULL != abort_task) 317 if (NULL != abort_task)
317 GNUNET_SCHEDULER_cancel(abort_task); 318 GNUNET_SCHEDULER_cancel (abort_task);
318 if (NULL != delay_task_id) 319 if (NULL != delay_task_id)
319 { 320 {
320 GNUNET_SCHEDULER_cancel(delay_task_id); 321 GNUNET_SCHEDULER_cancel (delay_task_id);
321 delay_task_id = NULL; 322 delay_task_id = NULL;
322 } 323 }
323 if (NULL != hc_handle) 324 if (NULL != hc_handle)
324 GNUNET_TESTBED_is_host_habitable_cancel(hc_handle); 325 GNUNET_TESTBED_is_host_habitable_cancel (hc_handle);
325 if (NULL != op) 326 if (NULL != op)
326 { 327 {
327 GNUNET_TESTBED_operation_done(op); 328 GNUNET_TESTBED_operation_done (op);
328 op = NULL; 329 op = NULL;
329 } 330 }
330 if (NULL != mc) 331 if (NULL != mc)
331 GNUNET_TESTBED_controller_disconnect(mc); 332 GNUNET_TESTBED_controller_disconnect (mc);
332 if (NULL != cp) 333 if (NULL != cp)
333 GNUNET_TESTBED_controller_stop(cp); 334 GNUNET_TESTBED_controller_stop (cp);
334 if (NULL != slave3) 335 if (NULL != slave3)
335 GNUNET_TESTBED_host_destroy(slave3); 336 GNUNET_TESTBED_host_destroy (slave3);
336 if (NULL != slave2) 337 if (NULL != slave2)
337 GNUNET_TESTBED_host_destroy(slave2); 338 GNUNET_TESTBED_host_destroy (slave2);
338 if (NULL != slave) 339 if (NULL != slave)
339 GNUNET_TESTBED_host_destroy(slave); 340 GNUNET_TESTBED_host_destroy (slave);
340 if (NULL != host) 341 if (NULL != host)
341 GNUNET_TESTBED_host_destroy(host); 342 GNUNET_TESTBED_host_destroy (host);
342 if (NULL != cfg) 343 if (NULL != cfg)
343 GNUNET_CONFIGURATION_destroy(cfg); 344 GNUNET_CONFIGURATION_destroy (cfg);
344 if (NULL != cfg3) 345 if (NULL != cfg3)
345 GNUNET_CONFIGURATION_destroy(cfg3); 346 GNUNET_CONFIGURATION_destroy (cfg3);
346 if (NULL != rh) 347 if (NULL != rh)
347 GNUNET_TESTBED_cancel_registration(rh); 348 GNUNET_TESTBED_cancel_registration (rh);
348} 349}
349 350
350 351
@@ -354,11 +355,11 @@ do_shutdown(void *cls)
354 * @param cls NULL 355 * @param cls NULL
355 */ 356 */
356static void 357static void
357do_abort(void *cls) 358do_abort (void *cls)
358{ 359{
359 LOG(GNUNET_ERROR_TYPE_WARNING, "Aborting in stage %d\n", result); 360 LOG (GNUNET_ERROR_TYPE_WARNING, "Aborting in stage %d\n", result);
360 abort_task = NULL; 361 abort_task = NULL;
361 GNUNET_SCHEDULER_shutdown(); 362 GNUNET_SCHEDULER_shutdown ();
362} 363}
363 364
364 365
@@ -369,11 +370,11 @@ do_abort(void *cls)
369 * @return 370 * @return
370 */ 371 */
371static void 372static void
372do_abort_now(void *cls) 373do_abort_now (void *cls)
373{ 374{
374 if (NULL != abort_task) 375 if (NULL != abort_task)
375 GNUNET_SCHEDULER_cancel(abort_task); 376 GNUNET_SCHEDULER_cancel (abort_task);
376 abort_task = GNUNET_SCHEDULER_add_now(&do_abort, NULL); 377 abort_task = GNUNET_SCHEDULER_add_now (&do_abort, NULL);
377} 378}
378 379
379 380
@@ -384,7 +385,7 @@ do_abort_now(void *cls)
384 * @param emsg the error message; NULL if host registration is successful 385 * @param emsg the error message; NULL if host registration is successful
385 */ 386 */
386static void 387static void
387registration_cont(void *cls, const char *emsg); 388registration_cont (void *cls, const char *emsg);
388 389
389 390
390/** 391/**
@@ -394,29 +395,29 @@ registration_cont(void *cls, const char *emsg);
394 * @return 395 * @return
395 */ 396 */
396static void 397static void
397delay_task(void *cls) 398delay_task (void *cls)
398{ 399{
399 delay_task_id = NULL; 400 delay_task_id = NULL;
400 switch (result) 401 switch (result)
401 { 402 {
402 case SLAVE2_PEER_CREATE_SUCCESS: 403 case SLAVE2_PEER_CREATE_SUCCESS:
403 op = GNUNET_TESTBED_peer_stop(NULL, slave1_peer, NULL, NULL); 404 op = GNUNET_TESTBED_peer_stop (NULL, slave1_peer, NULL, NULL);
404 FAIL_TEST(NULL != op); 405 FAIL_TEST (NULL != op);
405 break; 406 break;
406 407
407 case MASTER_SLAVE2_PEERS_CONNECTED: 408 case MASTER_SLAVE2_PEERS_CONNECTED:
408 slave3 = GNUNET_TESTBED_host_create_with_id(3, "127.0.0.1", NULL, cfg, 0); 409 slave3 = GNUNET_TESTBED_host_create_with_id (3, "127.0.0.1", NULL, cfg, 0);
409 rh = GNUNET_TESTBED_register_host(mc, slave3, &registration_cont, NULL); 410 rh = GNUNET_TESTBED_register_host (mc, slave3, &registration_cont, NULL);
410 break; 411 break;
411 412
412 case SLAVE2_SLAVE3_PEERS_CONNECTED: 413 case SLAVE2_SLAVE3_PEERS_CONNECTED:
413 op = GNUNET_TESTBED_peer_stop(NULL, slave2_peer, NULL, NULL); 414 op = GNUNET_TESTBED_peer_stop (NULL, slave2_peer, NULL, NULL);
414 FAIL_TEST(NULL != op); 415 FAIL_TEST (NULL != op);
415 break; 416 break;
416 417
417 default: 418 default:
418 FAIL_TEST(0); 419 FAIL_TEST (0);
419 } 420 }
420} 421}
421 422
422 423
@@ -430,48 +431,48 @@ delay_task(void *cls)
430 * @param emsg NULL if peer is not NULL; else MAY contain the error description 431 * @param emsg NULL if peer is not NULL; else MAY contain the error description
431 */ 432 */
432static void 433static void
433peer_create_cb(void *cls, struct GNUNET_TESTBED_Peer *peer, const char *emsg) 434peer_create_cb (void *cls, struct GNUNET_TESTBED_Peer *peer, const char *emsg)
434{ 435{
435 FAIL_TEST(NULL != peer); 436 FAIL_TEST (NULL != peer);
436 FAIL_TEST(NULL == emsg); 437 FAIL_TEST (NULL == emsg);
437 switch (result) 438 switch (result)
438 { 439 {
439 case MASTER_STARTED: 440 case MASTER_STARTED:
440 result = MASTER_PEER_CREATE_SUCCESS; 441 result = MASTER_PEER_CREATE_SUCCESS;
441 master_peer = peer; 442 master_peer = peer;
442 GNUNET_TESTBED_operation_done(op); 443 GNUNET_TESTBED_operation_done (op);
443 op = GNUNET_TESTBED_peer_start(NULL, master_peer, NULL, NULL); 444 op = GNUNET_TESTBED_peer_start (NULL, master_peer, NULL, NULL);
444 break; 445 break;
445 446
446 case SLAVE1_LINK_SUCCESS: 447 case SLAVE1_LINK_SUCCESS:
447 result = SLAVE1_PEER_CREATE_SUCCESS; 448 result = SLAVE1_PEER_CREATE_SUCCESS;
448 slave1_peer = peer; 449 slave1_peer = peer;
449 GNUNET_TESTBED_operation_done(op); 450 GNUNET_TESTBED_operation_done (op);
450 op = GNUNET_TESTBED_peer_start(NULL, slave1_peer, NULL, NULL); 451 op = GNUNET_TESTBED_peer_start (NULL, slave1_peer, NULL, NULL);
451 break; 452 break;
452 453
453 case SLAVE2_LINK_SUCCESS: 454 case SLAVE2_LINK_SUCCESS:
454 result = SLAVE2_PEER_CREATE_SUCCESS; 455 result = SLAVE2_PEER_CREATE_SUCCESS;
455 slave2_peer = peer; 456 slave2_peer = peer;
456 GNUNET_TESTBED_operation_done(op); 457 GNUNET_TESTBED_operation_done (op);
457 op = NULL; 458 op = NULL;
458 delay_task_id = GNUNET_SCHEDULER_add_delayed( 459 delay_task_id = GNUNET_SCHEDULER_add_delayed (
459 GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 1), 460 GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 1),
460 &delay_task, 461 &delay_task,
461 NULL); 462 NULL);
462 return; 463 return;
463 464
464 case SLAVE3_STARTED: 465 case SLAVE3_STARTED:
465 result = SLAVE3_PEER_CREATE_SUCCESS; 466 result = SLAVE3_PEER_CREATE_SUCCESS;
466 slave3_peer = peer; 467 slave3_peer = peer;
467 GNUNET_TESTBED_operation_done(op); 468 GNUNET_TESTBED_operation_done (op);
468 op = GNUNET_TESTBED_peer_start(NULL, slave3_peer, NULL, NULL); 469 op = GNUNET_TESTBED_peer_start (NULL, slave3_peer, NULL, NULL);
469 break; 470 break;
470 471
471 default: 472 default:
472 FAIL_TEST(0); 473 FAIL_TEST (0);
473 } 474 }
474 FAIL_TEST(NULL != op); 475 FAIL_TEST (NULL != op);
475} 476}
476 477
477 478
@@ -482,14 +483,14 @@ peer_create_cb(void *cls, struct GNUNET_TESTBED_Peer *peer, const char *emsg)
482 * @param event the event information to check 483 * @param event the event information to check
483 */ 484 */
484static void 485static void
485check_operation_success(const struct GNUNET_TESTBED_EventInformation *event) 486check_operation_success (const struct GNUNET_TESTBED_EventInformation *event)
486{ 487{
487 FAIL_TEST(NULL != event); 488 FAIL_TEST (NULL != event);
488 FAIL_TEST(GNUNET_TESTBED_ET_OPERATION_FINISHED == event->type); 489 FAIL_TEST (GNUNET_TESTBED_ET_OPERATION_FINISHED == event->type);
489 FAIL_TEST(event->op == op); 490 FAIL_TEST (event->op == op);
490 FAIL_TEST(NULL == event->op_cls); 491 FAIL_TEST (NULL == event->op_cls);
491 FAIL_TEST(NULL == event->details.operation_finished.emsg); 492 FAIL_TEST (NULL == event->details.operation_finished.emsg);
492 FAIL_TEST(NULL == event->details.operation_finished.generic); 493 FAIL_TEST (NULL == event->details.operation_finished.generic);
493} 494}
494 495
495 496
@@ -501,180 +502,180 @@ check_operation_success(const struct GNUNET_TESTBED_EventInformation *event)
501 * @param event information about the event 502 * @param event information about the event
502 */ 503 */
503static void 504static void
504controller_cb(void *cls, const struct GNUNET_TESTBED_EventInformation *event) 505controller_cb (void *cls, const struct GNUNET_TESTBED_EventInformation *event)
505{ 506{
506 switch (result) 507 switch (result)
507 { 508 {
508 case SLAVE2_REGISTERED: 509 case SLAVE2_REGISTERED:
509 check_operation_success(event); 510 check_operation_success (event);
510 GNUNET_TESTBED_operation_done(op); 511 GNUNET_TESTBED_operation_done (op);
511 op = NULL; 512 op = NULL;
512 result = SLAVE1_LINK_SUCCESS; 513 result = SLAVE1_LINK_SUCCESS;
513 FAIL_TEST(NULL != slave2); 514 FAIL_TEST (NULL != slave2);
514 FAIL_TEST(NULL != slave); 515 FAIL_TEST (NULL != slave);
515 op = GNUNET_TESTBED_peer_create(mc, slave, cfg, peer_create_cb, NULL); 516 op = GNUNET_TESTBED_peer_create (mc, slave, cfg, peer_create_cb, NULL);
516 FAIL_TEST(NULL != op); 517 FAIL_TEST (NULL != op);
517 break; 518 break;
518 519
519 case SLAVE1_PEER_START_SUCCESS: 520 case SLAVE1_PEER_START_SUCCESS:
520 check_operation_success(event); 521 check_operation_success (event);
521 GNUNET_TESTBED_operation_done(op); 522 GNUNET_TESTBED_operation_done (op);
522 result = SLAVE2_LINK_SUCCESS; 523 result = SLAVE2_LINK_SUCCESS;
523 op = GNUNET_TESTBED_peer_create(mc, slave2, cfg, peer_create_cb, NULL); 524 op = GNUNET_TESTBED_peer_create (mc, slave2, cfg, peer_create_cb, NULL);
524 FAIL_TEST(NULL != op); 525 FAIL_TEST (NULL != op);
525 break; 526 break;
526 527
527 case MASTER_PEER_CREATE_SUCCESS: 528 case MASTER_PEER_CREATE_SUCCESS:
528 FAIL_TEST(GNUNET_TESTBED_ET_PEER_START == event->type); 529 FAIL_TEST (GNUNET_TESTBED_ET_PEER_START == event->type);
529 FAIL_TEST(event->details.peer_start.host == host); 530 FAIL_TEST (event->details.peer_start.host == host);
530 FAIL_TEST(event->details.peer_start.peer == master_peer); 531 FAIL_TEST (event->details.peer_start.peer == master_peer);
531 GNUNET_TESTBED_operation_done(op); 532 GNUNET_TESTBED_operation_done (op);
532 op = NULL; 533 op = NULL;
533 result = MASTER_PEER_START_SUCCESS; 534 result = MASTER_PEER_START_SUCCESS;
534 slave = GNUNET_TESTBED_host_create_with_id(1, "127.0.0.1", NULL, cfg, 0); 535 slave = GNUNET_TESTBED_host_create_with_id (1, "127.0.0.1", NULL, cfg, 0);
535 FAIL_TEST(NULL != slave); 536 FAIL_TEST (NULL != slave);
536 rh = GNUNET_TESTBED_register_host(mc, slave, &registration_cont, NULL); 537 rh = GNUNET_TESTBED_register_host (mc, slave, &registration_cont, NULL);
537 FAIL_TEST(NULL != rh); 538 FAIL_TEST (NULL != rh);
538 break; 539 break;
539 540
540 case SLAVE1_PEER_CREATE_SUCCESS: 541 case SLAVE1_PEER_CREATE_SUCCESS:
541 FAIL_TEST(GNUNET_TESTBED_ET_PEER_START == event->type); 542 FAIL_TEST (GNUNET_TESTBED_ET_PEER_START == event->type);
542 FAIL_TEST(event->details.peer_start.host == slave); 543 FAIL_TEST (event->details.peer_start.host == slave);
543 FAIL_TEST(event->details.peer_start.peer == slave1_peer); 544 FAIL_TEST (event->details.peer_start.peer == slave1_peer);
544 GNUNET_TESTBED_operation_done(op); 545 GNUNET_TESTBED_operation_done (op);
545 result = SLAVE1_PEER_START_SUCCESS; 546 result = SLAVE1_PEER_START_SUCCESS;
546 op = GNUNET_TESTBED_controller_link(NULL, mc, slave2, slave, GNUNET_YES); 547 op = GNUNET_TESTBED_controller_link (NULL, mc, slave2, slave, GNUNET_YES);
547 break; 548 break;
548 549
549 case SLAVE2_PEER_CREATE_SUCCESS: 550 case SLAVE2_PEER_CREATE_SUCCESS:
550 FAIL_TEST(GNUNET_TESTBED_ET_PEER_STOP == event->type); 551 FAIL_TEST (GNUNET_TESTBED_ET_PEER_STOP == event->type);
551 FAIL_TEST(event->details.peer_stop.peer == slave1_peer); 552 FAIL_TEST (event->details.peer_stop.peer == slave1_peer);
552 GNUNET_TESTBED_operation_done(op); 553 GNUNET_TESTBED_operation_done (op);
553 result = SLAVE1_PEER_STOP_SUCCESS; 554 result = SLAVE1_PEER_STOP_SUCCESS;
554 op = GNUNET_TESTBED_peer_start(NULL, slave2_peer, NULL, NULL); 555 op = GNUNET_TESTBED_peer_start (NULL, slave2_peer, NULL, NULL);
555 FAIL_TEST(NULL != op); 556 FAIL_TEST (NULL != op);
556 break; 557 break;
557 558
558 case SLAVE3_PEER_CREATE_SUCCESS: 559 case SLAVE3_PEER_CREATE_SUCCESS:
559 FAIL_TEST(GNUNET_TESTBED_ET_PEER_START == event->type); 560 FAIL_TEST (GNUNET_TESTBED_ET_PEER_START == event->type);
560 FAIL_TEST(event->details.peer_start.host == slave3); 561 FAIL_TEST (event->details.peer_start.host == slave3);
561 FAIL_TEST(event->details.peer_start.peer == slave3_peer); 562 FAIL_TEST (event->details.peer_start.peer == slave3_peer);
562 GNUNET_TESTBED_operation_done(op); 563 GNUNET_TESTBED_operation_done (op);
563 result = SLAVE3_PEER_START_SUCCESS; 564 result = SLAVE3_PEER_START_SUCCESS;
564 sleep(1); 565 sleep (1);
565 LOG_DEBUG("**************************************\n"); 566 LOG_DEBUG ("**************************************\n");
566 op = 567 op =
567 GNUNET_TESTBED_overlay_connect(mc, NULL, NULL, slave2_peer, slave3_peer); 568 GNUNET_TESTBED_overlay_connect (mc, NULL, NULL, slave2_peer, slave3_peer);
568 FAIL_TEST(NULL != op); 569 FAIL_TEST (NULL != op);
569 break; 570 break;
570 571
571 case SLAVE3_PEER_START_SUCCESS: 572 case SLAVE3_PEER_START_SUCCESS:
572 FAIL_TEST(NULL != event); 573 FAIL_TEST (NULL != event);
573 FAIL_TEST(GNUNET_TESTBED_ET_CONNECT == event->type); 574 FAIL_TEST (GNUNET_TESTBED_ET_CONNECT == event->type);
574 FAIL_TEST(event->details.peer_connect.peer1 == slave2_peer); 575 FAIL_TEST (event->details.peer_connect.peer1 == slave2_peer);
575 FAIL_TEST(event->details.peer_connect.peer2 == slave3_peer); 576 FAIL_TEST (event->details.peer_connect.peer2 == slave3_peer);
576 result = SLAVE2_SLAVE3_PEERS_CONNECTED; 577 result = SLAVE2_SLAVE3_PEERS_CONNECTED;
577 GNUNET_TESTBED_operation_done(op); 578 GNUNET_TESTBED_operation_done (op);
578 op = NULL; 579 op = NULL;
579 delay_task_id = GNUNET_SCHEDULER_add_delayed( 580 delay_task_id = GNUNET_SCHEDULER_add_delayed (
580 GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 1), 581 GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 1),
581 &delay_task, 582 &delay_task,
582 NULL); 583 NULL);
583 break; 584 break;
584 585
585 case SLAVE1_PEER_STOP_SUCCESS: 586 case SLAVE1_PEER_STOP_SUCCESS:
586 FAIL_TEST(GNUNET_TESTBED_ET_PEER_START == event->type); 587 FAIL_TEST (GNUNET_TESTBED_ET_PEER_START == event->type);
587 FAIL_TEST(event->details.peer_start.host == slave2); 588 FAIL_TEST (event->details.peer_start.host == slave2);
588 FAIL_TEST(event->details.peer_start.peer == slave2_peer); 589 FAIL_TEST (event->details.peer_start.peer == slave2_peer);
589 GNUNET_TESTBED_operation_done(op); 590 GNUNET_TESTBED_operation_done (op);
590 result = SLAVE2_PEER_START_SUCCESS; 591 result = SLAVE2_PEER_START_SUCCESS;
591 op = 592 op =
592 GNUNET_TESTBED_overlay_connect(mc, NULL, NULL, master_peer, slave2_peer); 593 GNUNET_TESTBED_overlay_connect (mc, NULL, NULL, master_peer, slave2_peer);
593 break; 594 break;
594 595
595 case SLAVE2_PEER_START_SUCCESS: 596 case SLAVE2_PEER_START_SUCCESS:
596 FAIL_TEST(NULL != event); 597 FAIL_TEST (NULL != event);
597 FAIL_TEST(GNUNET_TESTBED_ET_CONNECT == event->type); 598 FAIL_TEST (GNUNET_TESTBED_ET_CONNECT == event->type);
598 FAIL_TEST(event->details.peer_connect.peer1 == master_peer); 599 FAIL_TEST (event->details.peer_connect.peer1 == master_peer);
599 FAIL_TEST(event->details.peer_connect.peer2 == slave2_peer); 600 FAIL_TEST (event->details.peer_connect.peer2 == slave2_peer);
600 result = MASTER_SLAVE2_PEERS_CONNECTED; 601 result = MASTER_SLAVE2_PEERS_CONNECTED;
601 GNUNET_TESTBED_operation_done(op); 602 GNUNET_TESTBED_operation_done (op);
602 op = NULL; 603 op = NULL;
603 delay_task_id = GNUNET_SCHEDULER_add_delayed( 604 delay_task_id = GNUNET_SCHEDULER_add_delayed (
604 GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 1), 605 GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 1),
605 &delay_task, 606 &delay_task,
606 NULL); 607 NULL);
607 break; 608 break;
608 609
609 case SLAVE2_SLAVE3_PEERS_CONNECTED: 610 case SLAVE2_SLAVE3_PEERS_CONNECTED:
610 FAIL_TEST(GNUNET_TESTBED_ET_PEER_STOP == event->type); 611 FAIL_TEST (GNUNET_TESTBED_ET_PEER_STOP == event->type);
611 FAIL_TEST(event->details.peer_stop.peer == slave2_peer); 612 FAIL_TEST (event->details.peer_stop.peer == slave2_peer);
612 GNUNET_TESTBED_operation_done(op); 613 GNUNET_TESTBED_operation_done (op);
613 result = SLAVE2_PEER_STOP_SUCCESS; 614 result = SLAVE2_PEER_STOP_SUCCESS;
614 op = GNUNET_TESTBED_peer_destroy(slave1_peer); 615 op = GNUNET_TESTBED_peer_destroy (slave1_peer);
615 FAIL_TEST(NULL != op); 616 FAIL_TEST (NULL != op);
616 break; 617 break;
617 618
618 case SLAVE2_PEER_STOP_SUCCESS: 619 case SLAVE2_PEER_STOP_SUCCESS:
619 check_operation_success(event); 620 check_operation_success (event);
620 GNUNET_TESTBED_operation_done(op); 621 GNUNET_TESTBED_operation_done (op);
621 result = SLAVE1_PEER_DESTROY_SUCCESS; 622 result = SLAVE1_PEER_DESTROY_SUCCESS;
622 op = GNUNET_TESTBED_peer_destroy(slave2_peer); 623 op = GNUNET_TESTBED_peer_destroy (slave2_peer);
623 FAIL_TEST(NULL != op); 624 FAIL_TEST (NULL != op);
624 break; 625 break;
625 626
626 case SLAVE1_PEER_DESTROY_SUCCESS: 627 case SLAVE1_PEER_DESTROY_SUCCESS:
627 check_operation_success(event); 628 check_operation_success (event);
628 GNUNET_TESTBED_operation_done(op); 629 GNUNET_TESTBED_operation_done (op);
629 op = NULL; 630 op = NULL;
630 result = SLAVE2_PEER_DESTROY_SUCCESS; 631 result = SLAVE2_PEER_DESTROY_SUCCESS;
631 op = GNUNET_TESTBED_get_slave_config(NULL, mc, slave3); 632 op = GNUNET_TESTBED_get_slave_config (NULL, mc, slave3);
632 FAIL_TEST(NULL != op); 633 FAIL_TEST (NULL != op);
633 break; 634 break;
634 635
635 case SLAVE2_PEER_DESTROY_SUCCESS: 636 case SLAVE2_PEER_DESTROY_SUCCESS:
636 FAIL_TEST(NULL != event); 637 FAIL_TEST (NULL != event);
637 FAIL_TEST(GNUNET_TESTBED_ET_OPERATION_FINISHED == event->type); 638 FAIL_TEST (GNUNET_TESTBED_ET_OPERATION_FINISHED == event->type);
638 FAIL_TEST(event->op == op); 639 FAIL_TEST (event->op == op);
639 FAIL_TEST(NULL == event->op_cls); 640 FAIL_TEST (NULL == event->op_cls);
640 FAIL_TEST(NULL == event->details.operation_finished.emsg); 641 FAIL_TEST (NULL == event->details.operation_finished.emsg);
641 cfg3 = GNUNET_CONFIGURATION_dup(event->details.operation_finished.generic); 642 cfg3 = GNUNET_CONFIGURATION_dup (event->details.operation_finished.generic);
642 GNUNET_TESTBED_operation_done(op); 643 GNUNET_TESTBED_operation_done (op);
643 result = SLAVE3_GET_CONFIG_SUCCESS; 644 result = SLAVE3_GET_CONFIG_SUCCESS;
644 op = GNUNET_TESTBED_controller_link(NULL, mc, slave3, slave, GNUNET_NO); 645 op = GNUNET_TESTBED_controller_link (NULL, mc, slave3, slave, GNUNET_NO);
645 break; 646 break;
646 647
647 case SLAVE3_REGISTERED: 648 case SLAVE3_REGISTERED:
648 check_operation_success(event); 649 check_operation_success (event);
649 GNUNET_TESTBED_operation_done(op); 650 GNUNET_TESTBED_operation_done (op);
650 result = SLAVE3_STARTED; 651 result = SLAVE3_STARTED;
651 op = GNUNET_TESTBED_peer_create(mc, slave3, cfg, peer_create_cb, NULL); 652 op = GNUNET_TESTBED_peer_create (mc, slave3, cfg, peer_create_cb, NULL);
652 FAIL_TEST(NULL != op); 653 FAIL_TEST (NULL != op);
653 break; 654 break;
654 655
655 case SLAVE3_GET_CONFIG_SUCCESS: 656 case SLAVE3_GET_CONFIG_SUCCESS:
656 result = SLAVE3_LINK_SUCCESS; 657 result = SLAVE3_LINK_SUCCESS;
657 GNUNET_TESTBED_operation_done(op); 658 GNUNET_TESTBED_operation_done (op);
658 op = GNUNET_TESTBED_peer_destroy(master_peer); 659 op = GNUNET_TESTBED_peer_destroy (master_peer);
659 break; 660 break;
660 661
661 case SLAVE3_LINK_SUCCESS: 662 case SLAVE3_LINK_SUCCESS:
662 check_operation_success(event); 663 check_operation_success (event);
663 result = MASTER_PEER_DESTROY_SUCCESS; 664 result = MASTER_PEER_DESTROY_SUCCESS;
664 GNUNET_TESTBED_operation_done(op); 665 GNUNET_TESTBED_operation_done (op);
665 op = GNUNET_TESTBED_peer_destroy(slave3_peer); 666 op = GNUNET_TESTBED_peer_destroy (slave3_peer);
666 break; 667 break;
667 668
668 case MASTER_PEER_DESTROY_SUCCESS: 669 case MASTER_PEER_DESTROY_SUCCESS:
669 result = SUCCESS; 670 result = SUCCESS;
670 GNUNET_TESTBED_operation_done(op); 671 GNUNET_TESTBED_operation_done (op);
671 op = NULL; 672 op = NULL;
672 GNUNET_SCHEDULER_shutdown(); 673 GNUNET_SCHEDULER_shutdown ();
673 break; 674 break;
674 675
675 default: 676 default:
676 FAIL_TEST(0); 677 FAIL_TEST (0);
677 } 678 }
678} 679}
679 680
680 681
@@ -685,43 +686,43 @@ controller_cb(void *cls, const struct GNUNET_TESTBED_EventInformation *event)
685 * @param emsg the error message; NULL if host registration is successful 686 * @param emsg the error message; NULL if host registration is successful
686 */ 687 */
687static void 688static void
688registration_cont(void *cls, const char *emsg) 689registration_cont (void *cls, const char *emsg)
689{ 690{
690 rh = NULL; 691 rh = NULL;
691 switch (result) 692 switch (result)
692 { 693 {
693 case MASTER_PEER_START_SUCCESS: 694 case MASTER_PEER_START_SUCCESS:
694 FAIL_TEST(NULL == emsg); 695 FAIL_TEST (NULL == emsg);
695 FAIL_TEST(NULL != mc); 696 FAIL_TEST (NULL != mc);
696 result = SLAVE1_REGISTERED; 697 result = SLAVE1_REGISTERED;
697 slave2 = GNUNET_TESTBED_host_create_with_id(2, "127.0.0.1", NULL, cfg, 0); 698 slave2 = GNUNET_TESTBED_host_create_with_id (2, "127.0.0.1", NULL, cfg, 0);
698 FAIL_TEST(NULL != slave2); 699 FAIL_TEST (NULL != slave2);
699 rh = GNUNET_TESTBED_register_host(mc, slave2, &registration_cont, NULL); 700 rh = GNUNET_TESTBED_register_host (mc, slave2, &registration_cont, NULL);
700 FAIL_TEST(NULL != rh); 701 FAIL_TEST (NULL != rh);
701 break; 702 break;
702 703
703 case SLAVE1_REGISTERED: 704 case SLAVE1_REGISTERED:
704 FAIL_TEST(NULL == emsg); 705 FAIL_TEST (NULL == emsg);
705 FAIL_TEST(NULL != mc); 706 FAIL_TEST (NULL != mc);
706 result = SLAVE2_REGISTERED; 707 result = SLAVE2_REGISTERED;
707 FAIL_TEST(NULL != cfg); 708 FAIL_TEST (NULL != cfg);
708 op = GNUNET_TESTBED_controller_link(NULL, mc, slave, NULL, GNUNET_YES); 709 op = GNUNET_TESTBED_controller_link (NULL, mc, slave, NULL, GNUNET_YES);
709 FAIL_TEST(NULL != op); 710 FAIL_TEST (NULL != op);
710 break; 711 break;
711 712
712 case MASTER_SLAVE2_PEERS_CONNECTED: 713 case MASTER_SLAVE2_PEERS_CONNECTED:
713 FAIL_TEST(NULL == emsg); 714 FAIL_TEST (NULL == emsg);
714 FAIL_TEST(NULL != mc); 715 FAIL_TEST (NULL != mc);
715 FAIL_TEST(NULL == op); 716 FAIL_TEST (NULL == op);
716 result = SLAVE3_REGISTERED; 717 result = SLAVE3_REGISTERED;
717 op = GNUNET_TESTBED_controller_link(NULL, mc, slave3, NULL, GNUNET_YES); 718 op = GNUNET_TESTBED_controller_link (NULL, mc, slave3, NULL, GNUNET_YES);
718 FAIL_TEST(NULL != op); 719 FAIL_TEST (NULL != op);
719 break; 720 break;
720 721
721 default: 722 default:
722 GNUNET_break(0); 723 GNUNET_break (0);
723 do_abort_now(NULL); 724 do_abort_now (NULL);
724 } 725 }
725} 726}
726 727
727/** 728/**
@@ -734,34 +735,34 @@ registration_cont(void *cls, const char *emsg)
734 * GNUNET_TESTBED_controller_stop() shouldn't be called in this case 735 * GNUNET_TESTBED_controller_stop() shouldn't be called in this case
735 */ 736 */
736static void 737static void
737status_cb(void *cls, 738status_cb (void *cls,
738 const struct GNUNET_CONFIGURATION_Handle *config, 739 const struct GNUNET_CONFIGURATION_Handle *config,
739 int status) 740 int status)
740{ 741{
741 switch (result) 742 switch (result)
742 { 743 {
743 case INIT: 744 case INIT:
744 FAIL_TEST(GNUNET_OK == status); 745 FAIL_TEST (GNUNET_OK == status);
745 event_mask = 0; 746 event_mask = 0;
746 event_mask |= (1L << GNUNET_TESTBED_ET_PEER_START); 747 event_mask |= (1L << GNUNET_TESTBED_ET_PEER_START);
747 event_mask |= (1L << GNUNET_TESTBED_ET_PEER_STOP); 748 event_mask |= (1L << GNUNET_TESTBED_ET_PEER_STOP);
748 event_mask |= (1L << GNUNET_TESTBED_ET_CONNECT); 749 event_mask |= (1L << GNUNET_TESTBED_ET_CONNECT);
749 event_mask |= (1L << GNUNET_TESTBED_ET_OPERATION_FINISHED); 750 event_mask |= (1L << GNUNET_TESTBED_ET_OPERATION_FINISHED);
750 mc = GNUNET_TESTBED_controller_connect(host, 751 mc = GNUNET_TESTBED_controller_connect (host,
751 event_mask, 752 event_mask,
752 &controller_cb, 753 &controller_cb,
753 NULL); 754 NULL);
754 FAIL_TEST(NULL != mc); 755 FAIL_TEST (NULL != mc);
755 result = MASTER_STARTED; 756 result = MASTER_STARTED;
756 op = GNUNET_TESTBED_peer_create(mc, host, cfg, peer_create_cb, NULL); 757 op = GNUNET_TESTBED_peer_create (mc, host, cfg, peer_create_cb, NULL);
757 FAIL_TEST(NULL != op); 758 FAIL_TEST (NULL != op);
758 break; 759 break;
759 760
760 default: 761 default:
761 GNUNET_break(0); 762 GNUNET_break (0);
762 cp = NULL; 763 cp = NULL;
763 do_abort_now(NULL); 764 do_abort_now (NULL);
764 } 765 }
765} 766}
766 767
767 768
@@ -776,24 +777,24 @@ status_cb(void *cls,
776 * @param status #GNUNET_YES if it is habitable; #GNUNET_NO if not 777 * @param status #GNUNET_YES if it is habitable; #GNUNET_NO if not
777 */ 778 */
778static void 779static void
779host_habitable_cb(void *cls, 780host_habitable_cb (void *cls,
780 const struct GNUNET_TESTBED_Host *_host, 781 const struct GNUNET_TESTBED_Host *_host,
781 int status) 782 int status)
782{ 783{
783 hc_handle = NULL; 784 hc_handle = NULL;
784 if (GNUNET_NO == status) 785 if (GNUNET_NO == status)
785 { 786 {
786 (void)printf("%s", 787 (void) printf ("%s",
787 "Unable to run the test as this system is not configured " 788 "Unable to run the test as this system is not configured "
788 "to use password less SSH logins to localhost.\n" 789 "to use password less SSH logins to localhost.\n"
789 "Skipping test\n"); 790 "Skipping test\n");
790 GNUNET_SCHEDULER_cancel(abort_task); 791 GNUNET_SCHEDULER_cancel (abort_task);
791 abort_task = NULL; 792 abort_task = NULL;
792 GNUNET_SCHEDULER_shutdown(); 793 GNUNET_SCHEDULER_shutdown ();
793 result = SKIP; 794 result = SKIP;
794 return; 795 return;
795 } 796 }
796 cp = GNUNET_TESTBED_controller_start("127.0.0.1", host, status_cb, NULL); 797 cp = GNUNET_TESTBED_controller_start ("127.0.0.1", host, status_cb, NULL);
797} 798}
798 799
799 800
@@ -806,35 +807,35 @@ host_habitable_cb(void *cls,
806 * @param cfg the configuration file handle 807 * @param cfg the configuration file handle
807 */ 808 */
808static void 809static void
809run(void *cls, 810run (void *cls,
810 char *const *args, 811 char *const *args,
811 const char *cfgfile, 812 const char *cfgfile,
812 const struct GNUNET_CONFIGURATION_Handle *config) 813 const struct GNUNET_CONFIGURATION_Handle *config)
813{ 814{
814 cfg = GNUNET_CONFIGURATION_dup(config); 815 cfg = GNUNET_CONFIGURATION_dup (config);
815 host = GNUNET_TESTBED_host_create(NULL, NULL, cfg, 0); 816 host = GNUNET_TESTBED_host_create (NULL, NULL, cfg, 0);
816 FAIL_TEST(NULL != host); 817 FAIL_TEST (NULL != host);
817 if (NULL == (hc_handle = GNUNET_TESTBED_is_host_habitable(host, 818 if (NULL == (hc_handle = GNUNET_TESTBED_is_host_habitable (host,
818 config, 819 config,
819 &host_habitable_cb, 820 &host_habitable_cb,
820 NULL))) 821 NULL)))
821 { 822 {
822 GNUNET_TESTBED_host_destroy(host); 823 GNUNET_TESTBED_host_destroy (host);
823 GNUNET_CONFIGURATION_destroy(cfg); 824 GNUNET_CONFIGURATION_destroy (cfg);
824 cfg = NULL; 825 cfg = NULL;
825 host = NULL; 826 host = NULL;
826 (void)printf("%s", 827 (void) printf ("%s",
827 "Unable to run the test as this system is not configured " 828 "Unable to run the test as this system is not configured "
828 "to use password less SSH logins to localhost.\n" 829 "to use password less SSH logins to localhost.\n"
829 "Marking test as successful\n"); 830 "Marking test as successful\n");
830 result = SKIP; 831 result = SKIP;
831 return; 832 return;
832 } 833 }
833 abort_task = GNUNET_SCHEDULER_add_delayed( 834 abort_task = GNUNET_SCHEDULER_add_delayed (
834 GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_MINUTES, 5), 835 GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MINUTES, 5),
835 &do_abort, 836 &do_abort,
836 NULL); 837 NULL);
837 GNUNET_SCHEDULER_add_shutdown(&do_shutdown, NULL); 838 GNUNET_SCHEDULER_add_shutdown (&do_shutdown, NULL);
838} 839}
839 840
840 841
@@ -842,36 +843,37 @@ run(void *cls,
842 * Main function 843 * Main function
843 */ 844 */
844int 845int
845main(int argc, char **argv) 846main (int argc, char **argv)
846{ 847{
847 char *const argv2[] = { "test_testbed_api_controllerlink", 848 char *const argv2[] = { "test_testbed_api_controllerlink",
848 "-c", 849 "-c",
849 "test_testbed_api.conf", 850 "test_testbed_api.conf",
850 NULL }; 851 NULL };
851 struct GNUNET_GETOPT_CommandLineOption options[] = { GNUNET_GETOPT_OPTION_END }; 852 struct GNUNET_GETOPT_CommandLineOption options[] =
853 { GNUNET_GETOPT_OPTION_END };
852 int ret; 854 int ret;
853 855
854 result = INIT; 856 result = INIT;
855 ret = GNUNET_PROGRAM_run((sizeof(argv2) / sizeof(char *)) - 1, 857 ret = GNUNET_PROGRAM_run ((sizeof(argv2) / sizeof(char *)) - 1,
856 argv2, 858 argv2,
857 "test_testbed_api_controllerlink", 859 "test_testbed_api_controllerlink",
858 "nohelp", 860 "nohelp",
859 options, 861 options,
860 &run, 862 &run,
861 NULL); 863 NULL);
862 if (GNUNET_OK != ret) 864 if (GNUNET_OK != ret)
863 return 1; 865 return 1;
864 switch (result) 866 switch (result)
865 { 867 {
866 case SUCCESS: 868 case SUCCESS:
867 return 0; 869 return 0;
868 870
869 case SKIP: 871 case SKIP:
870 return 77; /* Mark test as skipped */ 872 return 77; /* Mark test as skipped */
871 873
872 default: 874 default:
873 return 1; 875 return 1;
874 } 876 }
875} 877}
876 878
877/* end of test_testbed_api_controllerlink.c */ 879/* end of test_testbed_api_controllerlink.c */