Skip to content

async: add callback method #218

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
gaozhangfei wants to merge 1 commit into
base: master
Choose a base branch
from
Open

async: add callback method #218

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
47 changes: 47 additions & 0 deletions src/uadk_async.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,13 @@ static void uadk_e_set_async_poll_state(int state)
static void async_fd_cleanup(ASYNC_WAIT_CTX *ctx, const void *key,
OSSL_ASYNC_FD readfd, void *custom)
{
# if OPENSSL_VERSION_NUMBER >= 0x30000000
int (*callback)(void *arg);
void *args;

if (ASYNC_WAIT_CTX_get_callback(ctx, &callback, &args))
return;
# endif
close(readfd);
}

Expand All @@ -52,6 +59,10 @@ int async_setup_async_event_notification(struct async_op *op)
ASYNC_WAIT_CTX *waitctx;
void *custom = NULL;
OSSL_ASYNC_FD efd;
# if OPENSSL_VERSION_NUMBER >= 0x30000000
int (*callback)(void *arg);
void *args;
# endif

memset(op, 0, sizeof(struct async_op));
op->job = ASYNC_get_current_job();
Expand All @@ -62,6 +73,11 @@ int async_setup_async_event_notification(struct async_op *op)
if (!waitctx)
return UADK_E_FAIL;

# if OPENSSL_VERSION_NUMBER >= 0x30000000
if (ASYNC_WAIT_CTX_get_callback(waitctx, &callback, &args))
return UADK_E_SUCCESS;
# endif

if (!ASYNC_WAIT_CTX_get_fd(waitctx, uadk_async_key, &efd, &custom)) {
efd = eventfd(0, EFD_NONBLOCK);
if (efd == -1)
Expand All @@ -84,6 +100,10 @@ int async_clear_async_event_notification(void)
void *custom = NULL;
OSSL_ASYNC_FD efd;
ASYNC_JOB *job;
# if OPENSSL_VERSION_NUMBER >= 0x30000000
int (*callback)(void *arg);
void *args;
#endif

job = ASYNC_get_current_job();
if (!job)
Expand All @@ -93,6 +113,10 @@ int async_clear_async_event_notification(void)
if (!waitctx)
return UADK_E_FAIL;

# if OPENSSL_VERSION_NUMBER >= 0x30000000
if (ASYNC_WAIT_CTX_get_callback(waitctx, &callback, &args))
return UADK_E_SUCCESS;
#endif
if (!ASYNC_WAIT_CTX_get_changed_fds(waitctx, NULL, &num_add_fds, NULL, &num_del_fds))
return UADK_E_FAIL;

Expand Down Expand Up @@ -257,6 +281,11 @@ int async_pause_job(void *ctx, struct async_op *op, enum task_type type)
void *custom;
uint64_t buf;
int ret;
# if OPENSSL_VERSION_NUMBER >= 0x30000000
int callback_set = 0;
int (*callback)(void *arg);
void *args;
#endif

ret = async_add_poll_task(ctx, op, type);
if (!ret)
Expand All @@ -266,10 +295,18 @@ int async_pause_job(void *ctx, struct async_op *op, enum task_type type)
if (!waitctx)
return UADK_E_FAIL;

# if OPENSSL_VERSION_NUMBER >= 0x30000000
if (ASYNC_WAIT_CTX_get_callback(waitctx, &callback, &args))
callback_set = 1;
#endif
do {
if (!ASYNC_pause_job())
return UADK_E_FAIL;

# if OPENSSL_VERSION_NUMBER >= 0x30000000
if (callback_set)
return UADK_E_SUCCESS;
#endif
ret = ASYNC_WAIT_CTX_get_fd(waitctx, uadk_async_key, &efd, &custom);
if (ret <= 0)
continue;
Expand All @@ -292,11 +329,21 @@ int async_wake_job(ASYNC_JOB *job)
uint64_t buf = 1;
void *custom;
int ret;
# if OPENSSL_VERSION_NUMBER >= 0x30000000
int (*callback)(void *arg);
void *args;
#endif

waitctx = ASYNC_get_wait_ctx(job);
if (!waitctx)
return UADK_E_FAIL;

# if OPENSSL_VERSION_NUMBER >= 0x30000000
if (ASYNC_WAIT_CTX_get_callback(waitctx, &callback, &args)) {
(*callback)(args);
return UADK_E_SUCCESS;
}
#endif
ret = ASYNC_WAIT_CTX_get_fd(waitctx, uadk_async_key, &efd, &custom);
if (ret > 0) {
if (write(efd, &buf, sizeof(uint64_t)) == -1) {
Expand Down