primresource.cpp

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: 2006-2021 Istituto Italiano di Tecnologia (IIT)
 * SPDX-License-Identifier: BSD-3-Clause
 */
 
#include <yarp/manager/primresource.h>
 
#include <cstring>
 
using namespace yarp::manager;
 
 
Memory::Memory() : GenericResource("Memory")
{
    totalSpace = (Capacity)0;
    freeSpace = (Capacity)0;
}
 
 
Memory::Memory(const char* szName) : GenericResource("Memory")
{
    setName(szName);
    totalSpace = (Capacity)0;
    freeSpace = (Capacity)0;
}
 
bool Memory::satisfy(GenericResource* resource)
{
    if (!getAvailability() || getDisable()) {
        return false;
    }
 
    auto* mem = dynamic_cast<Memory*>(resource);
    if (!mem) {
        return false;
    }
    return ( (freeSpace >= mem->getFreeSpace()) &&
             (totalSpace >= mem->getTotalSpace()) );
}
 
Node* Memory::clone()
{
    auto* resource = new Memory(*this);
    return resource;
}
 
 
Memory::~Memory() = default;
 
 
 
Storage::Storage() : GenericResource("Storage")
{
    totalSpace = (Capacity)0;
    freeSpace = (Capacity)0;
}
 
 
Storage::Storage(const char* szName) : GenericResource("Storage")
{
    setName(szName);
    totalSpace = (Capacity)0;
    freeSpace = (Capacity)0;
}
 
bool Storage::satisfy(GenericResource* resource)
{
    if (!getAvailability() || getDisable()) {
        return false;
    }
 
    auto* mem = dynamic_cast<Storage*>(resource);
    if (!mem) {
        return false;
    }
    return ( (freeSpace >= mem->getFreeSpace()) &&
             (totalSpace >= mem->getTotalSpace()) );
}
 
Node* Storage::clone()
{
    auto* resource = new Storage(*this);
    return resource;
}
 
 
Storage::~Storage() = default;
 
 
 
Network::Network() : GenericResource("Network")
{
}
 
 
Network::Network(const char* szName) : GenericResource("Network")
{
    setName(szName);
}
 
bool Network::satisfy(GenericResource* resource)
{
    if (!getAvailability() || getDisable()) {
        return false;
    }
 
    auto* net = dynamic_cast<Network*>(resource);
    if (!net) {
        return false;
    }
    bool ret = (!strlen(net->getIP4()))? true : (strIP4 == std::string(net->getIP4()));
    ret &= (!strlen(net->getIP6()))? true : (strIP6 == std::string(net->getIP6()));
    ret &= (!strlen(net->getMAC()))? true : (strMAC == std::string(net->getMAC()));
    return ret;
}
 
Node* Network::clone()
{
    auto* resource = new Network(*this);
    return resource;
}
 
 
Network::~Network() = default;
 
 
 
Processor::Processor() : GenericResource("Processor")
{
    cores = (size_t)0;
    frequency = (double)0.0;
    siblings = (size_t)0;
    cpuload.loadAverage1 = (double)0.0;
    cpuload.loadAverage5 = (double)0.0;
    cpuload.loadAverage15 = (double)0.0;
    cpuload.loadAverageInstant = (double)0.0;
}
 
 
Processor::Processor(const char* szName) : GenericResource("Processor")
{
    setName(szName);
    cores = (size_t)0;
    frequency = (double)0.0;
    siblings = (size_t)0;
    cpuload.loadAverage1 = (double)0.0;
    cpuload.loadAverage5 = (double)0.0;
    cpuload.loadAverage15 = (double)0.0;
    cpuload.loadAverageInstant = (double)0.0;
}
 
