diff options
| author | Sumit Bose <sbose@redhat.com> | 2016-01-18 13:20:16 +0100 |
|---|---|---|
| committer | Jakub Hrozek <jhrozek@redhat.com> | 2016-01-19 17:42:11 +0100 |
| commit | e89c2cb5ec77d57ed93952dae08df51738834faf (patch) | |
| tree | 452ae93b861fd9e61f5a2d164149d97294cea7f2 | |
| parent | 9dcc7dbf04466cd8cd90aa0bb8acbebef9aca832 (diff) | |
| download | sssd-e89c2cb5ec77d57ed93952dae08df51738834faf.tar.gz sssd-e89c2cb5ec77d57ed93952dae08df51738834faf.tar.xz sssd-e89c2cb5ec77d57ed93952dae08df51738834faf.zip | |
DP_TASK: add be_ptask_get_timeout()
Reviewed-by: Jakub Hrozek <jhrozek@redhat.com>
| -rw-r--r-- | src/providers/dp_ptask.c | 5 | ||||
| -rw-r--r-- | src/providers/dp_ptask.h | 1 | ||||
| -rw-r--r-- | src/tests/cmocka/test_be_ptask.c | 22 |
3 files changed, 28 insertions, 0 deletions
diff --git a/src/providers/dp_ptask.c b/src/providers/dp_ptask.c index 51800ab5..3ebb134b 100644 --- a/src/providers/dp_ptask.c +++ b/src/providers/dp_ptask.c @@ -384,6 +384,11 @@ time_t be_ptask_get_period(struct be_ptask *task) return task->period; } +time_t be_ptask_get_timeout(struct be_ptask *task) +{ + return task->timeout; +} + struct be_ptask_sync_ctx { be_ptask_sync_t fn; void *pvt; diff --git a/src/providers/dp_ptask.h b/src/providers/dp_ptask.h index 1b931010..3b975536 100644 --- a/src/providers/dp_ptask.h +++ b/src/providers/dp_ptask.h @@ -126,5 +126,6 @@ void be_ptask_disable(struct be_ptask *task); void be_ptask_destroy(struct be_ptask **task); time_t be_ptask_get_period(struct be_ptask *task); +time_t be_ptask_get_timeout(struct be_ptask *task); #endif /* _DP_PTASK_H_ */ diff --git a/src/tests/cmocka/test_be_ptask.c b/src/tests/cmocka/test_be_ptask.c index a0daaf96..cbf61e81 100644 --- a/src/tests/cmocka/test_be_ptask.c +++ b/src/tests/cmocka/test_be_ptask.c @@ -33,6 +33,7 @@ #define DELAY 2 #define PERIOD 1 +#define TIMEOUT 123 #define new_test(test) \ cmocka_unit_test_setup_teardown(test_ ## test, test_setup, test_teardown) @@ -795,6 +796,26 @@ void test_be_ptask_get_period(void **state) assert_null(ptask); } +void test_be_ptask_get_timeout(void **state) +{ + struct test_ctx *test_ctx = (struct test_ctx *)(*state); + struct be_ptask *ptask = NULL; + time_t out_timeout; + errno_t ret; + + ret = be_ptask_create(test_ctx, test_ctx->be_ctx, PERIOD, 0, 0, 0, TIMEOUT, + BE_PTASK_OFFLINE_SKIP, 0, test_be_ptask_send, + test_be_ptask_recv, test_ctx, "Test ptask", &ptask); + assert_int_equal(ret, ERR_OK); + assert_non_null(ptask); + + out_timeout = be_ptask_get_timeout(ptask); + assert_true(TIMEOUT == out_timeout); + + be_ptask_destroy(&ptask); + assert_null(ptask); +} + void test_be_ptask_create_sync(void **state) { struct test_ctx *test_ctx = (struct test_ctx *)(*state); @@ -970,6 +991,7 @@ int main(int argc, const char *argv[]) new_test(be_ptask_reschedule_timeout), new_test(be_ptask_reschedule_backoff), new_test(be_ptask_get_period), + new_test(be_ptask_get_timeout), new_test(be_ptask_create_sync), new_test(be_ptask_sync_reschedule_ok), new_test(be_ptask_sync_reschedule_error), |