VuoRuntimePersistentState.cc

Go to the documentation of this file.

 
#include "VuoRuntimePersistentState.hh"
 
#include "VuoCompositionDiff.hh"
#include "VuoNodeRegistry.hh"
#include "VuoNodeSynchronization.hh"
#include "VuoRuntimeCommunicator.hh"
#include "VuoRuntimeState.hh"
#include "VuoThreadManager.hh"
 
VuoRuntimePersistentState::VuoRuntimePersistentState(const char *workingDirectory)
{
    this->workingDirectory = (strlen(workingDirectory) > 0 ? workingDirectory : getCurrentWorkingDirectory());
 
    lastEventId = 0;
 
    _isStopRequested = false;
 
    finiCallbackQueue = dispatch_queue_create("org.vuo.runtime.finiCallback", NULL);
 
    triggerWorkersScheduled = dispatch_group_create();
 
    compositionDiff = new VuoCompositionDiff();
    nodeRegistry = new VuoNodeRegistry(this);
    communicator = new VuoRuntimeCommunicator(this);
    threadManager = new VuoThreadManager();
    nodeSynchronization = new VuoNodeSynchronization();
}
 
VuoRuntimePersistentState::~VuoRuntimePersistentState(void)
{
    dispatch_release(finiCallbackQueue);
    dispatch_release(triggerWorkersScheduled);
 
    delete compositionDiff;
    delete nodeRegistry;
    delete communicator;
    delete threadManager;
    delete nodeSynchronization;
}
 
string VuoRuntimePersistentState::getCurrentWorkingDirectory(void)
{
    // Keep consistent with VuoGetWorkingDirectory().
    char currentWorkingDirectory[PATH_MAX+1];
    getcwd(currentWorkingDirectory, PATH_MAX+1);
    return currentWorkingDirectory;
}
 
char * VuoRuntimePersistentState::getWorkingDirectory(void)
{
    return strdup(workingDirectory.c_str());
}
 
unsigned long VuoRuntimePersistentState::getNextEventId(void)
{
    return __sync_add_and_fetch(&lastEventId, 1);
}
 
bool VuoRuntimePersistentState::isStopRequested(void)
{
    return _isStopRequested;
}
 
void VuoRuntimePersistentState::setStopRequested(bool isStopRequested)
{
    _isStopRequested = isStopRequested;
}
 
void VuoRuntimePersistentState::addFiniCallback(VuoCompositionFiniCallback fini)
{
    dispatch_sync(finiCallbackQueue, ^{
                      finiCallbacks.push_back(fini);
                  });
}
 
void VuoRuntimePersistentState::callFiniCallbacks(void)
{
    dispatch_sync(finiCallbackQueue, ^{
                      VuoCompositionState compositionState = { (void *)runtimeState, "" };
                      vuoAddCompositionStateToThreadLocalStorage(&compositionState);
 
                      for (vector<VuoCompositionFiniCallback>::iterator i = finiCallbacks.begin(); i != finiCallbacks.end(); ++i)
                          (*i)();
 
                      vuoRemoveCompositionStateFromThreadLocalStorage();
                  });
}
 
dispatch_group_t VuoRuntimePersistentState::getTriggerWorkersScheduled(void)
{
    return triggerWorkersScheduled;
}
 
extern "C"
{
 
unsigned long vuoGetNextEventId(VuoCompositionState *compositionState)
{
    VuoRuntimeState *runtimeState = (VuoRuntimeState *)compositionState->runtimeState;
    return runtimeState->persistentState->getNextEventId();
}
 
dispatch_group_t vuoGetTriggerWorkersScheduled(VuoCompositionState *compositionState)
{
    VuoRuntimeState *runtimeState = (VuoRuntimeState *)compositionState->runtimeState;
    return runtimeState->persistentState->getTriggerWorkersScheduled();
}
 
}