Lines Matching refs:test_ctx
41 struct test_ctx {
52 #define mark_online(test_ctx) do { \
53 test_ctx->be_ctx->offstat.went_offline = 0; \
54 test_ctx->be_ctx->offstat.offline = false; \
57 #define mark_offline(test_ctx) do { \
58 test_ctx->be_ctx->offstat.went_offline = get_current_time(); \
59 test_ctx->be_ctx->offstat.offline = true; \
62 /* Since both test_ctx->done and ptask->req is marked as finished already
67 #define is_sync_ptask_finished(test_ctx, ptask) \
68 (test_ctx->done && ptask->req == NULL)
94 struct test_ctx *test_ctx = NULL;
96 test_ctx = sss_mock_ptr_type(struct test_ctx *);
97 test_ctx->add_online_cb_called = true;
108 struct test_ctx *test_ctx = NULL;
110 test_ctx = sss_mock_ptr_type(struct test_ctx *);
111 test_ctx->add_offline_cb_called = true;
117 struct test_ctx *test_ctx;
127 struct test_ctx *test_ctx = NULL;
135 test_ctx = talloc_get_type(pvt, struct test_ctx);
136 assert_non_null(test_ctx);
138 test_ctx->when = get_current_time();
143 state->test_ctx = test_ctx;
156 struct test_ctx *test_ctx = NULL;
162 test_ctx = talloc_get_type(pvt, struct test_ctx);
163 assert_non_null(test_ctx);
165 test_ctx->when = get_current_time();
166 test_ctx->done = true;
178 struct test_ctx *test_ctx = NULL;
186 test_ctx = talloc_get_type(pvt, struct test_ctx);
187 assert_non_null(test_ctx);
189 test_ctx->when = get_current_time();
194 state->test_ctx = test_ctx;
208 state->test_ctx->done = true;
222 state->test_ctx->done = true;
233 struct test_ctx *test_ctx = NULL;
240 test_ctx = talloc_get_type(pvt, struct test_ctx);
241 assert_non_null(test_ctx);
243 test_ctx->when = get_current_time();
244 test_ctx->done = true;
255 struct test_ctx *test_ctx = NULL;
262 test_ctx = talloc_get_type(pvt, struct test_ctx);
263 assert_non_null(test_ctx);
265 test_ctx->when = get_current_time();
266 test_ctx->done = true;
273 struct test_ctx *test_ctx = NULL;
277 test_ctx = talloc_zero(global_talloc_context, struct test_ctx);
278 assert_non_null(test_ctx);
280 test_ctx->tctx = create_ev_test_ctx(test_ctx);
281 assert_non_null(test_ctx->tctx);
283 test_ctx->be_ctx = mock_be_ctx(test_ctx, test_ctx->tctx);
284 assert_non_null(test_ctx->be_ctx);
286 test_ctx->be_ctx->ev = tevent_context_init(test_ctx->be_ctx);
287 assert_non_null(test_ctx->be_ctx->ev);
289 check_leaks_push(test_ctx);
290 *state = test_ctx;
304 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
308 ret = be_ptask_create(test_ctx, NULL, PERIOD, 0, 0, 0, 0,
317 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
321 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, 0, 0, 0, 0, 0,
330 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
334 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
343 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
347 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
356 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
360 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
369 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
375 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
377 test_be_ptask_recv, test_ctx, "Test ptask", &ptask);
382 while (!test_ctx->done) {
383 tevent_loop_once(test_ctx->be_ctx->ev);
387 assert_true(now <= test_ctx->when);
388 assert_true(ptask->last_execution <= test_ctx->when);
396 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
402 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, DELAY, 0, 0, 0,
404 test_be_ptask_recv, test_ctx, "Test ptask", &ptask);
409 while (!test_ctx->done) {
410 tevent_loop_once(test_ctx->be_ctx->ev);
414 assert_true(now + DELAY <= test_ctx->when);
415 assert_true(ptask->last_execution <= test_ctx->when);
423 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
427 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
429 test_be_ptask_recv, test_ctx, "Test ptask", &ptask);
445 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
451 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
453 test_be_ptask_recv, test_ctx, "Test ptask", &ptask);
464 while (!test_ctx->done) {
465 tevent_loop_once(test_ctx->be_ctx->ev);
469 assert_true(now <= test_ctx->when);
470 assert_true(ptask->last_execution <= test_ctx->when);
478 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
483 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, DELAY, 0, 0,
485 test_be_ptask_recv, test_ctx, "Test ptask", &ptask);
490 while (!test_ctx->done) {
491 tevent_loop_once(test_ctx->be_ctx->ev);
495 test_ctx->done = false;
499 while (!test_ctx->done) {
500 tevent_loop_once(test_ctx->be_ctx->ev);
504 assert_true(now + DELAY <= test_ctx->when);
505 assert_true(ptask->last_execution <= test_ctx->when);
513 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
519 mark_offline(test_ctx);
522 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
524 test_be_ptask_recv, test_ctx, "Test ptask", &ptask);
532 while (ptask->next_execution == next_execution && !test_ctx->done) {
533 tevent_loop_once(test_ctx->be_ctx->ev);
546 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
550 mark_offline(test_ctx);
552 will_return(be_add_online_cb, test_ctx);
553 will_return(be_add_offline_cb, test_ctx);
555 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
557 test_be_ptask_recv, test_ctx, "Test ptask", &ptask);
562 assert_true(test_ctx->add_online_cb_called);
563 assert_true(test_ctx->add_offline_cb_called);
565 while (ptask->enabled && !test_ctx->done) {
566 tevent_loop_once(test_ctx->be_ctx->ev);
570 assert_false(test_ctx->done);
579 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
583 mark_offline(test_ctx);
585 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
587 test_be_ptask_recv, test_ctx, "Test ptask", &ptask);
592 while (!test_ctx->done) {
593 tevent_loop_once(test_ctx->be_ctx->ev);
605 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
612 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
614 test_be_ptask_recv, test_ctx, "Test ptask", &ptask);
621 while (!test_ctx->done) {
622 tevent_loop_once(test_ctx->be_ctx->ev);
626 assert_true(now <= test_ctx->when);
627 assert_true(ptask->last_execution <= test_ctx->when);
638 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
643 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
645 test_be_ptask_recv, test_ctx, "Test ptask",
651 while (!test_ctx->done) {
653 tevent_loop_once(test_ctx->be_ctx->ev);
665 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
670 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
672 test_be_ptask_error_recv, test_ctx, "Test ptask",
678 while (!test_ctx->done) {
680 tevent_loop_once(test_ctx->be_ctx->ev);
692 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
697 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 1,
699 test_be_ptask_error_recv, test_ctx, "Test ptask",
706 while (!test_ctx->done && ptask->req == NULL) {
707 tevent_loop_once(test_ctx->be_ctx->ev);
711 while (!test_ctx->done && ptask->req != NULL) {
713 tevent_loop_once(test_ctx->be_ctx->ev);
716 assert_false(test_ctx->done);
726 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
734 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
736 test_be_ptask_recv, test_ctx, "Test ptask", &ptask);
744 while (!test_ctx->done) {
749 tevent_loop_once(test_ctx->be_ctx->ev);
753 assert_true(now_first <= test_ctx->when);
754 assert_true(ptask->last_execution <= test_ctx->when);
760 test_ctx->done = false;
765 while (!test_ctx->done) {
766 tevent_loop_once(test_ctx->be_ctx->ev);
770 assert_true(now_backoff + PERIOD <= test_ctx->when);
771 assert_true(ptask->last_execution <= test_ctx->when);
783 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
788 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
790 test_be_ptask_recv, test_ctx, "Test ptask", &ptask);
803 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
808 ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, TIMEOUT,
810 test_be_ptask_recv, test_ctx, "Test ptask", &ptask);
823 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
829 ret = be_ptask_create_sync(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
831 test_ctx, "Test ptask", &ptask);
836 while (!test_ctx->done) {
837 tevent_loop_once(test_ctx->be_ctx->ev);
841 assert_true(now <= test_ctx->when);
842 assert_true(ptask->last_execution <= test_ctx->when);
850 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
857 ret = be_ptask_create_sync(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
859 test_ctx, "Test ptask", &ptask);
866 while (!is_sync_ptask_finished(test_ctx, ptask)) {
867 tevent_loop_once(test_ctx->be_ctx->ev);
871 assert_true(now <= test_ctx->when);
872 assert_true(ptask->last_execution <= test_ctx->when);
883 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
888 ret = be_ptask_create_sync(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
891 test_ctx, "Test ptask", &ptask);
896 while (!is_sync_ptask_finished(test_ctx, ptask)) {
898 tevent_loop_once(test_ctx->be_ctx->ev);
910 struct test_ctx *test_ctx = (struct test_ctx *)(*state);
918 ret = be_ptask_create_sync(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, 0,
921 test_ctx, "Test ptask", &ptask);
929 while (!is_sync_ptask_finished(test_ctx, ptask)) {
934 tevent_loop_once(test_ctx->be_ctx->ev);
938 assert_true(now_first <= test_ctx->when);
939 assert_true(ptask->last_execution <= test_ctx->when);
945 test_ctx->done = false;
950 while (!is_sync_ptask_finished(test_ctx, ptask)) {
951 tevent_loop_once(test_ctx->be_ctx->ev);
955 assert_true(now_backoff + PERIOD <= test_ctx->when);
956 assert_true(ptask->last_execution <= test_ctx->when);