MimmoNamespace.cpp

#include "MimmoNamespace.hpp"
#include "BaseManipulation.hpp"
 
std::string mimmo::MIMMO_LOG_FILE = "mimmo";    
std::string mimmo::MIMMO_LOG_DIR = ".";         
bool        mimmo::MIMMO_EXPERT = false;        
mimmo::IBinaryStream& operator>>(mimmo::IBinaryStream &buffer, mimmo::FileDataInfo&  var){
 
    buffer >> var.ftype;
    buffer >> var.fdir;
    buffer >> var.fname;
 
    return buffer;
};
 
mimmo::OBinaryStream& operator<<(mimmo::OBinaryStream &buffer, const mimmo::FileDataInfo& var){
 
    buffer<<var.ftype;
    buffer<<var.fdir;
    buffer<<var.fname;
 
    return buffer;
};
 
 
namespace mimmo{
 
FileDataInfo::FileDataInfo(){
    ftype = 0;
};
 
FileDataInfo::~FileDataInfo(){};
 
 
namespace pin{
 
bool
addPin(BaseManipulation* objSend, BaseManipulation* objRec, PortID portS, PortID portR, bool forced){
    bitpit::Logger* log = &bitpit::log::cout(MIMMO_LOG_FILE);
    bool done = false;
    if (!objSend->arePortsBuilt()){
        objSend->buildPorts();
        if (!objSend->arePortsBuilt()){
            (*log) << "error: " << objSend->m_name << " cannot build ports -> exit! " << std::endl;
            throw std::runtime_error (objSend->m_name + " cannot build ports");
        }
    }
    if (!objRec->arePortsBuilt()){
        objRec->buildPorts();
        if (!objRec->arePortsBuilt()){
            (*log) << "error: " << objRec->m_name << " cannot build ports -> exit! " << std::endl;
            throw std::runtime_error (objRec->m_name + " cannot build ports");
        }
    }
    if (!(objSend->getConnectionType() == ConnectionType::BACKWARD) && !(objRec->getConnectionType() == ConnectionType::FORWARD) ){
        if (objSend->m_portOut.count(portS) != 0 && objRec->m_portIn.count(portR) != 0){
            if (forced || checkCompatibility(objSend, objRec, portS, portR)){
                objSend->addPinOut(objRec, portS, portR);
                objRec->addPinIn(objSend, portR);
                objSend->addChild(objRec);
                objRec->addParent(objSend);
                done = true;
            }
        }
    }
    log->setPriority(bitpit::log::NORMAL);
    if (!done) (*log)<<"warning: pin connection " << objSend->getName() << "[" << portS << "] --> " << objRec->getName() << "[" << portR << "] NOT linked. "<< std::endl;
    log->setPriority(bitpit::log::DEBUG);
    return done;
}
 
void
removeAllPins(BaseManipulation* objSend, BaseManipulation* objRec){
 
    std::unordered_map<PortID, PortOut*> pinsOut = objSend->getPortsOut();
    for (std::unordered_map<PortID, PortOut*>::iterator i = pinsOut.begin(); i != pinsOut.end(); i++){
        if (i->second != nullptr){
            std::vector<BaseManipulation*> linked = i->second->getLink();
            for (int j=0; j<(int)linked.size(); j++){
                if (linked[j] == objRec){
                    objSend->removePinOut(i->first,j);
                    objSend->unsetChild(objRec);
                }
            }
        }
    }
 
    std::unordered_map<PortID, PortIn*> pinsIn = objRec->getPortsIn();
    for (std::unordered_map<PortID, PortIn*>::iterator i = pinsIn.begin(); i != pinsIn.end(); i++){
        std::vector<BaseManipulation*> linked = i->second->getLink();
        if (i->second != nullptr){
            for (int j=0; j<(int)linked.size(); j++){
                if (linked[j] == objSend){
                    objRec->removePinIn(i->first,j);
                    objRec->unsetParent(objSend);
                }
            }
        }
    }
 
}
 
void
removePin(BaseManipulation* objSend, BaseManipulation* objRec, PortID portS, PortID portR){
 
    objSend->removePinOut(objRec, portS);
    objRec->removePinIn(objSend, portR);
    objSend->unsetChild(objRec);
    objRec->unsetParent(objSend);
 
}
 
bool
checkCompatibility(BaseManipulation* objSend, BaseManipulation* objRec, PortID portS, PortID portR){
    bool check = false;
    PortIn*     pinin   = objRec->getPortsIn()[portR];
    PortOut*    pinout  = objSend->getPortsOut()[portS];
    DataType typeR = pinin->getDataType();
    DataType typeS = pinout->getDataType();
    check = (typeS == typeR);
    return(check);
}
 
}//end pin namespace
 
void    setLogger(std::string log){
    if (BaseManipulation::sm_baseManipulationCounter > 1){
        bitpit::Logger* log = &bitpit::log::cout(MIMMO_LOG_FILE);
        (*log) << "warning: logger already set -> cannot change logger name " << std::endl;
        return;
    }
    MIMMO_LOG_FILE = log;
}
 
void    setLoggerDirectory(std::string dir){
    if (BaseManipulation::sm_baseManipulationCounter > 1){
        bitpit::Logger* log = &bitpit::log::cout(MIMMO_LOG_FILE);
        (*log) << "warning: logger already set -> cannot change logger directory " << std::endl;
        return;
    }
    MIMMO_LOG_DIR = dir;
}
 
void    warningXML(bitpit::Logger* log, std::string name){
    (*log)<<"warning in custom xml " << name << " constructor. No valid xml data found"<<std::endl;
}
 
void setExpertMode(bool flag){
    MIMMO_EXPERT = flag;
}
 
}//end mimmo namespace