VuoCompilerTriggerDescription.cc

Go to the documentation of this file.

 
#include "VuoCompilerGraph.hh"
#include "VuoCompilerNode.hh"
#include "VuoCompilerTriggerDescription.hh"
#include "VuoCompilerTriggerPort.hh"
#include "VuoNode.hh"
#include "VuoNodeClass.hh"
#include "VuoPort.hh"
#include "VuoType.hh"
#include "VuoStringUtilities.hh"
 
VuoCompilerTriggerDescription::VuoCompilerTriggerDescription(void)
{
    nodeIndex = ULONG_MAX - 1;
    portContextIndex = -1;
    eventThrottling = VuoPortClass::EventThrottling_Enqueue;
    dataType = NULL;
    minWorkerThreadsNeeded = -1;
    minWorkerThreadsNeeded = -1;
    chainCount = -1;
}
 
json_object * VuoCompilerTriggerDescription::getJson(VuoCompilerNode *triggerNode, VuoCompilerTriggerPort *trigger, VuoCompilerGraph *graph)
{
    size_t nodeIndex = triggerNode->getIndexInOrderedNodes();
    string nodeIdentifier = triggerNode->getGraphvizIdentifier();
    string nodeClassName = triggerNode->getBase()->getNodeClass()->getClassName();
    string portName = trigger->getBase()->getClass()->getName();
    int portContextIndex = trigger->getIndexInPortContexts();
    VuoPortClass::EventThrottling eventThrottling = trigger->getBase()->getEventThrottling();
    string eventThrottlingStr = (eventThrottling == VuoPortClass::EventThrottling_Drop ? "drop" : "enqueue");
    VuoType *dataType = trigger->getDataVuoType();
    string dataTypeStr = (dataType ? dataType->getModuleKey() : "event");
    int minWorkerThreadsNeeded, maxWorkerThreadsNeeded;
    graph->getWorkerThreadsNeeded(trigger, minWorkerThreadsNeeded, maxWorkerThreadsNeeded);
    int chainCount = (int)graph->getChains()[trigger].size();
 
    json_object *js = json_object_new_object();
 
    json_object_object_add(js, "nodeIndex", json_object_new_int64(nodeIndex));
    json_object_object_add(js, "nodeIdentifier", json_object_new_string(nodeIdentifier.c_str()));
    json_object_object_add(js, "nodeClassName", json_object_new_string(nodeClassName.c_str()));
    json_object_object_add(js, "portName", json_object_new_string(portName.c_str()));
    json_object_object_add(js, "portContextIndex", json_object_new_int(portContextIndex));
    json_object_object_add(js, "eventThrottling", json_object_new_string(eventThrottlingStr.c_str()));
    json_object_object_add(js, "dataType", json_object_new_string(dataTypeStr.c_str()));
    json_object_object_add(js, "minWorkerThreadsNeeded", json_object_new_int(minWorkerThreadsNeeded));
    json_object_object_add(js, "maxWorkerThreadsNeeded", json_object_new_int(maxWorkerThreadsNeeded));
    json_object_object_add(js, "chainCount", json_object_new_int(chainCount));
 
    return js;
}
 
vector<VuoCompilerTriggerDescription *> VuoCompilerTriggerDescription::parseFromJson(json_object *js)
{
    vector<VuoCompilerTriggerDescription *> triggers;
 
    int itemCount = json_object_array_length(js);
    for (int i = 0; i < itemCount; ++i)
    {
        json_object *itemJs = json_object_array_get_idx(js, i);
        json_object *o = NULL;
 
        VuoCompilerTriggerDescription *trigger = new VuoCompilerTriggerDescription();
 
        if (json_object_object_get_ex(itemJs, "nodeIndex", &o))
            trigger->nodeIndex = json_object_get_int64(o);
        if (json_object_object_get_ex(itemJs, "nodeIdentifier", &o))
            trigger->nodeIdentifier = json_object_get_string(o);
        if (json_object_object_get_ex(itemJs, "nodeClassName", &o))
            trigger->nodeClassName = json_object_get_string(o);
        if (json_object_object_get_ex(itemJs, "portName", &o))
            trigger->portName = json_object_get_string(o);
        if (json_object_object_get_ex(itemJs, "portContextIndex", &o))
            trigger->portContextIndex = json_object_get_int(o);
        if (json_object_object_get_ex(itemJs, "eventThrottling", &o))
        {
            string eventThrottlingStr = json_object_get_string(o);
            trigger->eventThrottling = (eventThrottlingStr == "drop" ? VuoPortClass::EventThrottling_Drop : VuoPortClass::EventThrottling_Enqueue);
        }
        if (json_object_object_get_ex(itemJs, "dataType", &o))
        {
            string dataTypeStr = json_object_get_string(o);
            trigger->dataType = (dataTypeStr == "event" ? NULL : new VuoType(dataTypeStr));
        }
        if (json_object_object_get_ex(itemJs, "minWorkerThreadsNeeded", &o))
            trigger->minWorkerThreadsNeeded = json_object_get_int(o);
        if (json_object_object_get_ex(itemJs, "maxWorkerThreadsNeeded", &o))
            trigger->maxWorkerThreadsNeeded = json_object_get_int(o);
        if (json_object_object_get_ex(itemJs, "chainCount", &o))
            trigger->chainCount = json_object_get_int(o);
        if (json_object_object_get_ex(itemJs, "subcompositionNodeClassName", &o))
            trigger->subcompositionNodeClassName = json_object_get_string(o);
        if (json_object_object_get_ex(itemJs, "subcompositionNodeIdentifier", &o))
            trigger->subcompositionNodeIdentifier = json_object_get_string(o);
 
        triggers.push_back(trigger);
    }
 
    return triggers;
}
 
