Revision cd0cba58 src/urt_node.c
src/urt_node.c | ||
---|---|---|
51 | 51 |
void _main(void* arg) |
52 | 52 |
{ |
53 | 53 |
urt_osEventMask_t mask; |
54 |
urt_osEventFlags_t flag; //TODO: flag from core here
|
|
54 |
urt_osEventFlags_t flag = 0;
|
|
55 | 55 |
urtEventRegister(urtCoreGetEvtSource(), &localNode.listener, mask, flag); |
56 | 56 |
if (localNode.setupcallback != NULL) |
57 | 57 |
{ |
58 | 58 |
mask = localNode.setupcallback(&localNode, arg); |
59 |
if (mask /*TODO: check single bits from mask to find out if bit for core is 1 */)
|
|
59 |
if (mask == urtCoreGetEventMask())
|
|
60 | 60 |
{ |
61 | 61 |
urtCoreStopNodes(URT_STATUS_NODE_INVALEVTMASK); |
62 | 62 |
} |
... | ... | |
75 | 75 |
if (terminated /*TODO: replace with function*/) |
76 | 76 |
{ |
77 | 77 |
urt_osEventMask_t temp = urtEventWait(mask, URT_EVENT_WAIT_ONE, URT_DELAY_INFINITE); |
78 |
if (temp /*TODO: check single bits from mask to find out if bit for core is 1 */)
|
|
78 |
if (temp == urtCoreGetEventMask())
|
|
79 | 79 |
{ |
80 | 80 |
localNode.loopcallback(&localNode, mask, arg); |
81 | 81 |
#if (URT_CFG_PUBSUB_PROFILING || URT_CFG_RPC_PROFILING) |
82 | 82 |
localNode.loops++; |
83 | 83 |
#endif /* URT_CFG_PUBSUB_PROFILING || URT_CFG_RPC_PROFILING */ |
84 |
if (mask /*TODO: check single bits from mask to find out if bit for core is 1 */)
|
|
84 |
if (mask == urtCoreGetEventMask())
|
|
85 | 85 |
{ |
86 | 86 |
urtCoreStopNodes(URT_STATUS_NODE_INVALEVTMASK); |
87 | 87 |
} |
Also available in: Unified diff