9f5a87fd66
Reviewed-by: Matt Caswell <matt@openssl.org> Reviewed-by: Paul Yang <yang.yang@baishancloud.com> Signed-off-by: Ping Yu <ping.yu@intel.com> Signed-off-by: Steven Linsell <stevenx.linsell@intel.com> (Merged from https://github.com/openssl/openssl/pull/7573)
80 lines
1.9 KiB
C
80 lines
1.9 KiB
C
/*
|
|
* Copyright 2015-2016 The OpenSSL Project Authors. All Rights Reserved.
|
|
*
|
|
* Licensed under the Apache License 2.0 (the "License"). You may not use
|
|
* this file except in compliance with the License. You can obtain a copy
|
|
* in the file LICENSE in the source distribution or at
|
|
* https://www.openssl.org/source/license.html
|
|
*/
|
|
|
|
/*
|
|
* Must do this before including any header files, because on MacOS/X <stlib.h>
|
|
* includes <signal.h> which includes <ucontext.h>
|
|
*/
|
|
#if defined(__APPLE__) && defined(__MACH__) && !defined(_XOPEN_SOURCE)
|
|
# define _XOPEN_SOURCE /* Otherwise incomplete ucontext_t structure */
|
|
# pragma GCC diagnostic ignored "-Wdeprecated-declarations"
|
|
#endif
|
|
|
|
#if defined(_WIN32)
|
|
# include <windows.h>
|
|
#endif
|
|
|
|
#include "internal/async.h"
|
|
#include <openssl/crypto.h>
|
|
|
|
typedef struct async_ctx_st async_ctx;
|
|
typedef struct async_pool_st async_pool;
|
|
|
|
#include "arch/async_win.h"
|
|
#include "arch/async_posix.h"
|
|
#include "arch/async_null.h"
|
|
|
|
struct async_ctx_st {
|
|
async_fibre dispatcher;
|
|
ASYNC_JOB *currjob;
|
|
unsigned int blocked;
|
|
};
|
|
|
|
struct async_job_st {
|
|
async_fibre fibrectx;
|
|
int (*func) (void *);
|
|
void *funcargs;
|
|
int ret;
|
|
int status;
|
|
ASYNC_WAIT_CTX *waitctx;
|
|
};
|
|
|
|
struct fd_lookup_st {
|
|
const void *key;
|
|
OSSL_ASYNC_FD fd;
|
|
void *custom_data;
|
|
void (*cleanup)(ASYNC_WAIT_CTX *, const void *, OSSL_ASYNC_FD, void *);
|
|
int add;
|
|
int del;
|
|
struct fd_lookup_st *next;
|
|
};
|
|
|
|
struct async_wait_ctx_st {
|
|
struct fd_lookup_st *fds;
|
|
size_t numadd;
|
|
size_t numdel;
|
|
ASYNC_callback_fn callback;
|
|
void *callback_arg;
|
|
int status;
|
|
};
|
|
|
|
DEFINE_STACK_OF(ASYNC_JOB)
|
|
|
|
struct async_pool_st {
|
|
STACK_OF(ASYNC_JOB) *jobs;
|
|
size_t curr_size;
|
|
size_t max_size;
|
|
};
|
|
|
|
void async_local_cleanup(void);
|
|
void async_start_func(void);
|
|
async_ctx *async_get_ctx(void);
|
|
|
|
void async_wait_ctx_reset_counts(ASYNC_WAIT_CTX *ctx);
|
|
|