sys_mbox_t sys_mbox_new(int size)\r
{\r
xQueueHandle mbox;\r
- \r
+\r
( void ) size;\r
- \r
+\r
mbox = xQueueCreate( archMESG_QUEUE_LENGTH, sizeof( void * ) );\r
\r
#if SYS_STATS\r
#if SYS_STATS\r
lwip_stats.sys.mbox.err++;\r
#endif /* SYS_STATS */\r
- \r
+\r
// TODO notify the user of failure.\r
}\r
\r
else {\r
// could not post, queue must be full\r
result = ERR_MEM;\r
- \r
+\r
#if SYS_STATS\r
lwip_stats.sys.mbox.err++;\r
#endif /* SYS_STATS */\r
- \r
+\r
}\r
\r
return result;\r
{\r
msg = &dummyptr;\r
}\r
- \r
+\r
if ( timeout != 0 )\r
{\r
if ( pdTRUE == xQueueReceive( mbox, &(*msg), timeout / portTICK_RATE_MS ) )\r
{\r
EndTime = xTaskGetTickCount();\r
Elapsed = (EndTime - StartTime) * portTICK_RATE_MS;\r
- \r
+\r
return ( Elapsed );\r
}\r
else // timed out blocking for message\r
{\r
*msg = NULL;\r
- \r
+\r
return SYS_ARCH_TIMEOUT;\r
}\r
}\r
while( pdTRUE != xQueueReceive( mbox, &(*msg), portMAX_DELAY ) ){} // time is arbitrary\r
EndTime = xTaskGetTickCount();\r
Elapsed = (EndTime - StartTime) * portTICK_RATE_MS;\r
- \r
- return ( Elapsed ); // return time blocked TODO test \r
+\r
+ return ( Elapsed ); // return time blocked TODO test\r
}\r
}\r
\r
xSemaphoreHandle xSemaphore;\r
\r
vSemaphoreCreateBinary( xSemaphore );\r
- \r
+\r
if( xSemaphore == NULL )\r
{\r
- \r
+\r
#if SYS_STATS\r
++lwip_stats.sys.sem.err;\r
#endif /* SYS_STATS */\r
- \r
+\r
return SYS_SEM_NULL; // TODO need assert\r
}\r
- \r
+\r
if(count == 0) // Means it can't be taken\r
{\r
xSemaphoreTake(xSemaphore,1);\r
lwip_stats.sys.sem.max = lwip_stats.sys.sem.used;\r
}\r
#endif /* SYS_STATS */\r
- \r
+\r
return xSemaphore;\r
}\r
\r
{\r
EndTime = xTaskGetTickCount();\r
Elapsed = (EndTime - StartTime) * portTICK_RATE_MS;\r
- \r
- return (Elapsed); // return time blocked TODO test \r
+\r
+ return (Elapsed); // return time blocked TODO test\r
}\r
else\r
{\r
EndTime = xTaskGetTickCount();\r
Elapsed = (EndTime - StartTime) * portTICK_RATE_MS;\r
\r
- return ( Elapsed ); // return time blocked \r
- \r
+ return ( Elapsed ); // return time blocked\r
+\r
}\r
}\r
\r
#if SYS_STATS\r
--lwip_stats.sys.sem.used;\r
#endif /* SYS_STATS */\r
- \r
+\r
vQueueDelete( sem );\r
}\r
\r
\r
if ( s_nextthread < SYS_THREAD_MAX )\r
{\r
- result = xTaskCreate( thread, ( signed portCHAR * ) name, stacksize, arg, prio, &CreatedTask );\r
+ result = xTaskCreate( thread, name, stacksize, arg, prio, &CreatedTask );\r
\r
// For each task created, store the task handle (pid) in the timers array.\r
// This scheme doesn't allow for threads to be deleted\r
* Prints an assertion messages and aborts execution.\r
*/\r
void sys_assert( const char *msg )\r
-{ \r
+{\r
( void ) msg;\r
/*FSL:only needed for debugging\r
printf(msg);\r