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