Further improvements to ASYNC_WAIT_CTX_clear_fd
[openssl.git] / crypto / async / async_locl.h
1 /*
2  * Copyright 2015-2016 The OpenSSL Project Authors. All Rights Reserved.
3  *
4  * Licensed under the OpenSSL license (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 <internal/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 };
63
64 DEFINE_STACK_OF(ASYNC_JOB)
65
66 struct async_pool_st {
67     STACK_OF(ASYNC_JOB) *jobs;
68     size_t curr_size;
69     size_t max_size;
70 };
71
72 void async_local_cleanup(void);
73 void async_start_func(void);
74 async_ctx *async_get_ctx(void);
75
76 void async_wait_ctx_reset_counts(ASYNC_WAIT_CTX *ctx);
77