crypto/async/async_locl.h

   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