Revision 33aa05c5 src/urt_core.c
| src/urt_core.c | ||
|---|---|---|
| 128 | 128 |
{
|
| 129 | 129 |
urtThreadStart(node->thread); |
| 130 | 130 |
node = node->next; |
| 131 |
urtThreadMSleep(100); //TODO: delete |
|
| 132 | 131 |
} |
| 133 | 132 |
urtMutexUnlock(&core._lock); |
| 134 | 133 |
return; |
| ... | ... | |
| 208 | 207 |
urt_osEventFlags_t flag = URT_EVENTFLAG_TERMINATE; |
| 209 | 208 |
urtEventSourceBroadcast(&core._evtSource, flag); |
| 210 | 209 |
urtMutexUnlock(&core._lock); |
| 211 |
if (priorityBoosted) |
|
| 210 |
if (priorityBoosted) {
|
|
| 212 | 211 |
core._nodes->thread->prio = oldPrio; |
| 212 |
} |
|
| 213 | 213 |
return URT_STATUS_OK; |
| 214 | 214 |
} |
| 215 | 215 |
else |
| ... | ... | |
| 256 | 256 |
* |
| 257 | 257 |
* @return Returns a pointer to the requested service. Returns NULL if no service matches the given ID. |
| 258 | 258 |
*/ |
| 259 |
# if (URT_CFG_PUBSUB_ENABLED)
|
|
| 259 |
#if (URT_CFG_PUBSUB_ENABLED == true)
|
|
| 260 | 260 |
|
| 261 | 261 |
/** |
| 262 | 262 |
* @brief Append topic to core's list of topics. |
| ... | ... | |
| 295 | 295 |
else |
| 296 | 296 |
return NULL; |
| 297 | 297 |
} |
| 298 |
# endif /* URT_CFG_PUBSUB_ENABLED */
|
|
| 298 |
#endif /* URT_CFG_PUBSUB_ENABLED */ |
|
| 299 | 299 |
|
| 300 | 300 |
|
| 301 | 301 |
# if (URT_CFG_RPC_ENABLED) |
| ... | ... | |
| 327 | 327 |
urt_service_t* urtCoreGetService(urt_serviceid_t id) {return urt_service_t;}
|
| 328 | 328 |
# endif /* URT_CFG_RPC_ENABLED */ |
| 329 | 329 |
|
| 330 |
#if (URT_CFG_PUBSUB_QOS_DEADLINECHECKS) |
|
| 330 |
#if (URT_CFG_PUBSUB_QOS_DEADLINECHECKS == true)
|
|
| 331 | 331 |
urt_osTimerCallback_t urtCoreCallbackDefault(void* params) |
| 332 | 332 |
{
|
| 333 | 333 |
urtMutexLock(&core._lock); |
Also available in: Unified diff