TI's MQTT Demo with freertos CM4F

Dependencies:   mbed

Committer:
dflet
Date:
Thu Sep 03 14:07:01 2015 +0000
Revision:
0:1e7b5dd9edb4
First commit, it's been hanging around for a while. Updated SPI mode change 1 to 0.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
dflet 0:1e7b5dd9edb4 1 /*
dflet 0:1e7b5dd9edb4 2 * spawn.c - CC31xx/CC32xx Host Driver Implementation
dflet 0:1e7b5dd9edb4 3 *
dflet 0:1e7b5dd9edb4 4 * Copyright (C) 2014 Texas Instruments Incorporated - http://www.ti.com/
dflet 0:1e7b5dd9edb4 5 *
dflet 0:1e7b5dd9edb4 6 *
dflet 0:1e7b5dd9edb4 7 * Redistribution and use in source and binary forms, with or without
dflet 0:1e7b5dd9edb4 8 * modification, are permitted provided that the following conditions
dflet 0:1e7b5dd9edb4 9 * are met:
dflet 0:1e7b5dd9edb4 10 *
dflet 0:1e7b5dd9edb4 11 * Redistributions of source code must retain the above copyright
dflet 0:1e7b5dd9edb4 12 * notice, this list of conditions and the following disclaimer.
dflet 0:1e7b5dd9edb4 13 *
dflet 0:1e7b5dd9edb4 14 * Redistributions in binary form must reproduce the above copyright
dflet 0:1e7b5dd9edb4 15 * notice, this list of conditions and the following disclaimer in the
dflet 0:1e7b5dd9edb4 16 * documentation and/or other materials provided with the
dflet 0:1e7b5dd9edb4 17 * distribution.
dflet 0:1e7b5dd9edb4 18 *
dflet 0:1e7b5dd9edb4 19 * Neither the name of Texas Instruments Incorporated nor the names of
dflet 0:1e7b5dd9edb4 20 * its contributors may be used to endorse or promote products derived
dflet 0:1e7b5dd9edb4 21 * from this software without specific prior written permission.
dflet 0:1e7b5dd9edb4 22 *
dflet 0:1e7b5dd9edb4 23 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
dflet 0:1e7b5dd9edb4 24 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
dflet 0:1e7b5dd9edb4 25 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
dflet 0:1e7b5dd9edb4 26 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
dflet 0:1e7b5dd9edb4 27 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
dflet 0:1e7b5dd9edb4 28 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
dflet 0:1e7b5dd9edb4 29 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
dflet 0:1e7b5dd9edb4 30 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
dflet 0:1e7b5dd9edb4 31 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
dflet 0:1e7b5dd9edb4 32 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
dflet 0:1e7b5dd9edb4 33 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
dflet 0:1e7b5dd9edb4 34 *
dflet 0:1e7b5dd9edb4 35 */
dflet 0:1e7b5dd9edb4 36
dflet 0:1e7b5dd9edb4 37
dflet 0:1e7b5dd9edb4 38
dflet 0:1e7b5dd9edb4 39 /*****************************************************************************/
dflet 0:1e7b5dd9edb4 40 /* Include files */
dflet 0:1e7b5dd9edb4 41 /*****************************************************************************/
dflet 0:1e7b5dd9edb4 42 #include "cc3100_simplelink.h"
dflet 0:1e7b5dd9edb4 43
dflet 0:1e7b5dd9edb4 44 #include "cc3100_spawn.h"
dflet 0:1e7b5dd9edb4 45
dflet 0:1e7b5dd9edb4 46 #if (defined (SL_PLATFORM_MULTI_THREADED)) && (!defined (SL_PLATFORM_EXTERNAL_SPAWN))
dflet 0:1e7b5dd9edb4 47
dflet 0:1e7b5dd9edb4 48 namespace mbed_cc3100 {
dflet 0:1e7b5dd9edb4 49
dflet 0:1e7b5dd9edb4 50 #define _SL_MAX_INTERNAL_SPAWN_ENTRIES 10
dflet 0:1e7b5dd9edb4 51
dflet 0:1e7b5dd9edb4 52 cc3100 _cc3100(PC_13, PC_6, PE_5, PE_4, PE_6, SPI(PB_5, PB_4, PB_3));
dflet 0:1e7b5dd9edb4 53
dflet 0:1e7b5dd9edb4 54
dflet 0:1e7b5dd9edb4 55 typedef struct _SlInternalSpawnEntry_t {
dflet 0:1e7b5dd9edb4 56 _SlSpawnEntryFunc_t pEntry;
dflet 0:1e7b5dd9edb4 57 void* pValue;
dflet 0:1e7b5dd9edb4 58 struct _SlInternalSpawnEntry_t* pNext;
dflet 0:1e7b5dd9edb4 59 } _SlInternalSpawnEntry_t;
dflet 0:1e7b5dd9edb4 60
dflet 0:1e7b5dd9edb4 61 typedef struct {
dflet 0:1e7b5dd9edb4 62 _SlInternalSpawnEntry_t SpawnEntries[_SL_MAX_INTERNAL_SPAWN_ENTRIES];
dflet 0:1e7b5dd9edb4 63 _SlInternalSpawnEntry_t* pFree;
dflet 0:1e7b5dd9edb4 64 _SlInternalSpawnEntry_t* pWaitForExe;
dflet 0:1e7b5dd9edb4 65 _SlInternalSpawnEntry_t* pLastInWaitList;
dflet 0:1e7b5dd9edb4 66 _SlSyncObj_t SyncObj;
dflet 0:1e7b5dd9edb4 67 _SlLockObj_t LockObj;
dflet 0:1e7b5dd9edb4 68 } _SlInternalSpawnCB_t;
dflet 0:1e7b5dd9edb4 69
dflet 0:1e7b5dd9edb4 70 _SlInternalSpawnCB_t g_SlInternalSpawnCB;
dflet 0:1e7b5dd9edb4 71
dflet 0:1e7b5dd9edb4 72 //cc3100_spawn::cc3100_spawn()
dflet 0:1e7b5dd9edb4 73 //{
dflet 0:1e7b5dd9edb4 74
dflet 0:1e7b5dd9edb4 75 //}
dflet 0:1e7b5dd9edb4 76
dflet 0:1e7b5dd9edb4 77 //cc3100_spawn::~cc3100_spawn()
dflet 0:1e7b5dd9edb4 78 //{
dflet 0:1e7b5dd9edb4 79
dflet 0:1e7b5dd9edb4 80 //}
dflet 0:1e7b5dd9edb4 81
dflet 0:1e7b5dd9edb4 82
dflet 0:1e7b5dd9edb4 83 void /*cc3100_spawn::*/_SlInternalSpawnTaskEntry()
dflet 0:1e7b5dd9edb4 84 {
dflet 0:1e7b5dd9edb4 85 int16_t i;
dflet 0:1e7b5dd9edb4 86 _SlInternalSpawnEntry_t* pEntry;
dflet 0:1e7b5dd9edb4 87 uint8_t LastEntry;
dflet 0:1e7b5dd9edb4 88
dflet 0:1e7b5dd9edb4 89 /* create and lock the locking object. lock in order to avoid race condition
dflet 0:1e7b5dd9edb4 90 on the first creation */
dflet 0:1e7b5dd9edb4 91 sl_LockObjCreate(&g_SlInternalSpawnCB.LockObj,"SlSpawnProtect");
dflet 0:1e7b5dd9edb4 92 sl_LockObjLock(&g_SlInternalSpawnCB.LockObj,SL_OS_NO_WAIT);
dflet 0:1e7b5dd9edb4 93
dflet 0:1e7b5dd9edb4 94 /* create and clear the sync object */
dflet 0:1e7b5dd9edb4 95 sl_SyncObjCreate(&g_SlInternalSpawnCB.SyncObj,"SlSpawnSync");
dflet 0:1e7b5dd9edb4 96 sl_SyncObjWait(&g_SlInternalSpawnCB.SyncObj,SL_OS_NO_WAIT);
dflet 0:1e7b5dd9edb4 97
dflet 0:1e7b5dd9edb4 98 g_SlInternalSpawnCB.pFree = &g_SlInternalSpawnCB.SpawnEntries[0];
dflet 0:1e7b5dd9edb4 99 g_SlInternalSpawnCB.pWaitForExe = NULL;
dflet 0:1e7b5dd9edb4 100 g_SlInternalSpawnCB.pLastInWaitList = NULL;
dflet 0:1e7b5dd9edb4 101
dflet 0:1e7b5dd9edb4 102 /* create the link list between the entries */
dflet 0:1e7b5dd9edb4 103 for (i=0 ; i<_SL_MAX_INTERNAL_SPAWN_ENTRIES - 1 ; i++) {
dflet 0:1e7b5dd9edb4 104 g_SlInternalSpawnCB.SpawnEntries[i].pNext = &g_SlInternalSpawnCB.SpawnEntries[i+1];
dflet 0:1e7b5dd9edb4 105 g_SlInternalSpawnCB.SpawnEntries[i].pEntry = NULL;
dflet 0:1e7b5dd9edb4 106 }
dflet 0:1e7b5dd9edb4 107 g_SlInternalSpawnCB.SpawnEntries[i].pNext = NULL;
dflet 0:1e7b5dd9edb4 108
dflet 0:1e7b5dd9edb4 109 _cc3100._driver._SlDrvObjUnLock(&g_SlInternalSpawnCB.LockObj);
dflet 0:1e7b5dd9edb4 110
dflet 0:1e7b5dd9edb4 111
dflet 0:1e7b5dd9edb4 112 /* here we ready to execute entries */
dflet 0:1e7b5dd9edb4 113
dflet 0:1e7b5dd9edb4 114 while (TRUE) {
dflet 0:1e7b5dd9edb4 115 sl_SyncObjWait(&g_SlInternalSpawnCB.SyncObj,SL_OS_WAIT_FOREVER);
dflet 0:1e7b5dd9edb4 116 /* go over all entries that already waiting for execution */
dflet 0:1e7b5dd9edb4 117 LastEntry = FALSE;
dflet 0:1e7b5dd9edb4 118 do {
dflet 0:1e7b5dd9edb4 119 /* get entry to execute */
dflet 0:1e7b5dd9edb4 120 _cc3100._driver._SlDrvObjLockWaitForever(&g_SlInternalSpawnCB.LockObj);
dflet 0:1e7b5dd9edb4 121
dflet 0:1e7b5dd9edb4 122 pEntry = g_SlInternalSpawnCB.pWaitForExe;
dflet 0:1e7b5dd9edb4 123 if ( NULL == pEntry ) {
dflet 0:1e7b5dd9edb4 124 _cc3100._driver._SlDrvObjUnLock(&g_SlInternalSpawnCB.LockObj);
dflet 0:1e7b5dd9edb4 125 break;
dflet 0:1e7b5dd9edb4 126 }
dflet 0:1e7b5dd9edb4 127 g_SlInternalSpawnCB.pWaitForExe = pEntry->pNext;
dflet 0:1e7b5dd9edb4 128 if (pEntry == g_SlInternalSpawnCB.pLastInWaitList) {
dflet 0:1e7b5dd9edb4 129 g_SlInternalSpawnCB.pLastInWaitList = NULL;
dflet 0:1e7b5dd9edb4 130 LastEntry = TRUE;
dflet 0:1e7b5dd9edb4 131 }
dflet 0:1e7b5dd9edb4 132
dflet 0:1e7b5dd9edb4 133 _cc3100._driver._SlDrvObjUnLock(&g_SlInternalSpawnCB.LockObj);
dflet 0:1e7b5dd9edb4 134
dflet 0:1e7b5dd9edb4 135
dflet 0:1e7b5dd9edb4 136 /* pEntry could be null in case that the sync was already set by some
dflet 0:1e7b5dd9edb4 137 of the entries during execution of earlier entry */
dflet 0:1e7b5dd9edb4 138 if (NULL != pEntry) {
dflet 0:1e7b5dd9edb4 139 pEntry->pEntry(pEntry->pValue);
dflet 0:1e7b5dd9edb4 140 /* free the entry */
dflet 0:1e7b5dd9edb4 141 _cc3100._driver._SlDrvObjLockWaitForever(&g_SlInternalSpawnCB.LockObj);
dflet 0:1e7b5dd9edb4 142
dflet 0:1e7b5dd9edb4 143 pEntry->pNext = g_SlInternalSpawnCB.pFree;
dflet 0:1e7b5dd9edb4 144 g_SlInternalSpawnCB.pFree = pEntry;
dflet 0:1e7b5dd9edb4 145
dflet 0:1e7b5dd9edb4 146
dflet 0:1e7b5dd9edb4 147 if (NULL != g_SlInternalSpawnCB.pWaitForExe) {
dflet 0:1e7b5dd9edb4 148 /* new entry received meanwhile */
dflet 0:1e7b5dd9edb4 149 LastEntry = FALSE;
dflet 0:1e7b5dd9edb4 150 }
dflet 0:1e7b5dd9edb4 151
dflet 0:1e7b5dd9edb4 152 _cc3100._driver._SlDrvObjUnLock(&g_SlInternalSpawnCB.LockObj);
dflet 0:1e7b5dd9edb4 153
dflet 0:1e7b5dd9edb4 154 }
dflet 0:1e7b5dd9edb4 155
dflet 0:1e7b5dd9edb4 156 } while (!LastEntry);
dflet 0:1e7b5dd9edb4 157 }
dflet 0:1e7b5dd9edb4 158 }
dflet 0:1e7b5dd9edb4 159
dflet 0:1e7b5dd9edb4 160
dflet 0:1e7b5dd9edb4 161 int16_t /*cc3100_spawn::*/_SlInternalSpawn(_SlSpawnEntryFunc_t pEntry , void* pValue , uint32_t flags)
dflet 0:1e7b5dd9edb4 162 {
dflet 0:1e7b5dd9edb4 163 int16_t Res = 0;
dflet 0:1e7b5dd9edb4 164 _SlInternalSpawnEntry_t* pSpawnEntry;
dflet 0:1e7b5dd9edb4 165
dflet 0:1e7b5dd9edb4 166 if (NULL == pEntry) {
dflet 0:1e7b5dd9edb4 167 Res = -1;
dflet 0:1e7b5dd9edb4 168 } else {
dflet 0:1e7b5dd9edb4 169 _cc3100._driver._SlDrvObjLockWaitForever(&g_SlInternalSpawnCB.LockObj);
dflet 0:1e7b5dd9edb4 170
dflet 0:1e7b5dd9edb4 171 pSpawnEntry = g_SlInternalSpawnCB.pFree;
dflet 0:1e7b5dd9edb4 172 g_SlInternalSpawnCB.pFree = pSpawnEntry->pNext;
dflet 0:1e7b5dd9edb4 173
dflet 0:1e7b5dd9edb4 174 pSpawnEntry->pEntry = pEntry;
dflet 0:1e7b5dd9edb4 175 pSpawnEntry->pValue = pValue;
dflet 0:1e7b5dd9edb4 176 pSpawnEntry->pNext = NULL;
dflet 0:1e7b5dd9edb4 177
dflet 0:1e7b5dd9edb4 178 if (NULL == g_SlInternalSpawnCB.pWaitForExe) {
dflet 0:1e7b5dd9edb4 179 g_SlInternalSpawnCB.pWaitForExe = pSpawnEntry;
dflet 0:1e7b5dd9edb4 180 g_SlInternalSpawnCB.pLastInWaitList = pSpawnEntry;
dflet 0:1e7b5dd9edb4 181 } else {
dflet 0:1e7b5dd9edb4 182 g_SlInternalSpawnCB.pLastInWaitList->pNext = pSpawnEntry;
dflet 0:1e7b5dd9edb4 183 g_SlInternalSpawnCB.pLastInWaitList = pSpawnEntry;
dflet 0:1e7b5dd9edb4 184 }
dflet 0:1e7b5dd9edb4 185
dflet 0:1e7b5dd9edb4 186 _cc3100._driver._SlDrvObjUnLock(&g_SlInternalSpawnCB.LockObj);
dflet 0:1e7b5dd9edb4 187
dflet 0:1e7b5dd9edb4 188 /* this sync is called after releasing the lock object to avoid unnecessary context switches */
dflet 0:1e7b5dd9edb4 189 _cc3100._driver._SlDrvSyncObjSignal(&g_SlInternalSpawnCB.SyncObj);
dflet 0:1e7b5dd9edb4 190 }
dflet 0:1e7b5dd9edb4 191
dflet 0:1e7b5dd9edb4 192 return Res;
dflet 0:1e7b5dd9edb4 193 }
dflet 0:1e7b5dd9edb4 194
dflet 0:1e7b5dd9edb4 195 }//namespace mbed_cc3100
dflet 0:1e7b5dd9edb4 196
dflet 0:1e7b5dd9edb4 197 #endif//SL_PLATFORM_MULTI_THREADED
dflet 0:1e7b5dd9edb4 198