13 #include <condition_variable>
21 portContext->
event =
false;
48 nodeContext->
nodeMutex =
new std::mutex();
56 nodeContext->
outputEvents = (
bool *)calloc(outputEventCount,
sizeof(
bool));
85 free(portContext->
data);
103 delete static_cast<std::mutex *
>(nodeContext->
nodeMutex);
118 portContext->
event = event;
126 portContext->
data = data;
142 return portContext->
event;
150 return portContext->
data;
275 vector<unsigned long> *executingEventIds =
static_cast< vector<unsigned long> *
>(nodeContext->
executingEventIds);
276 executingEventIds->clear();
277 executingEventIds->push_back(eventId);
287 vector<unsigned long> *executingEventIds =
static_cast< vector<unsigned long> *
>(nodeContext->
executingEventIds);
288 if (! executingEventIds->empty())
289 executingEventIds->push_back(eventId);
300 vector<unsigned long> *executingEventIds =
static_cast< vector<unsigned long> *
>(nodeContext->
executingEventIds);
301 auto found = find(executingEventIds->begin(), executingEventIds->end(), eventId);
302 if (found != executingEventIds->end())
304 executingEventIds->erase(found);
305 return executingEventIds->empty();
318 vector<unsigned long> *executingEventIds =
static_cast< vector<unsigned long> *
>(nodeContext->
executingEventIds);
319 return executingEventIds->at(0);