← Back to branch summary

~vorlon/ubuntu/raring/upstart/lp.1199778

« back to all changes in this revision

Viewing changes to init/tests/test_job_class.c

  • Committer: Scott James Remnant
  • Date: 2008-06-06 02:52:15 UTC
  • Revision ID: scott@netsplit.com-20080606025215-ka6swh7bjw7l9tk5
* init/tests/test_control.c (my_connect_handler): Use TEST_DBUS_MESSAGE
instead of a pop/read/write loop.
(test_emit_event): Renamed TEST_DBUS_CONN to TEST_DBUS_OPEN.
* init/tests/test_job.c (test_new, test_register)
(test_change_state): Use TEST_DBUS_OPEN and TEST_DBUS_CLOSE to setup
and tear down D-Bus connections and TEST_DBUS_MESSAGE instead of
a loop.
* init/tests/test_job_class.c (test_consider, test_reconsider)
(test_register, test_unregister): Likewise.

Show diffs side-by-side

added added

removed removed

Lines of Context:
init/tests/test_job_class.c
161
161
        dbus_error_init (&dbus_error);
162
162
 
163
163
        TEST_DBUS (dbus_pid);
164
 
 
165
 
        client_conn = dbus_bus_get (DBUS_BUS_SYSTEM, NULL);
166
 
        assert (client_conn != NULL);
167
 
        dbus_connection_set_exit_on_disconnect (client_conn, FALSE);
 
164
        TEST_DBUS_OPEN (conn);
 
165
        TEST_DBUS_OPEN (client_conn);
168
166
 
169
167
        dbus_bus_add_match (client_conn, "type='signal'", &dbus_error);
170
168
        assert (! dbus_error_is_set (&dbus_error));
171
169
 
172
170
 
173
 
        assert (conn = nih_dbus_bus (DBUS_BUS_SYSTEM, NULL));
174
 
 
175
 
        while (! (message = dbus_connection_pop_message (client_conn)))
176
 
                dbus_connection_read_write (client_conn, -1);
177
 
 
178
 
        assert (dbus_message_is_signal (message, DBUS_INTERFACE_DBUS,
179
 
                                        "NameAcquired"));
180
 
 
181
 
        dbus_message_unref (message);
182
 
 
183
 
 
184
171
        source1 = conf_source_new (NULL, "/tmp/foo", CONF_DIR);
185
172
 
186
173
        source2 = conf_source_new (NULL, "/tmp/bar", CONF_JOB_DIR);
224
211
 
225
212
        dbus_connection_flush (conn);
226
213
 
227
 
        while (! (message = dbus_connection_pop_message (client_conn)))
228
 
                dbus_connection_read_write (client_conn, -1);
229
 
 
 
214
        TEST_DBUS_MESSAGE (client_conn, message);
230
215
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart",
231
216
                                           "JobAdded"));
232
217
 
264
249
 
265
250
        dbus_connection_flush (conn);
266
251
 
267
 
        while (! (message = dbus_connection_pop_message (client_conn)))
268
 
                dbus_connection_read_write (client_conn, -1);
269
 
 
 
252
        TEST_DBUS_MESSAGE (client_conn, message);
270
253
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart",
271
254
                                           "JobAdded"));
272
255
 
321
304
 
322
305
        dbus_connection_flush (conn);
323
306
 
324
 
        while (! (message = dbus_connection_pop_message (client_conn)))
325
 
                dbus_connection_read_write (client_conn, -1);
326
 
 
 
307
        TEST_DBUS_MESSAGE (client_conn, message);
327
308
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart.Test",
328
309
                                           "TestPassed"));
329
310
 
360
341
 
361
342
        dbus_connection_flush (conn);
362
343
 
363
 
        while (! (message = dbus_connection_pop_message (client_conn)))
364
 
                dbus_connection_read_write (client_conn, -1);
365
 
 
 
344
        TEST_DBUS_MESSAGE (client_conn, message);
366
345
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart",
367
346
                                           "JobRemoved"));
368
347
 
374
353
 
375
354
        dbus_message_unref (message);
376
355
 
377
 
        while (! (message = dbus_connection_pop_message (client_conn)))
378
 
                dbus_connection_read_write (client_conn, -1);
379
 
 
 
356
        TEST_DBUS_MESSAGE (client_conn, message);
380
357
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart",
381
358
                                           "JobAdded"));
382
359
 
419
396
 
420
397
        dbus_connection_flush (conn);
421
398
 
422
 
        while (! (message = dbus_connection_pop_message (client_conn)))
423
 
                dbus_connection_read_write (client_conn, -1);
424
 
 
 
399
        TEST_DBUS_MESSAGE (client_conn, message);
425
400
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart",
426
401
                                           "JobRemoved"));
427
402
 
433
408
 
434
409
        dbus_message_unref (message);
435
410
 
436
 
        while (! (message = dbus_connection_pop_message (client_conn)))
437
 
                dbus_connection_read_write (client_conn, -1);
438
 
 
 
