From e89c2cb5ec77d57ed93952dae08df51738834faf Mon Sep 17 00:00:00 2001 From: Sumit Bose Date: Jan 19 2016 16:42:11 +0000 Subject: DP_TASK: add be_ptask_get_timeout() Reviewed-by: Jakub Hrozek --- diff --git a/src/providers/dp_ptask.c b/src/providers/dp_ptask.c index 51800ab..3ebb134 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 1b93101..3b97553 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 a0daaf9..cbf61e8 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),