Azure IoT / azure_c_shared_utility

Azure IoT common library

Dependents:   STM32F746_iothub_client_sample_mqtt f767zi_mqtt iothub_client_sample_amqp iothub_client_sample_http ... more

threadapi_rtx_mbed.cpp@1:9190c0f4d23a, 2016-04-24 (annotated)

Committer:
AzureIoTClient
Date:
Sun Apr 24 16:41:14 2016 -0700
Revision:
1:9190c0f4d23a
Parent:
0:fa2de1b79154
Child:
6:c55b013dfc2a
1.0.5

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Azure.IoT Build 0:fa2de1b79154 1 // Copyright (c) Microsoft. All rights reserved.
Azure.IoT Build 0:fa2de1b79154 2 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
Azure.IoT Build 0:fa2de1b79154 3
Azure.IoT Build 0:fa2de1b79154 4 #include <stdlib.h>
Azure.IoT Build 0:fa2de1b79154 5 #ifdef _CRTDBG_MAP_ALLOC
Azure.IoT Build 0:fa2de1b79154 6 #include <crtdbg.h>
Azure.IoT Build 0:fa2de1b79154 7 #endif
Azure.IoT Build 0:fa2de1b79154 8
Azure.IoT Build 0:fa2de1b79154 9 #include "azure_c_shared_utility/threadapi.h"
Azure.IoT Build 0:fa2de1b79154 10 #include "rtos.h"
Azure.IoT Build 0:fa2de1b79154 11 #include "azure_c_shared_utility/iot_logging.h"
Azure.IoT Build 0:fa2de1b79154 12
Azure.IoT Build 0:fa2de1b79154 13 DEFINE_ENUM_STRINGS(THREADAPI_RESULT, THREADAPI_RESULT_VALUES);
Azure.IoT Build 0:fa2de1b79154 14
Azure.IoT Build 0:fa2de1b79154 15 #define MAX_THREADS 4
Azure.IoT Build 0:fa2de1b79154 16 #define STACK_SIZE 0x4000
Azure.IoT Build 0:fa2de1b79154 17
Azure.IoT Build 0:fa2de1b79154 18 typedef struct _thread
Azure.IoT Build 0:fa2de1b79154 19 {
Azure.IoT Build 0:fa2de1b79154 20 Thread* thrd;
Azure.IoT Build 0:fa2de1b79154 21 osThreadId id;
Azure.IoT Build 0:fa2de1b79154 22 Queue<int, 1> result;
Azure.IoT Build 0:fa2de1b79154 23 } mbedThread;
Azure.IoT Build 0:fa2de1b79154 24 static mbedThread threads[MAX_THREADS] = { 0 };
Azure.IoT Build 0:fa2de1b79154 25
Azure.IoT Build 0:fa2de1b79154 26 typedef struct _create_param
Azure.IoT Build 0:fa2de1b79154 27 {
Azure.IoT Build 0:fa2de1b79154 28 THREAD_START_FUNC func;
Azure.IoT Build 0:fa2de1b79154 29 const void* arg;
Azure.IoT Build 0:fa2de1b79154 30 mbedThread *p_thread;
Azure.IoT Build 0:fa2de1b79154 31 } create_param;
Azure.IoT Build 0:fa2de1b79154 32
Azure.IoT Build 0:fa2de1b79154 33 static void thread_wrapper(const void* createParamArg)
Azure.IoT Build 0:fa2de1b79154 34 {
Azure.IoT Build 0:fa2de1b79154 35 const create_param* p = (const create_param*)createParamArg;
Azure.IoT Build 0:fa2de1b79154 36 p->p_thread->id = Thread::gettid();
Azure.IoT Build 0:fa2de1b79154 37 (*(p->func))((void*)p->arg);
Azure.IoT Build 0:fa2de1b79154 38 free((void*)p);
Azure.IoT Build 0:fa2de1b79154 39 }
Azure.IoT Build 0:fa2de1b79154 40
Azure.IoT Build 0:fa2de1b79154 41 THREADAPI_RESULT ThreadAPI_Create(THREAD_HANDLE* threadHandle, THREAD_START_FUNC func, void* arg)
Azure.IoT Build 0:fa2de1b79154 42 {
Azure.IoT Build 0:fa2de1b79154 43 THREADAPI_RESULT result;
Azure.IoT Build 0:fa2de1b79154 44 if ((threadHandle == NULL) ||
Azure.IoT Build 0:fa2de1b79154 45 (func == NULL))
Azure.IoT Build 0:fa2de1b79154 46 {
Azure.IoT Build 0:fa2de1b79154 47 result = THREADAPI_INVALID_ARG;
AzureIoTClient 1:9190c0f4d23a 48 LogError("(result = %s)", ENUM_TO_STRING(THREADAPI_RESULT, result));
Azure.IoT Build 0:fa2de1b79154 49 }
Azure.IoT Build 0:fa2de1b79154 50 else
Azure.IoT Build 0:fa2de1b79154 51 {
Azure.IoT Build 0:fa2de1b79154 52 size_t slot;
Azure.IoT Build 0:fa2de1b79154 53 for (slot = 0; slot < MAX_THREADS; slot++)
Azure.IoT Build 0:fa2de1b79154 54 {
Azure.IoT Build 0:fa2de1b79154 55 if (threads[slot].id == NULL)
Azure.IoT Build 0:fa2de1b79154 56 break;
Azure.IoT Build 0:fa2de1b79154 57 }
Azure.IoT Build 0:fa2de1b79154 58
Azure.IoT Build 0:fa2de1b79154 59 if (slot < MAX_THREADS)
Azure.IoT Build 0:fa2de1b79154 60 {
Azure.IoT Build 0:fa2de1b79154 61 create_param* param = (create_param*)malloc(sizeof(create_param));
Azure.IoT Build 0:fa2de1b79154 62 if (param != NULL)
Azure.IoT Build 0:fa2de1b79154 63 {
Azure.IoT Build 0:fa2de1b79154 64 param->func = func;
Azure.IoT Build 0:fa2de1b79154 65 param->arg = arg;
Azure.IoT Build 0:fa2de1b79154 66 param->p_thread = threads + slot;
Azure.IoT Build 0:fa2de1b79154 67 threads[slot].thrd = new Thread(thread_wrapper, param, osPriorityNormal, STACK_SIZE);
Azure.IoT Build 0:fa2de1b79154 68 *threadHandle = (THREAD_HANDLE)(threads + slot);
Azure.IoT Build 0:fa2de1b79154 69 result = THREADAPI_OK;
Azure.IoT Build 0:fa2de1b79154 70 }
Azure.IoT Build 0:fa2de1b79154 71 else
Azure.IoT Build 0:fa2de1b79154 72 {
Azure.IoT Build 0:fa2de1b79154 73 result = THREADAPI_NO_MEMORY;
AzureIoTClient 1:9190c0f4d23a 74 LogError("(result = %s)", ENUM_TO_STRING(THREADAPI_RESULT, result));
Azure.IoT Build 0:fa2de1b79154 75 }
Azure.IoT Build 0:fa2de1b79154 76 }
Azure.IoT Build 0:fa2de1b79154 77 else
Azure.IoT Build 0:fa2de1b79154 78 {
Azure.IoT Build 0:fa2de1b79154 79 result = THREADAPI_NO_MEMORY;
AzureIoTClient 1:9190c0f4d23a 80 LogError("(result = %s)", ENUM_TO_STRING(THREADAPI_RESULT, result));
Azure.IoT Build 0:fa2de1b79154 81 }
Azure.IoT Build 0:fa2de1b79154 82 }
Azure.IoT Build 0:fa2de1b79154 83
Azure.IoT Build 0:fa2de1b79154 84 return result;
Azure.IoT Build 0:fa2de1b79154 85 }
Azure.IoT Build 0:fa2de1b79154 86
Azure.IoT Build 0:fa2de1b79154 87 THREADAPI_RESULT ThreadAPI_Join(THREAD_HANDLE thr, int *res)
Azure.IoT Build 0:fa2de1b79154 88 {
Azure.IoT Build 0:fa2de1b79154 89 THREADAPI_RESULT result = THREADAPI_OK;
Azure.IoT Build 0:fa2de1b79154 90 mbedThread* p = (mbedThread*)thr;
Azure.IoT Build 0:fa2de1b79154 91 if (p)
Azure.IoT Build 0:fa2de1b79154 92 {
Azure.IoT Build 0:fa2de1b79154 93 osEvent evt = p->result.get();
Azure.IoT Build 0:fa2de1b79154 94 if (evt.status == osEventMessage) {
Azure.IoT Build 0:fa2de1b79154 95 Thread* t = p->thrd;
Azure.IoT Build 0:fa2de1b79154 96 if (res)
Azure.IoT Build 0:fa2de1b79154 97 {
Azure.IoT Build 0:fa2de1b79154 98 *res = (int)evt.value.p;
Azure.IoT Build 0:fa2de1b79154 99 }
Azure.IoT Build 0:fa2de1b79154 100 (void)t->terminate();
Azure.IoT Build 0:fa2de1b79154 101 }
Azure.IoT Build 0:fa2de1b79154 102 else
Azure.IoT Build 0:fa2de1b79154 103 {
Azure.IoT Build 0:fa2de1b79154 104 result = THREADAPI_ERROR;
AzureIoTClient 1:9190c0f4d23a 105 LogError("(result = %s)", ENUM_TO_STRING(THREADAPI_RESULT, result));
Azure.IoT Build 0:fa2de1b79154 106 }
Azure.IoT Build 0:fa2de1b79154 107 }
Azure.IoT Build 0:fa2de1b79154 108 else
Azure.IoT Build 0:fa2de1b79154 109 {
Azure.IoT Build 0:fa2de1b79154 110 result = THREADAPI_INVALID_ARG;
AzureIoTClient 1:9190c0f4d23a 111 LogError("(result = %s)", ENUM_TO_STRING(THREADAPI_RESULT, result));
Azure.IoT Build 0:fa2de1b79154 112 }
Azure.IoT Build 0:fa2de1b79154 113 return result;
Azure.IoT Build 0:fa2de1b79154 114 }
Azure.IoT Build 0:fa2de1b79154 115
Azure.IoT Build 0:fa2de1b79154 116 void ThreadAPI_Exit(int res)
Azure.IoT Build 0:fa2de1b79154 117 {
Azure.IoT Build 0:fa2de1b79154 118 mbedThread* p;
Azure.IoT Build 0:fa2de1b79154 119 for (p = threads; p < &threads[MAX_THREADS]; p++)
Azure.IoT Build 0:fa2de1b79154 120 {
Azure.IoT Build 0:fa2de1b79154 121 if (p->id == Thread::gettid())
Azure.IoT Build 0:fa2de1b79154 122 {
Azure.IoT Build 0:fa2de1b79154 123 p->result.put((int*)res);
Azure.IoT Build 0:fa2de1b79154 124 break;
Azure.IoT Build 0:fa2de1b79154 125 }
Azure.IoT Build 0:fa2de1b79154 126 }
Azure.IoT Build 0:fa2de1b79154 127 }
Azure.IoT Build 0:fa2de1b79154 128
Azure.IoT Build 0:fa2de1b79154 129 void ThreadAPI_Sleep(unsigned int millisec)
Azure.IoT Build 0:fa2de1b79154 130 {
Azure.IoT Build 0:fa2de1b79154 131 //
Azure.IoT Build 0:fa2de1b79154 132 // The timer on mbed seems to wrap around 65 seconds. Hmmm.
Azure.IoT Build 0:fa2de1b79154 133 // So we will do our waits in increments of 30 seconds.
Azure.IoT Build 0:fa2de1b79154 134 //
Azure.IoT Build 0:fa2de1b79154 135 const int thirtySeconds = 30000;
Azure.IoT Build 0:fa2de1b79154 136 int numberOfThirtySecondWaits = millisec / thirtySeconds;
Azure.IoT Build 0:fa2de1b79154 137 int remainderOfThirtySeconds = millisec % thirtySeconds;
Azure.IoT Build 0:fa2de1b79154 138 int i;
Azure.IoT Build 0:fa2de1b79154 139 for (i = 1; i <= numberOfThirtySecondWaits; i++)
Azure.IoT Build 0:fa2de1b79154 140 {
Azure.IoT Build 0:fa2de1b79154 141 Thread::wait(thirtySeconds);
Azure.IoT Build 0:fa2de1b79154 142 }
Azure.IoT Build 0:fa2de1b79154 143 Thread::wait(remainderOfThirtySeconds);
Azure.IoT Build 0:fa2de1b79154 144 }