microflo/linux_mqtt_main.hpp
// TODO: introspect from Network/cmdstream instead of graph metadata
introspect from Network/cmdstream instead of graph metadata
introspect from Network / cmdstream instead of graph metadata
bool findPorts(ParticipantInfo *info) {
    for (size_t i=0; i<graph_inports_length; i++) {
        const char *name = graph_inports_name[i];
        MicroFlo::PortId portId = graph_inports_port[i];
        MicroFlo::NodeId nodeId = graph_inports_node[i];
        info->addInport(name, nodeId, portId);
    }
    for (size_t i=0; i<graph_outports_length; i++) {
        const char *name = graph_outports_name[i];
        MicroFlo::PortId portId = graph_outports_port[i];
        MicroFlo::NodeId nodeId = graph_outports_node[i];
        info->addOutport(name, nodeId, portId);
    }
    info->component = graph_name;
    return true;
}
bool findPorts ( ParticipantInfo * info ) { for ( size_t i = 0 ; i < graph_inports_length ; i ++ ) { const char * name = graph_inports_name [ i ] ; MicroFlo :: PortId portId = graph_inports_port [ i ] ; MicroFlo :: NodeId nodeId = graph_inports_node [ i ] ; info -> addInport ( name , nodeId , portId ) ; } for ( size_t i = 0 ; i < graph_outports_length ; i ++ ) { const char * name = graph_outports_name [ i ] ; MicroFlo :: PortId portId = graph_outports_port [ i ] ; MicroFlo :: NodeId nodeId = graph_outports_node [ i ] ; info -> addOutport ( name , nodeId , portId ) ; } info -> component = graph_name ; return true ; }
TODO: introspect from Network/cmdstream instead of graph metadata
TODO : introspect from Network / cmdstream instead of graph metadata
// FIXME: don't assume graph data is in 'graph_*' // Exported ports // Graph name // TODO: replace with command stream command for graph name