]>
Commit | Line | Data |
---|---|---|
50108304 MC |
1 | /* crypto/async/arch/async_win.c */ |
2 | /* | |
3 | * Written by Matt Caswell (matt@openssl.org) for the OpenSSL project. | |
4 | */ | |
5 | /* ==================================================================== | |
6 | * Copyright (c) 2015 The OpenSSL Project. All rights reserved. | |
7 | * | |
8 | * Redistribution and use in source and binary forms, with or without | |
9 | * modification, are permitted provided that the following conditions | |
10 | * are met: | |
11 | * | |
12 | * 1. Redistributions of source code must retain the above copyright | |
13 | * notice, this list of conditions and the following disclaimer. | |
14 | * | |
15 | * 2. Redistributions in binary form must reproduce the above copyright | |
16 | * notice, this list of conditions and the following disclaimer in | |
17 | * the documentation and/or other materials provided with the | |
18 | * distribution. | |
19 | * | |
20 | * 3. All advertising materials mentioning features or use of this | |
21 | * software must display the following acknowledgment: | |
22 | * "This product includes software developed by the OpenSSL Project | |
23 | * for use in the OpenSSL Toolkit. (http://www.OpenSSL.org/)" | |
24 | * | |
25 | * 4. The names "OpenSSL Toolkit" and "OpenSSL Project" must not be used to | |
26 | * endorse or promote products derived from this software without | |
27 | * prior written permission. For written permission, please contact | |
28 | * licensing@OpenSSL.org. | |
29 | * | |
30 | * 5. Products derived from this software may not be called "OpenSSL" | |
31 | * nor may "OpenSSL" appear in their names without prior written | |
32 | * permission of the OpenSSL Project. | |
33 | * | |
34 | * 6. Redistributions of any form whatsoever must retain the following | |
35 | * acknowledgment: | |
36 | * "This product includes software developed by the OpenSSL Project | |
37 | * for use in the OpenSSL Toolkit (http://www.OpenSSL.org/)" | |
38 | * | |
39 | * THIS SOFTWARE IS PROVIDED BY THE OpenSSL PROJECT ``AS IS'' AND ANY | |
40 | * EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | |
41 | * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR | |
42 | * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE OpenSSL PROJECT OR | |
43 | * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | |
44 | * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT | |
45 | * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | |
46 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) | |
47 | * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, | |
48 | * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) | |
49 | * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED | |
50 | * OF THE POSSIBILITY OF SUCH DAMAGE. | |
51 | * ==================================================================== | |
52 | */ | |
53 | ||
54 | #include "async_win.h" | |
55 | ||
56 | #ifdef ASYNC_WIN | |
57 | ||
58 | # include <windows.h> | |
d63de0eb MC |
59 | # include "internal/cryptlib.h" |
60 | ||
61 | struct winpool { | |
62 | STACK_OF(ASYNC_JOB) *pool; | |
63 | size_t curr_size; | |
64 | size_t max_size; | |
65 | }; | |
50108304 | 66 | |
636ca4ff | 67 | void async_start_func(void); |
50108304 | 68 | |
636ca4ff | 69 | int async_fibre_init_dispatcher(async_fibre *fibre) |
50108304 MC |
70 | { |
71 | LPVOID dispatcher; | |
72 | ||
73 | dispatcher = | |
74 | (LPVOID) CRYPTO_get_thread_local(CRYPTO_THREAD_LOCAL_ASYNC_DISPATCH); | |
e38565f5 | 75 | if (dispatcher == NULL) { |
50108304 MC |
76 | fibre->fibre = ConvertThreadToFiber(NULL); |
77 | CRYPTO_set_thread_local(CRYPTO_THREAD_LOCAL_ASYNC_DISPATCH, | |
78 | (void *)fibre->fibre); | |
79 | } else { | |
80 | fibre->fibre = dispatcher; | |
81 | } | |
82 | return 1; | |
83 | } | |
84 | ||
636ca4ff | 85 | VOID CALLBACK async_start_func_win(PVOID unused) |
50108304 | 86 | { |
636ca4ff | 87 | async_start_func(); |
50108304 MC |
88 | } |
89 | ||
2b2c78d4 | 90 | int async_pipe(OSSL_ASYNC_FD *pipefds) |
d63de0eb | 91 | { |
2b2c78d4 MC |
92 | if (CreatePipe(&pipefds[0], &pipefds[1], NULL, 256) == 0) |
93 | return 0; | |
d63de0eb | 94 | |
2b2c78d4 | 95 | return 1; |
d63de0eb MC |
96 | } |
97 | ||
2b2c78d4 | 98 | int async_write1(OSSL_ASYNC_FD fd, const void *buf) |
d63de0eb | 99 | { |
2b2c78d4 MC |
100 | DWORD numwritten = 0; |
101 | ||
102 | if (WriteFile(fd, buf, 1, &numwritten, NULL) && numwritten == 1) | |
d63de0eb MC |
103 | return 1; |
104 | ||
105 | return 0; | |
106 | } | |
107 | ||
2b2c78d4 | 108 | int async_read1(OSSL_ASYNC_FD fd, void *buf) |
d63de0eb | 109 | { |
2b2c78d4 MC |
110 | DWORD numread = 0; |
111 | ||
112 | if (ReadFile(fd, buf, 1, &numread, NULL) && numread == 1) | |
d63de0eb MC |
113 | return 1; |
114 | ||
115 | return 0; | |
116 | } | |
117 | ||
118 | STACK_OF(ASYNC_JOB) *async_get_pool(void) | |
119 | { | |
120 | struct winpool *pool; | |
121 | pool = (struct winpool *) | |
122 | CRYPTO_get_thread_local(CRYPTO_THREAD_LOCAL_ASYNC_POOL); | |
123 | return pool->pool; | |
124 | } | |
125 | ||
126 | ||
127 | int async_set_pool(STACK_OF(ASYNC_JOB) *poolin, size_t curr_size, | |
128 | size_t max_size) | |
129 | { | |
130 | struct winpool *pool; | |
131 | pool = OPENSSL_malloc(sizeof *pool); | |
e38565f5 | 132 | if (pool == NULL) |
d63de0eb MC |
133 | return 0; |
134 | ||
135 | pool->pool = poolin; | |
136 | pool->curr_size = curr_size; | |
137 | pool->max_size = max_size; | |
138 | CRYPTO_set_thread_local(CRYPTO_THREAD_LOCAL_ASYNC_POOL, (void *)pool); | |
139 | return 1; | |
140 | } | |
141 | ||
142 | void async_increment_pool_size(void) | |
143 | { | |
144 | struct winpool *pool; | |
145 | pool = (struct winpool *) | |
146 | CRYPTO_get_thread_local(CRYPTO_THREAD_LOCAL_ASYNC_POOL); | |
147 | pool->curr_size++; | |
148 | } | |
149 | ||
150 | void async_release_job_to_pool(ASYNC_JOB *job) | |
151 | { | |
152 | struct winpool *pool; | |
153 | pool = (struct winpool *) | |
154 | CRYPTO_get_thread_local(CRYPTO_THREAD_LOCAL_ASYNC_POOL); | |
155 | sk_ASYNC_JOB_push(pool->pool, job); | |
156 | } | |
157 | ||
158 | size_t async_pool_max_size(void) | |
159 | { | |
160 | struct winpool *pool; | |
161 | pool = (struct winpool *) | |
162 | CRYPTO_get_thread_local(CRYPTO_THREAD_LOCAL_ASYNC_POOL); | |
163 | return pool->max_size; | |
164 | } | |
165 | ||
166 | void async_release_pool(void) | |
167 | { | |
168 | struct winpool *pool; | |
169 | pool = (struct winpool *) | |
170 | CRYPTO_get_thread_local(CRYPTO_THREAD_LOCAL_ASYNC_POOL); | |
171 | sk_ASYNC_JOB_free(pool->pool); | |
172 | OPENSSL_free(pool); | |
173 | CRYPTO_set_thread_local(CRYPTO_THREAD_LOCAL_ASYNC_POOL, NULL); | |
174 | } | |
175 | ||
176 | int async_pool_can_grow(void) | |
177 | { | |
178 | struct winpool *pool; | |
179 | pool = (struct winpool *) | |
180 | CRYPTO_get_thread_local(CRYPTO_THREAD_LOCAL_ASYNC_POOL); | |
181 | return (pool->max_size == 0) || (pool->curr_size < pool->max_size); | |
182 | } | |
183 | ||
50108304 | 184 | #endif |