VuoCompilerDelegate.cc

Go to the documentation of this file.

 
#include "VuoCompilerDelegate.hh"
#include "VuoCompiler.hh"
#include "VuoCompilerIssue.hh"
 
VuoCompilerDelegate::VuoCompilerDelegate(void)
{
    pendingDataQueue = dispatch_queue_create("org.vuo.compiler.delegate.pending", 0);
}
 
void VuoCompilerDelegate::loadedModulesCompleted(void)
{
    LoadedModulesData *data = dequeueData();
    data->release();
}
 
void VuoCompilerDelegate::enqueueData(LoadedModulesData *data)
{
    dispatch_sync(pendingDataQueue, ^{
                      pendingData.push_back(data);
                  });
}
 
VuoCompilerDelegate::LoadedModulesData * VuoCompilerDelegate::dequeueData(void)
{
    __block LoadedModulesData *ret;
    dispatch_sync(pendingDataQueue, ^{
                      ret = pendingData.front();
                      pendingData.pop_front();
                  });
    return ret;
}
 
VuoCompilerDelegate::LoadedModulesData::LoadedModulesData(const set< pair<VuoCompilerModule *, VuoCompilerModule *> > &modulesModified,
                                                          const set<VuoCompilerModule *> &modulesRemoved, VuoCompilerIssues *issues)
{
    referenceCountQueue = dispatch_queue_create("org.vuo.compiler.delegate.reference", 0);
    referenceCount = 0;
 
    this->modulesModified = modulesModified;
    this->modulesRemoved = modulesRemoved;
    this->issues = issues;
}
 
VuoCompilerDelegate::LoadedModulesData::~LoadedModulesData(void)
{
    delete issues;
 
    for (set< pair<VuoCompilerModule *, VuoCompilerModule *> >::iterator i = modulesModified.begin(); i != modulesModified.end(); ++i)
        VuoCompiler::destroyModule((*i).first);
 
    for (set<VuoCompilerModule *>::iterator i = modulesRemoved.begin(); i != modulesRemoved.end(); ++i)
        VuoCompiler::destroyModule(*i);
}
 
void VuoCompilerDelegate::LoadedModulesData::retain(void)
{
    dispatch_sync(referenceCountQueue, ^{
                      ++referenceCount;
                  });
}
 
void VuoCompilerDelegate::LoadedModulesData::release(void)
{
    dispatch_sync(referenceCountQueue, ^{
                      --referenceCount;
                      if (referenceCount == 0) {
                          delete this;
                      }
                  });
}