|| || || || || ||

---

RepositoryDispatcher.h

Go to the documentation of this file.

#ifndef Impala_Persistency_RepositoryDispatcher_h
#define Impala_Persistency_RepositoryDispatcher_h

#include "Basis/ILog.h"

namespace Impala
{
namespace Persistency
{


template<class LocatorType, class DataType,
         class RepositoryInFileType, class RepositoryInMonetType>
class RepositoryDispatcher
{
public:

    RepositoryDispatcher()
    {
    }

    bool
    Exists(const LocatorType& loc)
    {
        String protocol = loc.GetProtocol();
        if ((protocol == "file") || (protocol == "dataServer"))
        {
            return mRepFile.Exists(loc);
        }
        /*
        if (protocol == "mapi")
        {
            return mRepMonet.Get(loc);
        }
        */
        ILOG_ERROR("Exists: unknown protocol: [" << loc.GetProtocol() << "] in "
                   << loc);
        return false;
    }

    DataType*
    Get(const LocatorType& loc)
    {
        String protocol = loc.GetProtocol();
        if ((protocol == "file") || (protocol == "dataServer"))
        {
            return mRepFile.Get(loc);
        }
        if (protocol == "mapi")
        {
            return mRepMonet.Get(loc);
        }
        ILOG_ERROR("Get: unknown protocol: [" << loc.GetProtocol() << "] in "
                   << loc);
        return 0;
    }

    void
    Add(const LocatorType& loc, DataType* data)
    {
        String protocol = loc.GetProtocol();
        if ((protocol == "file") || (protocol == "dataServer"))
        {
            return mRepFile.Add(loc, data);
        }
        if (protocol == "mapi")
        {
            return mRepMonet.Add(loc, data);
        }
        ILOG_ERROR("Add: unknown protocol: [" << loc.GetProtocol() << "] in "
                   << loc);
    }

    void
    Delete(const LocatorType& loc)
    {
        String protocol = loc.GetProtocol();
        if ((protocol == "file") || (protocol == "dataServer"))
        {
            return mRepFile.Delete(loc);
        }
        /*
        if (protocol == "mapi")
        {
            return mRepMonet.Delete(loc);
        }
        */
        ILOG_ERROR("Delete: unknown protocol: [" << loc.GetProtocol() << "] in "
                   << loc);
    }

    void
    Sync(const LocatorType& loc, DataType* data)
    {
        if (!Exists(loc)) // Todo: add a check in timestamp etc.
            Add(loc, data);
    }

    void
    Replace(const LocatorType& loc, DataType* data)
    {
        Delete(loc);
        Add(loc, data);
    }

protected:

    RepositoryInFileType  mRepFile;
    RepositoryInMonetType mRepMonet;

    ILOG_VAR_DEC;
};

ILOG_VAR_INIT_TEMPL_4(RepositoryDispatcher, LocatorType, DataType,
                      RepositoryInFileType, RepositoryInMonetType,
                      Impala.Persistency);

} // namespace Persistency
} // namespace Impala

#endif

---