20 portContext->
event =
false;
47 nodeContext->
semaphore = dispatch_semaphore_create(1);
54 nodeContext->
outputEvents = (
bool *)calloc(outputEventCount,
sizeof(
bool));
83 free(portContext->
data);
102 dispatch_release(nodeContext->
semaphore);
118 portContext->
event = event;
126 portContext->
data = data;
142 return portContext->
event;
150 return portContext->
data;
283 vector<unsigned long> *executingEventIds =
static_cast< vector<unsigned long> *
>(nodeContext->
executingEventIds);
284 executingEventIds->clear();
285 executingEventIds->push_back(eventId);
295 vector<unsigned long> *executingEventIds =
static_cast< vector<unsigned long> *
>(nodeContext->
executingEventIds);
296 if (! executingEventIds->empty())
297 executingEventIds->push_back(eventId);
308 vector<unsigned long> *executingEventIds =
static_cast< vector<unsigned long> *
>(nodeContext->
executingEventIds);
309 auto found = find(executingEventIds->begin(), executingEventIds->end(), eventId);
310 if (found != executingEventIds->end())
312 executingEventIds->erase(found);
313 return executingEventIds->empty();
326 vector<unsigned long> *executingEventIds =
static_cast< vector<unsigned long> *
>(nodeContext->
executingEventIds);
327 return executingEventIds->at(0);