wolf SSL / wolfSSL

wolfSSL SSL/TLS library, support up to TLS1.3

Dependents:   CyaSSL-Twitter-OAuth4Tw Example-client-tls-cert TwitterReader TweetTest ... more

wolfcrypt/src/wolfevent.c@13:f67a6c6013ca, 2017-08-22 (annotated)

Committer:
wolfSSL
Date:
Tue Aug 22 10:48:22 2017 +0000
Revision:
13:f67a6c6013ca
Parent:
11:cee25a834751 
wolfSSL3.12.0 with TLS1.3

Who changed what in which revision?

UserRevisionLine numberNew contents of line
wolfSSL 11:cee25a834751 1 /* wolfevent.c
wolfSSL 11:cee25a834751 2 *
wolfSSL 11:cee25a834751 3 * Copyright (C) 2006-2016 wolfSSL Inc.
wolfSSL 11:cee25a834751 4 *
wolfSSL 11:cee25a834751 5 * This file is part of wolfSSL.
wolfSSL 11:cee25a834751 6 *
wolfSSL 11:cee25a834751 7 * wolfSSL is free software; you can redistribute it and/or modify
wolfSSL 11:cee25a834751 8 * it under the terms of the GNU General Public License as published by
wolfSSL 11:cee25a834751 9 * the Free Software Foundation; either version 2 of the License, or
wolfSSL 11:cee25a834751 10 * (at your option) any later version.
wolfSSL 11:cee25a834751 11 *
wolfSSL 11:cee25a834751 12 * wolfSSL is distributed in the hope that it will be useful,
wolfSSL 11:cee25a834751 13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
wolfSSL 11:cee25a834751 14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
wolfSSL 11:cee25a834751 15 * GNU General Public License for more details.
wolfSSL 11:cee25a834751 16 *
wolfSSL 11:cee25a834751 17 * You should have received a copy of the GNU General Public License
wolfSSL 11:cee25a834751 18 * along with this program; if not, write to the Free Software
wolfSSL 11:cee25a834751 19 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1335, USA
wolfSSL 11:cee25a834751 20 */
wolfSSL 11:cee25a834751 21
wolfSSL 11:cee25a834751 22 #ifdef HAVE_CONFIG_H
wolfSSL 11:cee25a834751 23 #include <config.h>
wolfSSL 11:cee25a834751 24 #endif
wolfSSL 11:cee25a834751 25
wolfSSL 11:cee25a834751 26 #include <wolfssl/wolfcrypt/settings.h>
wolfSSL 11:cee25a834751 27
wolfSSL 11:cee25a834751 28
wolfSSL 11:cee25a834751 29 #ifdef HAVE_WOLF_EVENT
wolfSSL 11:cee25a834751 30
wolfSSL 11:cee25a834751 31 #include <wolfssl/internal.h>
wolfSSL 11:cee25a834751 32 #include <wolfssl/error-ssl.h>
wolfSSL 11:cee25a834751 33 #include <wolfssl/wolfcrypt/error-crypt.h>
wolfSSL 11:cee25a834751 34
wolfSSL 11:cee25a834751 35 #include <wolfssl/wolfcrypt/wolfevent.h>
wolfSSL 11:cee25a834751 36
wolfSSL 11:cee25a834751 37
wolfSSL 11:cee25a834751 38 int wolfEvent_Init(WOLF_EVENT* event, WOLF_EVENT_TYPE type, void* context)
wolfSSL 11:cee25a834751 39 {
wolfSSL 11:cee25a834751 40 if (event == NULL) {
wolfSSL 11:cee25a834751 41 return BAD_FUNC_ARG;
wolfSSL 11:cee25a834751 42 }
wolfSSL 11:cee25a834751 43
wolfSSL 11:cee25a834751 44 if (event->pending) {
wolfSSL 11:cee25a834751 45 WOLFSSL_MSG("event already pending!");
wolfSSL 11:cee25a834751 46 return BAD_COND_E;
wolfSSL 11:cee25a834751 47 }
wolfSSL 11:cee25a834751 48
wolfSSL 11:cee25a834751 49 XMEMSET(event, 0, sizeof(WOLF_EVENT));
wolfSSL 11:cee25a834751 50 event->type = type;
wolfSSL 11:cee25a834751 51 event->context = context;
wolfSSL 11:cee25a834751 52
wolfSSL 11:cee25a834751 53 return 0;
wolfSSL 11:cee25a834751 54 }
wolfSSL 11:cee25a834751 55
wolfSSL 11:cee25a834751 56 int wolfEvent_Poll(WOLF_EVENT* event, WOLF_EVENT_FLAG flags)
wolfSSL 11:cee25a834751 57 {
wolfSSL 11:cee25a834751 58 int ret = BAD_COND_E;
wolfSSL 11:cee25a834751 59
wolfSSL 11:cee25a834751 60 /* Check hardware */
wolfSSL 11:cee25a834751 61 #ifdef WOLFSSL_ASYNC_CRYPT
wolfSSL 11:cee25a834751 62 if (event->type >= WOLF_EVENT_TYPE_ASYNC_FIRST &&
wolfSSL 11:cee25a834751 63 event->type <= WOLF_EVENT_TYPE_ASYNC_LAST)
wolfSSL 11:cee25a834751 64 {
wolfSSL 11:cee25a834751 65 ret = wolfAsync_EventPoll(event, flags);
wolfSSL 11:cee25a834751 66 }
wolfSSL 11:cee25a834751 67 #endif /* WOLFSSL_ASYNC_CRYPT */
wolfSSL 11:cee25a834751 68
wolfSSL 11:cee25a834751 69 return ret;
wolfSSL 11:cee25a834751 70 }
wolfSSL 11:cee25a834751 71
wolfSSL 11:cee25a834751 72 int wolfEventQueue_Init(WOLF_EVENT_QUEUE* queue)
wolfSSL 11:cee25a834751 73 {
wolfSSL 11:cee25a834751 74 int ret = 0;
wolfSSL 11:cee25a834751 75
wolfSSL 11:cee25a834751 76 if (queue == NULL) {
wolfSSL 11:cee25a834751 77 return BAD_FUNC_ARG;
wolfSSL 11:cee25a834751 78 }
wolfSSL 11:cee25a834751 79
wolfSSL 11:cee25a834751 80 XMEMSET(queue, 0, sizeof(WOLF_EVENT_QUEUE));
wolfSSL 11:cee25a834751 81 #ifndef SINGLE_THREADED
wolfSSL 11:cee25a834751 82 ret = wc_InitMutex(&queue->lock);
wolfSSL 11:cee25a834751 83 #endif
wolfSSL 11:cee25a834751 84 return ret;
wolfSSL 11:cee25a834751 85 }
wolfSSL 11:cee25a834751 86
wolfSSL 11:cee25a834751 87
wolfSSL 11:cee25a834751 88 int wolfEventQueue_Push(WOLF_EVENT_QUEUE* queue, WOLF_EVENT* event)
wolfSSL 11:cee25a834751 89 {
wolfSSL 11:cee25a834751 90 int ret;
wolfSSL 11:cee25a834751 91
wolfSSL 11:cee25a834751 92 if (queue == NULL || event == NULL) {
wolfSSL 11:cee25a834751 93 return BAD_FUNC_ARG;
wolfSSL 11:cee25a834751 94 }
wolfSSL 11:cee25a834751 95
wolfSSL 11:cee25a834751 96 #ifndef SINGLE_THREADED
wolfSSL 11:cee25a834751 97 if ((ret = wc_LockMutex(&queue->lock)) != 0) {
wolfSSL 11:cee25a834751 98 return ret;
wolfSSL 11:cee25a834751 99 }
wolfSSL 11:cee25a834751 100 #endif
wolfSSL 11:cee25a834751 101
wolfSSL 11:cee25a834751 102 /* Setup event */
wolfSSL 11:cee25a834751 103 event->next = NULL;
wolfSSL 11:cee25a834751 104 event->pending = 1;
wolfSSL 11:cee25a834751 105
wolfSSL 11:cee25a834751 106 ret = wolfEventQueue_Add(queue, event);
wolfSSL 11:cee25a834751 107
wolfSSL 11:cee25a834751 108 #ifndef SINGLE_THREADED
wolfSSL 11:cee25a834751 109 wc_UnLockMutex(&queue->lock);
wolfSSL 11:cee25a834751 110 #endif
wolfSSL 11:cee25a834751 111
wolfSSL 11:cee25a834751 112 return ret;
wolfSSL 11:cee25a834751 113 }
wolfSSL 11:cee25a834751 114
wolfSSL 11:cee25a834751 115 int wolfEventQueue_Pop(WOLF_EVENT_QUEUE* queue, WOLF_EVENT** event)
wolfSSL 11:cee25a834751 116 {
wolfSSL 11:cee25a834751 117 int ret = 0;
wolfSSL 11:cee25a834751 118
wolfSSL 11:cee25a834751 119 if (queue == NULL || event == NULL) {
wolfSSL 11:cee25a834751 120 return BAD_FUNC_ARG;
wolfSSL 11:cee25a834751 121 }
wolfSSL 11:cee25a834751 122
wolfSSL 11:cee25a834751 123 #ifndef SINGLE_THREADED
wolfSSL 11:cee25a834751 124 /* In single threaded mode "event_queue.lock" doesn't exist */
wolfSSL 11:cee25a834751 125 if ((ret = wc_LockMutex(&queue->lock)) != 0) {
wolfSSL 11:cee25a834751 126 return ret;
wolfSSL 11:cee25a834751 127 }
wolfSSL 11:cee25a834751 128 #endif
wolfSSL 11:cee25a834751 129
wolfSSL 11:cee25a834751 130 /* Pop first item off queue */
wolfSSL 11:cee25a834751 131 *event = queue->head;
wolfSSL 11:cee25a834751 132 ret = wolfEventQueue_Remove(queue, *event);
wolfSSL 11:cee25a834751 133
wolfSSL 11:cee25a834751 134 #ifndef SINGLE_THREADED
wolfSSL 11:cee25a834751 135 wc_UnLockMutex(&queue->lock);
wolfSSL 11:cee25a834751 136 #endif
wolfSSL 11:cee25a834751 137
wolfSSL 11:cee25a834751 138 return ret;
wolfSSL 11:cee25a834751 139 }
wolfSSL 11:cee25a834751 140
wolfSSL 11:cee25a834751 141 /* assumes queue is locked by caller */
wolfSSL 11:cee25a834751 142 int wolfEventQueue_Add(WOLF_EVENT_QUEUE* queue, WOLF_EVENT* event)
wolfSSL 11:cee25a834751 143 {
wolfSSL 11:cee25a834751 144 if (queue == NULL || event == NULL) {
wolfSSL 11:cee25a834751 145 return BAD_FUNC_ARG;
wolfSSL 11:cee25a834751 146 }
wolfSSL 11:cee25a834751 147
wolfSSL 11:cee25a834751 148 if (queue->tail == NULL) {
wolfSSL 11:cee25a834751 149 queue->head = event;
wolfSSL 11:cee25a834751 150 }
wolfSSL 11:cee25a834751 151 else {
wolfSSL 11:cee25a834751 152 queue->tail->next = event;
wolfSSL 11:cee25a834751 153 event->prev = queue->tail;
wolfSSL 11:cee25a834751 154 }
wolfSSL 11:cee25a834751 155 queue->tail = event; /* add to the end either way */
wolfSSL 11:cee25a834751 156 queue->count++;
wolfSSL 11:cee25a834751 157
wolfSSL 11:cee25a834751 158 return 0;
wolfSSL 11:cee25a834751 159 }
wolfSSL 11:cee25a834751 160
wolfSSL 11:cee25a834751 161 /* assumes queue is locked by caller */
wolfSSL 11:cee25a834751 162 int wolfEventQueue_Remove(WOLF_EVENT_QUEUE* queue, WOLF_EVENT* event)
wolfSSL 11:cee25a834751 163 {
wolfSSL 11:cee25a834751 164 int ret = 0;
wolfSSL 11:cee25a834751 165
wolfSSL 11:cee25a834751 166 if (queue == NULL || event == NULL) {
wolfSSL 11:cee25a834751 167 return BAD_FUNC_ARG;
wolfSSL 11:cee25a834751 168 }
wolfSSL 11:cee25a834751 169
wolfSSL 11:cee25a834751 170 if (event == queue->head && event == queue->tail) {
wolfSSL 11:cee25a834751 171 queue->head = NULL;
wolfSSL 11:cee25a834751 172 queue->tail = NULL;
wolfSSL 11:cee25a834751 173 }
wolfSSL 11:cee25a834751 174 else if (event == queue->head) {
wolfSSL 11:cee25a834751 175 queue->head = event->next;
wolfSSL 11:cee25a834751 176 queue->head->prev = NULL;
wolfSSL 11:cee25a834751 177 }
wolfSSL 11:cee25a834751 178 else if (event == queue->tail) {
wolfSSL 11:cee25a834751 179 queue->tail = event->prev;
wolfSSL 11:cee25a834751 180 queue->tail->next = NULL;
wolfSSL 11:cee25a834751 181 }
wolfSSL 11:cee25a834751 182 else {
wolfSSL 11:cee25a834751 183 WOLF_EVENT* next = event->next;
wolfSSL 11:cee25a834751 184 WOLF_EVENT* prev = event->prev;
wolfSSL 11:cee25a834751 185 next->prev = prev;
wolfSSL 11:cee25a834751 186 prev->next = next;
wolfSSL 11:cee25a834751 187 }
wolfSSL 11:cee25a834751 188 queue->count--;
wolfSSL 11:cee25a834751 189
wolfSSL 11:cee25a834751 190 return ret;
wolfSSL 11:cee25a834751 191 }
wolfSSL 11:cee25a834751 192
wolfSSL 11:cee25a834751 193 int wolfEventQueue_Poll(WOLF_EVENT_QUEUE* queue, void* context_filter,
wolfSSL 11:cee25a834751 194 WOLF_EVENT** events, int maxEvents, WOLF_EVENT_FLAG flags, int* eventCount)
wolfSSL 11:cee25a834751 195 {
wolfSSL 11:cee25a834751 196 WOLF_EVENT* event;
wolfSSL 11:cee25a834751 197 int ret = 0, count = 0;
wolfSSL 11:cee25a834751 198
wolfSSL 11:cee25a834751 199 if (queue == NULL) {
wolfSSL 11:cee25a834751 200 return BAD_FUNC_ARG;
wolfSSL 11:cee25a834751 201 }
wolfSSL 11:cee25a834751 202
wolfSSL 11:cee25a834751 203 #ifndef SINGLE_THREADED
wolfSSL 11:cee25a834751 204 /* In single threaded mode "event_queue.lock" doesn't exist */
wolfSSL 11:cee25a834751 205 if ((ret = wc_LockMutex(&queue->lock)) != 0) {
wolfSSL 11:cee25a834751 206 return ret;
wolfSSL 11:cee25a834751 207 }
wolfSSL 11:cee25a834751 208 #endif
wolfSSL 11:cee25a834751 209
wolfSSL 11:cee25a834751 210 /* itterate event queue */
wolfSSL 11:cee25a834751 211 for (event = queue->head; event != NULL; event = event->next)
wolfSSL 11:cee25a834751 212 {
wolfSSL 11:cee25a834751 213 /* optional filter based on context */
wolfSSL 11:cee25a834751 214 if (context_filter == NULL || event->context == context_filter) {
wolfSSL 11:cee25a834751 215
wolfSSL 11:cee25a834751 216 /* poll event */
wolfSSL 11:cee25a834751 217 ret = wolfEvent_Poll(event, flags);
wolfSSL 11:cee25a834751 218 if (ret < 0) break; /* exit for */
wolfSSL 11:cee25a834751 219
wolfSSL 11:cee25a834751 220 /* If event is done then process */
wolfSSL 11:cee25a834751 221 if (event->done) {
wolfSSL 11:cee25a834751 222 /* remove from queue */
wolfSSL 11:cee25a834751 223 ret = wolfEventQueue_Remove(queue, event);
wolfSSL 11:cee25a834751 224 if (ret < 0) break; /* exit for */
wolfSSL 11:cee25a834751 225
wolfSSL 11:cee25a834751 226 /* return pointer in 'events' arg */
wolfSSL 11:cee25a834751 227 if (events) {
wolfSSL 11:cee25a834751 228 events[count] = event; /* return pointer */
wolfSSL 11:cee25a834751 229 }
wolfSSL 11:cee25a834751 230 count++;
wolfSSL 11:cee25a834751 231
wolfSSL 11:cee25a834751 232 /* check to make sure our event list isn't full */
wolfSSL 11:cee25a834751 233 if (events && count >= maxEvents) {
wolfSSL 11:cee25a834751 234 break; /* exit for */
wolfSSL 11:cee25a834751 235 }
wolfSSL 11:cee25a834751 236 }
wolfSSL 11:cee25a834751 237 }
wolfSSL 11:cee25a834751 238 }
wolfSSL 11:cee25a834751 239
wolfSSL 11:cee25a834751 240 #ifndef SINGLE_THREADED
wolfSSL 11:cee25a834751 241 wc_UnLockMutex(&queue->lock);
wolfSSL 11:cee25a834751 242 #endif
wolfSSL 11:cee25a834751 243
wolfSSL 11:cee25a834751 244 /* return number of properly populated events */
wolfSSL 11:cee25a834751 245 if (eventCount) {
wolfSSL 11:cee25a834751 246 *eventCount = count;
wolfSSL 11:cee25a834751 247 }
wolfSSL 11:cee25a834751 248
wolfSSL 11:cee25a834751 249 return ret;
wolfSSL 11:cee25a834751 250 }
wolfSSL 11:cee25a834751 251
wolfSSL 11:cee25a834751 252 int wolfEventQueue_Count(WOLF_EVENT_QUEUE* queue)
wolfSSL 11:cee25a834751 253 {
wolfSSL 11:cee25a834751 254 int ret;
wolfSSL 11:cee25a834751 255
wolfSSL 11:cee25a834751 256 if (queue == NULL) {
wolfSSL 11:cee25a834751 257 return BAD_FUNC_ARG;
wolfSSL 11:cee25a834751 258 }
wolfSSL 11:cee25a834751 259
wolfSSL 11:cee25a834751 260 #ifndef SINGLE_THREADED
wolfSSL 11:cee25a834751 261 /* In single threaded mode "event_queue.lock" doesn't exist */
wolfSSL 11:cee25a834751 262 if ((ret = wc_LockMutex(&queue->lock)) != 0) {
wolfSSL 11:cee25a834751 263 return ret;
wolfSSL 11:cee25a834751 264 }
wolfSSL 11:cee25a834751 265 #endif
wolfSSL 11:cee25a834751 266
wolfSSL 11:cee25a834751 267 ret = queue->count;
wolfSSL 11:cee25a834751 268
wolfSSL 11:cee25a834751 269 #ifndef SINGLE_THREADED
wolfSSL 11:cee25a834751 270 wc_UnLockMutex(&queue->lock);
wolfSSL 11:cee25a834751 271 #endif
wolfSSL 11:cee25a834751 272
wolfSSL 11:cee25a834751 273 return ret;
wolfSSL 11:cee25a834751 274 }
wolfSSL 11:cee25a834751 275
wolfSSL 11:cee25a834751 276 void wolfEventQueue_Free(WOLF_EVENT_QUEUE* queue)
wolfSSL 11:cee25a834751 277 {
wolfSSL 11:cee25a834751 278 if (queue) {
wolfSSL 11:cee25a834751 279 #ifndef SINGLE_THREADED
wolfSSL 11:cee25a834751 280 wc_FreeMutex(&queue->lock);
wolfSSL 11:cee25a834751 281 #endif
wolfSSL 11:cee25a834751 282 }
wolfSSL 11:cee25a834751 283 }
wolfSSL 11:cee25a834751 284
wolfSSL 11:cee25a834751 285 #endif /* HAVE_WOLF_EVENT */
wolfSSL 11:cee25a834751 286