411
        TEST_DBUS_MESSAGE (client_conn, message);
439
412
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart",
440
413
                                           "JobAdded"));
441
414
 
460
433
 
461
434
        nih_free (entry);
462
435
 
463
 
        dbus_connection_unref (conn);
464
 
 
465
 
        dbus_connection_unref (client_conn);
466
 
 
 
436
        TEST_DBUS_CLOSE (conn);
 
437
        TEST_DBUS_CLOSE (client_conn);
467
438
        TEST_DBUS_END (dbus_pid);
468
439
 
469
440
        dbus_shutdown ();
489
460
        dbus_error_init (&dbus_error);
490
461
 
491
462
        TEST_DBUS (dbus_pid);
492
 
 
493
 
        client_conn = dbus_bus_get (DBUS_BUS_SYSTEM, NULL);
494
 
        assert (client_conn != NULL);
495
 
        dbus_connection_set_exit_on_disconnect (client_conn, FALSE);
 
463
        TEST_DBUS_OPEN (conn);
 
464
        TEST_DBUS_OPEN (client_conn);
496
465
 
497
466
        dbus_bus_add_match (client_conn, "type='signal'", &dbus_error);
498
467
        assert (! dbus_error_is_set (&dbus_error));
499
468
 
500
469
 
501
 
        assert (conn = nih_dbus_bus (DBUS_BUS_SYSTEM, NULL));
502
 
 
503
 
        while (! (message = dbus_connection_pop_message (client_conn)))
504
 
                dbus_connection_read_write (client_conn, -1);
505
 
 
506
 
        assert (dbus_message_is_signal (message, DBUS_INTERFACE_DBUS,
507
 
                                        "NameAcquired"));
508
 
 
509
 
        dbus_message_unref (message);
510
 
 
511
 
 
512
470
        source1 = conf_source_new (NULL, "/tmp/foo", CONF_DIR);
513
471
 
514
472
        source2 = conf_source_new (NULL, "/tmp/bar", CONF_JOB_DIR);
563
521
 
564
522
        dbus_connection_flush (conn);
565
523
 
566
 
        while (! (message = dbus_connection_pop_message (client_conn)))
567
 
                dbus_connection_read_write (client_conn, -1);
568
 
 
 
524
        TEST_DBUS_MESSAGE (client_conn, message);
569
525
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart.Test",
570
526
                                           "TestPassed"));
571
527
 
598
554
 
599
555
        dbus_connection_flush (conn);
600
556
 
601
 
        while (! (message = dbus_connection_pop_message (client_conn)))
602
 
                dbus_connection_read_write (client_conn, -1);
603
 
 
 
557
        TEST_DBUS_MESSAGE (client_conn, message);
604
558
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart",
605
559
                                           "JobRemoved"));
606
560
 
612
566
 
613
567
        dbus_message_unref (message);
614
568
 
615
 
        while (! (message = dbus_connection_pop_message (client_conn)))
616
 
                dbus_connection_read_write (client_conn, -1);
617
 
 
 
569
        TEST_DBUS_MESSAGE (client_conn, message);
618
570
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart",
619
571
                                           "JobAdded"));
620
572
 
669
621
 
670
622
        dbus_connection_flush (conn);
671
623
 
672
 
        while (! (message = dbus_connection_pop_message (client_conn)))
673
 
                dbus_connection_read_write (client_conn, -1);
674
 
 
 
624
        TEST_DBUS_MESSAGE (client_conn, message);
675
625
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart.Test",
676
626
                                           "TestPassed"));
677
627
 
713
663
 
714
664
        dbus_connection_flush (conn);
715
665
 
716
 
        while (! (message = dbus_connection_pop_message (client_conn)))
717
 
                dbus_connection_read_write (client_conn, -1);
718
 
 
 
666
        TEST_DBUS_MESSAGE (client_conn, message);
719
667
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart.Test",
720
668
                                           "TestPassed"));
721
669
 
750
698
 
751
699
        dbus_connection_flush (conn);
752
700
 
753
 
        while (! (message = dbus_connection_pop_message (client_conn)))
754
 
                dbus_connection_read_write (client_conn, -1);
755
 
 
 
701
        TEST_DBUS_MESSAGE (client_conn, message);
756
702
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart.Test",
757
703
                                           "TestPassed"));
758
704
 
784
730
 
785
731
        dbus_connection_flush (conn);
786
732
 
787
 
        while (! (message = dbus_connection_pop_message (client_conn)))
788
 
                dbus_connection_read_write (client_conn, -1);
789
 
 
 
733
        TEST_DBUS_MESSAGE (client_conn, message);
790
734
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart",
791
735
                                           "JobRemoved"));
792
736
 
803
747
 
804
748
        nih_free (entry);
805
749
 
806
 
        dbus_connection_unref (conn);
807
 
 
808
 
        dbus_connection_unref (client_conn);
809
 
 
 
750
        TEST_DBUS_CLOSE (conn);
 
751
        TEST_DBUS_CLOSE (client_conn);
