gridnetwork.h

Go to the documentation of this file.

#ifndef GRIDNETWORK_H_
#define GRIDNETWORK_H_

#include <map>
#include <string>
#include <functional>
#include <stdexcept>
#include "bytebuffer.h"
#include "interfaces.h"
#include "runnable.h"

class Grid;

#define GRID_SAVE_FILE "gridComputing.grid"


class ExistingGrid : public std::runtime_error
{
private:
    std::string _name; 

public:
    ExistingGrid(const std::string& name) : std::runtime_error("Grid already exists"), _name(name) {} 
    const std::string& GetExistingName() const { return _name; } 
};


class UnknownGrid : public std::runtime_error
{
private:
    std::string _name; 

public:
    UnknownGrid(const std::string& name) : std::runtime_error("Grid not found"), _name(name) {} 
    const std::string& GetUnknownName() const { return _name; } 
};


class GridNetwork : public ISave, public IUpdate, public Runnable
{
private:
    std::map<std::string, Grid*> _bst; 
    void AddGrid(const std::string& name, Grid* grid); 

    uint64 _realPrevTime; 
    uint64 _realCurrTime; 

    void Run();

public:
    GridNetwork() : _realPrevTime(0), _realCurrTime(0) { Start(); }
    ~GridNetwork(); 

    void NewGrid(const std::string& name, const std::string& topic);
    void ChangeGridName(const std::string& oldName, const std::string& newName);
    void ChangeGridTopic(const std::string& name, const std::string& newTopic);
    void RemoveGrid(const std::string& name);

    Grid* GetGrid(const std::string& name);

    static GridNetwork* Load(ByteBuffer& bb);

    bool Save(ByteBuffer& bb) const override;

    void Update(uint32 diff);

    const std::map<std::string, Grid*>& GetContainer() const { return _bst; }

    std::vector<const Grid*> ApplyPredicate(std::function<bool(const Grid*)> predicate) const;

private: // no copying
    GridNetwork(const GridNetwork &);
    GridNetwork& operator =(GridNetwork const&);
};

#endif // GRIDNETWORK_H_