PowLu/TencentOS-tiny
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update HAL_OS_tencentos_tiny.c

Browse Source
This commit is contained in:
David Lin
2020-04-26 21:12:08 +08:00
committed by GitHub
parent 1581cefe97
commit 061afcb959
1 changed files with 35 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

73
components/connectivity/qcloud-iot-explorer-sdk/port/TencentOS_tiny/HAL_OS_tencentos_tiny.c
View File

@@ -32,7 +32,6 @@ void HAL_SleepMs(_IN_ uint32_t ms)
(void)tos_sleep_hmsm(0,0,0, ms); (void)tos_sleep_hmsm(0,0,0, ms);
} }
void HAL_Printf(_IN_ const char *fmt, ...) void HAL_Printf(_IN_ const char *fmt, ...)
{ {
va_list args; va_list args;
@@ -61,15 +60,14 @@ int HAL_Vsnprintf(_IN_ char *str, _IN_ const int len, _IN_ const char *format, v
return vsnprintf(str, len, format, ap); return vsnprintf(str, len, format, ap);
} }
void *HAL_Malloc(_IN_ uint32_t size) void *HAL_Malloc(_IN_ uint32_t size)
{ {
return tos_mmheap_alloc(size); return tos_mmheap_alloc(size);
} }
void HAL_Free(_IN_ void *ptr) void HAL_Free(_IN_ void *ptr)
{ {
tos_mmheap_free(ptr); tos_mmheap_free(ptr);
} }
void *HAL_MutexCreate(void) void *HAL_MutexCreate(void)
@@ -88,7 +86,7 @@ void *HAL_MutexCreate(void)
void HAL_MutexDestroy(_IN_ void *mutex) void HAL_MutexDestroy(_IN_ void *mutex)
{ {
k_err_t ret; k_err_t ret;
if (K_ERR_NONE != (ret = tos_mutex_destroy((k_mutex_t *)mutex))) { if (K_ERR_NONE != (ret = tos_mutex_destroy((k_mutex_t *)mutex))) {
HAL_Printf("osal_mutex_destroy err, err:%d\n\r", ret); HAL_Printf("osal_mutex_destroy err, err:%d\n\r", ret);
@@ -108,24 +106,24 @@ void HAL_MutexLock(_IN_ void *mutex)
int HAL_MutexTryLock(_IN_ void *mutex) int HAL_MutexTryLock(_IN_ void *mutex)
{ {
k_err_t ret; k_err_t ret;
if (K_ERR_NONE != (ret = tos_mutex_pend_timed((k_mutex_t *)mutex, 0))) { if (K_ERR_NONE != (ret = tos_mutex_pend_timed((k_mutex_t *)mutex, 0))) {
HAL_Printf("osal_mutex_lock err, err:%d\n\r", ret); HAL_Printf("osal_mutex_lock err, err:%d\n\r", ret);
return (int)ret; return (int)ret;
} }
return 0; return 0;
} }
void HAL_MutexUnlock(_IN_ void *mutex) void HAL_MutexUnlock(_IN_ void *mutex)
{ {
k_err_t ret; k_err_t ret;
if (K_ERR_NONE != (ret = tos_mutex_post((k_mutex_t *)mutex))) { if (K_ERR_NONE != (ret = tos_mutex_post((k_mutex_t *)mutex))) {
HAL_Printf("osal_mutex_unlock err, err:%d\n\r", ret); HAL_Printf("osal_mutex_unlock err, err:%d\n\r", ret);
} }
} }
#if defined(PLATFORM_HAS_CMSIS) && defined(AT_TCP_ENABLED) #if defined(PLATFORM_HAS_CMSIS) && defined(AT_TCP_ENABLED)
@@ -135,53 +133,52 @@ void HAL_MutexUnlock(_IN_ void *mutex)
*/ */
void * HAL_ThreadCreate(uint16_t stack_size, int priority, char * taskname,void *(*fn)(void*), void* arg) void * HAL_ThreadCreate(uint16_t stack_size, int priority, char * taskname,void *(*fn)(void*), void* arg)
{ {
osThreadId thread_t = (osThreadId)HAL_Malloc(sizeof(osThreadId)); osThreadId thread_t = (osThreadId)HAL_Malloc(sizeof(osThreadId));
osThreadDef(taskname, (os_pthread)fn, (osPriority)priority, 0, stack_size); osThreadDef(taskname, (os_pthread)fn, (osPriority)priority, 0, stack_size);
thread_t = osThreadCreate(osThread(taskname), arg); thread_t = osThreadCreate(osThread(taskname), arg);
if(NULL == thread_t){ if(NULL == thread_t){
HAL_Printf("create thread fail\n\r"); HAL_Printf("create thread fail\n\r");
} }
return (void *)thread_t; return (void *)thread_t;
} }
int HAL_ThreadDestroy(void* threadId) int HAL_ThreadDestroy(void* threadId)
{ {
return osThreadTerminate(threadId); return osThreadTerminate(threadId);
} }
void *HAL_SemaphoreCreate(void) void *HAL_SemaphoreCreate(void)
{ {
return (void *)osSemaphoreCreate(NULL, 1); return (void *)osSemaphoreCreate(NULL, 1);
} }
void HAL_SemaphoreDestroy(void *sem) void HAL_SemaphoreDestroy(void *sem)
{ {
osStatus ret; osStatus ret;
ret = osSemaphoreDelete ((osSemaphoreId)sem); ret = osSemaphoreDelete ((osSemaphoreId)sem);
if(osOK != ret) if(osOK != ret)
{ {
HAL_Printf("HAL_SemaphoreDestroy err, err:%d\n\r",ret); HAL_Printf("HAL_SemaphoreDestroy err, err:%d\n\r",ret);
} }
} }
void HAL_SemaphorePost(void *sem) void HAL_SemaphorePost(void *sem)
{ {
osStatus ret; osStatus ret;
ret = osSemaphoreRelease ((osSemaphoreId) sem); ret = osSemaphoreRelease ((osSemaphoreId) sem);
if(osOK != ret) if(osOK != ret)
{ {
HAL_Printf("HAL_SemaphorePost err, err:%d\n\r",ret); HAL_Printf("HAL_SemaphorePost err, err:%d\n\r",ret);
} }
} }
int HAL_SemaphoreWait(void *sem, uint32_t timeout_ms) int HAL_SemaphoreWait(void *sem, uint32_t timeout_ms)
{ {
return osSemaphoreWait ((osSemaphoreId)sem, timeout_ms); return osSemaphoreWait ((osSemaphoreId)sem, timeout_ms);
} }
#endif #endif