810
752
        TEST_DBUS_END (dbus_pid);
811
753
 
812
754
        dbus_shutdown ();
828
770
        dbus_error_init (&dbus_error);
829
771
 
830
772
        TEST_DBUS (dbus_pid);
831
 
 
832
 
        client_conn = dbus_bus_get (DBUS_BUS_SYSTEM, NULL);
833
 
        assert (client_conn != NULL);
834
 
        dbus_connection_set_exit_on_disconnect (client_conn, FALSE);
 
773
        TEST_DBUS_OPEN (conn);
 
774
        TEST_DBUS_OPEN (client_conn);
835
775
 
836
776
        dbus_bus_add_match (client_conn, "type='signal'", &dbus_error);
837
777
        assert (! dbus_error_is_set (&dbus_error));
838
778
 
839
779
 
840
 
        assert (conn = nih_dbus_bus (DBUS_BUS_SYSTEM, NULL));
841
 
 
842
 
        while (! (message = dbus_connection_pop_message (client_conn)))
843
 
                dbus_connection_read_write (client_conn, -1);
844
 
 
845
 
        assert (dbus_message_is_signal (message, DBUS_INTERFACE_DBUS,
846
 
                                        "NameAcquired"));
847
 
 
848
 
        dbus_message_unref (message);
849
 
 
850
 
 
851
780
        /* Check that we can register an existing job class on the bus
852
781
         * using its path and that the JobAdded signal is emitted to
853
782
         * announce it.
871
800
 
872
801
        dbus_connection_flush (conn);
873
802
 
874
 
        while (! (message = dbus_connection_pop_message (client_conn)))
875
 
                dbus_connection_read_write (client_conn, -1);
876
 
 
 
803
        TEST_DBUS_MESSAGE (client_conn, message);
877
804
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart",
878
805
                                           "JobAdded"));
879
806
 
918
845
 
919
846
        dbus_connection_flush (conn);
920
847
 
921
 
        while (! (message = dbus_connection_pop_message (client_conn)))
922
 
                dbus_connection_read_write (client_conn, -1);
923
 
 
 
848
        TEST_DBUS_MESSAGE (client_conn, message);
924
849
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart.Test",
925
850
                                           "TestPassed"));
926
851
 
929
854
        nih_free (class);
930
855
 
931
856
 
932
 
        dbus_connection_unref (conn);
933
 
 
934
 
        dbus_connection_unref (client_conn);
935
 
 
 
857
        TEST_DBUS_CLOSE (conn);
 
858
        TEST_DBUS_CLOSE (client_conn);
936
859
        TEST_DBUS_END (dbus_pid);
937
860
 
938
861
        dbus_shutdown ();
958
881
        dbus_error_init (&dbus_error);
959
882
 
960
883
        TEST_DBUS (dbus_pid);
961
 
 
962
 
        client_conn = dbus_bus_get (DBUS_BUS_SYSTEM, NULL);
963
 
        assert (client_conn != NULL);
964
 
        dbus_connection_set_exit_on_disconnect (client_conn, FALSE);
 
884
        TEST_DBUS_OPEN (conn);
 
885
        TEST_DBUS_OPEN (client_conn);
965
886
 
966
887
        dbus_bus_add_match (client_conn, "type='signal'", &dbus_error);
967
888
        assert (! dbus_error_is_set (&dbus_error));
968
889
 
969
890
 
970
 
        assert (conn = nih_dbus_bus (DBUS_BUS_SYSTEM, NULL));
971
 
 
972
 
        while (! (message = dbus_connection_pop_message (client_conn)))
973
 
                dbus_connection_read_write (client_conn, -1);
974
 
 
975
 
        assert (dbus_message_is_signal (message, DBUS_INTERFACE_DBUS,
976
 
                                        "NameAcquired"));
977
 
 
978
 
        dbus_message_unref (message);
979
 
 
980
 
 
981
891
        class = job_class_new (NULL, "test");
982
892
 
983
893
        assert (dbus_connection_get_object_path_data (conn, class->path,
1000
910
 
1001
911
        dbus_connection_flush (conn);
1002
912
 
1003
 
        while (! (message = dbus_connection_pop_message (client_conn)))
1004
 
                dbus_connection_read_write (client_conn, -1);
1005
 
 
 
913
        TEST_DBUS_MESSAGE (client_conn, message);
1006
914
        TEST_TRUE (dbus_message_is_signal (message, "com.ubuntu.Upstart",
1007
915
                                           "JobRemoved"));
1008
916
 
1017
925
        nih_free (class);
1018
926
 
1019
927
 
1020
 
        dbus_connection_unref (conn);
1021
 
 
1022
 
        dbus_connection_unref (client_conn);
1023
 
 
 
928
        TEST_DBUS_CLOSE (conn);
 
929
        TEST_DBUS_CLOSE (client_conn);
1024
930
        TEST_DBUS_END (dbus_pid);
1025
931
 
1026
932
        dbus_shutdown ();