json_object * VuoCompilerTriggerDescription::getJsonWithinSubcomposition(VuoCompilerNode *subcompositionNode)
{
    string eventThrottlingStr = (getEventThrottling() == VuoPortClass::EventThrottling_Drop ? "drop" : "enqueue");
    string dataTypeStr = (dataType ? dataType->getModuleKey() : "event");
    string subcompositionNodeClassNameStr = (subcompositionNodeClassName.empty() ?
                                                 subcompositionNode->getBase()->getNodeClass()->getClassName() : subcompositionNodeClassName);
    string subcompositionNodeIdentifierStr = (subcompositionNodeIdentifier.empty() ?
                                                  subcompositionNode->getGraphvizIdentifier() :
                                                  VuoStringUtilities::buildCompositionIdentifier(subcompositionNode->getGraphvizIdentifier(), subcompositionNodeIdentifier));
 
    json_object *js = json_object_new_object();
 
    json_object_object_add(js, "nodeIndex", json_object_new_int64(nodeIndex));
    json_object_object_add(js, "nodeIdentifier", json_object_new_string(nodeIdentifier.c_str()));
    json_object_object_add(js, "nodeClassName", json_object_new_string(nodeClassName.c_str()));
    json_object_object_add(js, "portName", json_object_new_string(portName.c_str()));
    json_object_object_add(js, "portContextIndex", json_object_new_int(portContextIndex));
    json_object_object_add(js, "eventThrottling", json_object_new_string(eventThrottlingStr.c_str()));
    json_object_object_add(js, "dataType", json_object_new_string(dataTypeStr.c_str()));
    json_object_object_add(js, "minWorkerThreadsNeeded", json_object_new_int(minWorkerThreadsNeeded));
    json_object_object_add(js, "maxWorkerThreadsNeeded", json_object_new_int(maxWorkerThreadsNeeded));
    json_object_object_add(js, "chainCount", json_object_new_int(chainCount));
    json_object_object_add(js, "subcompositionNodeClassName", json_object_new_string(subcompositionNodeClassNameStr.c_str()));
    json_object_object_add(js, "subcompositionNodeIdentifier", json_object_new_string(subcompositionNodeIdentifierStr.c_str()));
 
    return js;
}
 
size_t VuoCompilerTriggerDescription::getNodeIndex(void)
{
    return nodeIndex;
}
 
string VuoCompilerTriggerDescription::getNodeIdentifier(void)
{
    return nodeIdentifier;
}
 
string VuoCompilerTriggerDescription::getNodeClassName(void)
{
    return nodeClassName;
}
 
string VuoCompilerTriggerDescription::getPortName(void)
{
    return portName;
}
 
int VuoCompilerTriggerDescription::getPortContextIndex(void)
{
    return portContextIndex;
}
 
VuoPortClass::EventThrottling VuoCompilerTriggerDescription::getEventThrottling(void)
{
    return eventThrottling;
}
 
VuoType * VuoCompilerTriggerDescription::getDataType(void)
{
    return dataType;
}
 
void VuoCompilerTriggerDescription::setDataType(VuoType *dataType)
{
    this->dataType = dataType;
}
 
void VuoCompilerTriggerDescription::getWorkerThreadsNeeded(int &minThreadsNeeded, int &maxThreadsNeeded)
{
    minThreadsNeeded = this->minWorkerThreadsNeeded;
    maxThreadsNeeded = this->maxWorkerThreadsNeeded;
}
 
int VuoCompilerTriggerDescription::getChainCount(void)
{
    return chainCount;
}
 
string VuoCompilerTriggerDescription::getSubcompositionNodeClassName(void)
{
    return subcompositionNodeClassName;
}
 
string VuoCompilerTriggerDescription::getSubcompositionNodeIdentifier(void)
{
    return subcompositionNodeIdentifier;
}