1 | /* |
2 | * Copyright 2015-2016 The OpenSSL Project Authors. All Rights Reserved. |
3 | * |
4 | * Licensed under the Apache License 2.0 (the "License"). You may not use |
5 | * this file except in compliance with the License. You can obtain a copy |
6 | * in the file LICENSE in the source distribution or at |
7 | * https://www.openssl.org/source/license.html |
8 | */ |
9 | |
10 | /* |
11 | * Must do this before including any header files, because on MacOS/X <stlib.h> |
12 | * includes <signal.h> which includes <ucontext.h> |
13 | */ |
14 | #if defined(__APPLE__) && defined(__MACH__) && !defined(_XOPEN_SOURCE) |
15 | # define _XOPEN_SOURCE /* Otherwise incomplete ucontext_t structure */ |
16 | # pragma GCC diagnostic ignored "-Wdeprecated-declarations" |
17 | #endif |
18 | |
19 | #if defined(_WIN32) |
20 | # include <windows.h> |
21 | #endif |
22 | |
23 | #include "crypto/async.h" |
24 | #include <openssl/crypto.h> |
25 | |
26 | typedef struct async_ctx_st async_ctx; |
27 | typedef struct async_pool_st async_pool; |
28 | |
29 | #include "arch/async_win.h" |
30 | #include "arch/async_posix.h" |
31 | #include "arch/async_null.h" |
32 | |
33 | struct async_ctx_st { |
34 | async_fibre dispatcher; |
35 | ASYNC_JOB *currjob; |
36 | unsigned int blocked; |
37 | }; |
38 | |
39 | struct async_job_st { |
40 | async_fibre fibrectx; |
41 | int (*func) (void *); |
42 | void *funcargs; |
43 | int ret; |
44 | int status; |
45 | ASYNC_WAIT_CTX *waitctx; |
46 | }; |
47 | |
48 | struct fd_lookup_st { |
49 | const void *key; |
50 | OSSL_ASYNC_FD fd; |
51 | void *custom_data; |
52 | void (*cleanup)(ASYNC_WAIT_CTX *, const void *, OSSL_ASYNC_FD, void *); |
53 | int add; |
54 | int del; |
55 | struct fd_lookup_st *next; |
56 | }; |
57 | |
58 | struct async_wait_ctx_st { |
59 | struct fd_lookup_st *fds; |
60 | size_t numadd; |
61 | size_t numdel; |
62 | ASYNC_callback_fn callback; |
63 | void *callback_arg; |
64 | int status; |
65 | }; |
66 | |
67 | DEFINE_STACK_OF(ASYNC_JOB) |
68 | |
69 | struct async_pool_st { |
70 | STACK_OF(ASYNC_JOB) *jobs; |
71 | size_t curr_size; |
72 | size_t max_size; |
73 | }; |
74 | |
75 | void async_local_cleanup(void); |
76 | void async_start_func(void); |
77 | async_ctx *async_get_ctx(void); |
78 | |
79 | void async_wait_ctx_reset_counts(ASYNC_WAIT_CTX *ctx); |
80 | |
81 | |