diff options
Diffstat (limited to 'source')
| -rw-r--r-- | source/kit/async_function.h | 36 | ||||
| -rw-r--r-- | source/test/unittests/async_function.test.c | 4 |
2 files changed, 20 insertions, 20 deletions
diff --git a/source/kit/async_function.h b/source/kit/async_function.h index 1791291..6bb2e83 100644 --- a/source/kit/async_function.h +++ b/source/kit/async_function.h @@ -8,10 +8,10 @@ extern "C" { #endif enum { - kit_af_request_execute = 0, - kit_af_request_resume = 1, - kit_af_request_join = 2, - kit_af_request_resume_and_join = 3 + KIT_AF_REQUEST_EXECUTE = 0, + KIT_AF_REQUEST_RESUME = 1, + KIT_AF_REQUEST_JOIN = 2, + KIT_AF_REQUEST_RESUME_AND_JOIN = 3 }; typedef struct { @@ -54,13 +54,13 @@ typedef struct { KIT_AF_DECL(name_) { \ struct name_##_coro_state_ *self = \ (struct name_##_coro_state_ *) self_void_; \ - if (request_ != kit_af_request_execute) { \ + if (request_ != KIT_AF_REQUEST_EXECUTE) { \ if (self->_context.execute != NULL) \ self->_context.execute(self->_context.state, self_void_, \ request_); \ - else if (request_ == kit_af_request_join || \ - request_ == kit_af_request_resume_and_join) \ - self->_state_machine(self_void_, kit_af_request_execute); \ + else if (request_ == KIT_AF_REQUEST_JOIN || \ + request_ == KIT_AF_REQUEST_RESUME_AND_JOIN) \ + self->_state_machine(self_void_, KIT_AF_REQUEST_EXECUTE); \ return; \ } \ switch (self->_index) { \ @@ -128,7 +128,7 @@ typedef struct { if ((promise_)._index != -1) { \ self->_index = KIT_AF_LINE_(); \ (promise_)._state_machine(&(promise_), \ - kit_af_request_resume_and_join); \ + KIT_AF_REQUEST_RESUME_AND_JOIN); \ } \ if ((promise_)._index != -1) \ return; \ @@ -140,7 +140,7 @@ typedef struct { if ((promise_)._index != -1) { \ self->_index = KIT_AF_LINE_(); \ (promise_)._state_machine(&(promise_), \ - kit_af_request_resume_and_join); \ + KIT_AF_REQUEST_RESUME_AND_JOIN); \ self->return_value = (promise_).return_value; \ return; \ } \ @@ -176,7 +176,7 @@ typedef struct { } while (0) #define KIT_AF_RESUME(promise_) \ - (promise_)._state_machine(&(promise_), kit_af_request_resume) + (promise_)._state_machine(&(promise_), KIT_AF_REQUEST_RESUME) #define KIT_AF_RESUME_N(promises_, size_) \ do { \ @@ -187,7 +187,7 @@ typedef struct { } while (0) #define KIT_AF_JOIN(promise_) \ - ((promise_)._state_machine(&(promise_), kit_af_request_join), \ + ((promise_)._state_machine(&(promise_), KIT_AF_REQUEST_JOIN), \ (promise_).return_value) #define KIT_AF_JOIN_N(promises_, size_) \ @@ -200,7 +200,7 @@ typedef struct { #define KIT_AF_RESUME_AND_JOIN(promise_) \ ((promise_)._state_machine(&(promise_), \ - kit_af_request_resume_and_join), \ + KIT_AF_REQUEST_RESUME_AND_JOIN), \ (promise_).return_value) #define KIT_AF_RESUME_AND_JOIN_N(promises_, size_) \ @@ -256,7 +256,7 @@ typedef struct { #define KIT_AF_EXECUTE(promise_) \ KIT_AF_INTERNAL(promise_)._state_machine((promise_), \ - kit_af_request_execute) + KIT_AF_REQUEST_EXECUTE) #ifndef KIT_DISABLE_SHORT_NAMES # ifndef KIT_DISABLE_AF_SELF_SHORTCUT @@ -264,10 +264,10 @@ typedef struct { # endif # define af_request kit_af_request -# define af_request_execute kit_af_request_execute -# define af_request_resume kit_af_request_resume -# define af_request_join kit_af_request_join -# define af_request_resume_and_join kit_af_request_resume_and_join +# define AF_REQUEST_EXECUTE KIT_AF_REQUEST_EXECUTE +# define AF_REQUEST_RESUME KIT_AF_REQUEST_RESUME +# define AF_REQUEST_JOIN KIT_AF_REQUEST_JOIN +# define AF_REQUEST_RESUME_AND_JOIN KIT_AF_REQUEST_RESUME_AND_JOIN # define af_void kit_af_void # define af_state_machine kit_af_state_machine # define af_execute kit_af_execute diff --git a/source/test/unittests/async_function.test.c b/source/test/unittests/async_function.test.c index 6d1f8d9..5adc0e7 100644 --- a/source/test/unittests/async_function.test.c +++ b/source/test/unittests/async_function.test.c @@ -71,13 +71,13 @@ STATIC_CORO(int, test_await_multiple, CORO_END void test_execute_lazy(void *_, void *coro, int request) { - if (request == af_request_resume) + if (request == AF_REQUEST_RESUME) return; AF_EXECUTE(coro); } void test_execute_immediate(void *_, void *coro, int request) { - if (request == af_request_join) + if (request == AF_REQUEST_JOIN) return; AF_EXECUTE(coro); } |