bool Processor::satisfy(GenericResource* resource)
{
    if (!getAvailability() || getDisable()) {
        return false;
    }
 
    auto* proc = dynamic_cast<Processor*>(resource);
    if (!proc) {
        return false;
    }
 
    bool ret = (!strlen(proc->getArchitecture()))? true : (strArchitecure == std::string(proc->getArchitecture()));
    ret &= (!strlen(proc->getModel()))? true : (strModel == std::string(proc->getModel()));
    ret &= (cores >= proc->getCores());
    ret &= (siblings >= proc->getSiblings());
    ret &= (frequency >= proc->getFrequency());
    return ret;
}
 
 
Node* Processor::clone()
{
    auto* resource = new Processor(*this);
    return resource;
}
 
 
Processor::~Processor() = default;
 
 
 
Computer::Computer() : GenericResource("Computer")
{
}
 
 
Computer::Computer(const char* szName) : GenericResource("Computer")
{
    setName(szName);
    network.setName(szName);
}
 
 
Computer::Computer(const Computer &resource) : GenericResource(resource)
{
    Computer::swap(resource);
}
 
 
Computer& Computer::operator=(const Computer& rhs)
{
    GenericResource::operator=(rhs);
    Computer::swap(rhs);
    return *this;
}
 
 
bool Computer::addPeripheral(GenericResource& res)
{
    auto* newres = (GenericResource*) res.clone();
    peripheralResources.push_back(newres);
    return true;
}
 
 
bool Computer::satisfy(GenericResource* resource)
{
    if (!getAvailability() || getDisable()) {
        return false;
    }
 
    auto* mres = dynamic_cast<MultiResource*>(resource);
    if(mres)
    {
        if (!mres->resourceCount()) {
            return true;
        }
        for(int i=0; i<mres->resourceCount(); i++)
        {
            auto* comp = dynamic_cast<Computer*>(&mres->getResourceAt(i));
            if (comp && satisfyComputer(comp)) {
                return true;
            } else if (satisfyComputerResource(&mres->getResourceAt(i))) {
                return true;
            }
        }
        return false;
    }
 
    auto* comp = dynamic_cast<Computer*>(resource);
    if (comp) {
        return satisfyComputer(comp);
    }
 
    return satisfyComputerResource(resource);
}
 
 
bool Computer::satisfyComputer(Computer* comp)
{
    bool ret = satisfyComputerResource(&comp->getMemory());
    ret &= satisfyComputerResource(&comp->getStorage());
    ret &= satisfyComputerResource(&comp->getProcessor());
    ret &= satisfyComputerResource(&comp->getNetwork());
    ret &= satisfyComputerResource(&comp->getPlatform());
    for (int i = 0; i < comp->peripheralCount(); i++) {
        ret &= satisfyComputerResource(&comp->getPeripheralAt(i));
    }
    return ret;
}
 
 
bool Computer::satisfyComputerResource(GenericResource* resource)
{
    if (memory.satisfy(resource)) {
        return true;
    }
    if (storage.satisfy(resource)) {
        return true;
    }
    if (network.satisfy(resource)) {
        return true;
    }
    if (processor.satisfy(resource)) {
        return true;
    }
    if (platform.satisfy(resource)) {
        return true;
    }
 
    ResourcePIterator itr;
    for (itr = peripheralResources.begin(); itr != peripheralResources.end(); itr++) {
        if ((*itr)->satisfy(resource)) {
            return true;
        }
    }
    return false;
}
 
Node* Computer::clone()
{
    auto* resource = new Computer(*this);
    return resource;
}
 
void Computer::swap(const Computer &comp)
{
    clear();
    memory = comp.memory;
    storage = comp.storage;
    processor = comp.processor;
    network = comp.network;
    platform = comp.platform;
    processes = comp.processes;
    // deep copy
    for (int i = 0; i < comp.peripheralCount(); i++) {
        addPeripheral(comp.getPeripheralAt(i));
    }
}
 
void Computer::clear()
{
    for(auto& peripheralResource : peripheralResources)
    {
        delete peripheralResource;
        peripheralResource = nullptr;
    }
    peripheralResources.clear();
    processes.clear();
}
 
 
Computer::~Computer()
{
    clear();
}