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 | # ifdef VBOX
|
---|
21 | # include <iprt/win/windows.h>
|
---|
22 | # else
|
---|
23 | # include <windows.h>
|
---|
24 | # endif
|
---|
25 | #endif
|
---|
26 |
|
---|
27 | #include "crypto/async.h"
|
---|
28 | #include <openssl/crypto.h>
|
---|
29 |
|
---|
30 | typedef struct async_ctx_st async_ctx;
|
---|
31 | typedef struct async_pool_st async_pool;
|
---|
32 |
|
---|
33 | #include "arch/async_win.h"
|
---|
34 | #include "arch/async_posix.h"
|
---|
35 | #include "arch/async_null.h"
|
---|
36 |
|
---|
37 | struct async_ctx_st {
|
---|
38 | async_fibre dispatcher;
|
---|
39 | ASYNC_JOB *currjob;
|
---|
40 | unsigned int blocked;
|
---|
41 | };
|
---|
42 |
|
---|
43 | struct async_job_st {
|
---|
44 | async_fibre fibrectx;
|
---|
45 | int (*func) (void *);
|
---|
46 | void *funcargs;
|
---|
47 | int ret;
|
---|
48 | int status;
|
---|
49 | ASYNC_WAIT_CTX *waitctx;
|
---|
50 | };
|
---|
51 |
|
---|
52 | struct fd_lookup_st {
|
---|
53 | const void *key;
|
---|
54 | OSSL_ASYNC_FD fd;
|
---|
55 | void *custom_data;
|
---|
56 | void (*cleanup)(ASYNC_WAIT_CTX *, const void *, OSSL_ASYNC_FD, void *);
|
---|
57 | int add;
|
---|
58 | int del;
|
---|
59 | struct fd_lookup_st *next;
|
---|
60 | };
|
---|
61 |
|
---|
62 | struct async_wait_ctx_st {
|
---|
63 | struct fd_lookup_st *fds;
|
---|
64 | size_t numadd;
|
---|
65 | size_t numdel;
|
---|
66 | };
|
---|
67 |
|
---|
68 | DEFINE_STACK_OF(ASYNC_JOB)
|
---|
69 |
|
---|
70 | struct async_pool_st {
|
---|
71 | STACK_OF(ASYNC_JOB) *jobs;
|
---|
72 | size_t curr_size;
|
---|
73 | size_t max_size;
|
---|
74 | };
|
---|
75 |
|
---|
76 | void async_local_cleanup(void);
|
---|
77 | void async_start_func(void);
|
---|
78 | async_ctx *async_get_ctx(void);
|
---|
79 |
|
---|
80 | void async_wait_ctx_reset_counts(ASYNC_WAIT_CTX *ctx);
|
---|
81 |
|
---|