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

---

RepositoryInFileSystem.h

Go to the documentation of this file.

#ifndef Impala_Persistency_RepositoryInFileSystem_h
#define Impala_Persistency_RepositoryInFileSystem_h

#include "Persistency/File.h"
#include "Persistency/FileLocator.h"
#include "Util/SimpleMap.h"
#include "Core/Feature/FeatureDefinition.h"

namespace Impala
{
namespace Persistency
{


class RepositoryInFileSystem
{
public:

    static RepositoryInFileSystem&
    GetInstance()
    {
        static RepositoryInFileSystem theRepositoryInFileSystem;
        return theRepositoryInFileSystem;
    }

    File
    GetFile(const Locator& loc, CString fileName, bool toWrite, bool silent)
    {
        FileSystem* fs = GetFS(loc);
        String path = fs->GetFilePath(loc.GetDataSet(), fileName, toWrite,
                                      silent);
        return File(path, fs);
    }

    File
    GetFile(const Locator& loc, CString dir, CString file, bool toWrite,
            bool silent)
    {
        FileSystem* fs = GetFS(loc);
        if (toWrite)
            fs->MakeDir(dir);
        String path = fs->GetFilePath(dir, file, toWrite, silent);
        return File(path, fs);
    }

    File
    GetFile(const FileLocator& loc, bool toWrite, bool silent)
    {
        FileSystem* fs = GetFS(loc);
        String path = fs->GetFilePath("", loc.GetName(), toWrite, silent);
        return File(path, fs);
    }

private:

    RepositoryInFileSystem()
    {
    }

    FileSystem*
    GetFS(const Locator& loc)
    {
        FileSystem* fs = 0;
        if (mMap.Get(loc.ToString(), fs))
            return fs;

        String setName = loc.GetDataSet();
        String data("");
        if ((setName == "dot") || (setName == "."))
        {
            data = ".";
            ILOG_INFO_ONCE("'data' option for " << setName <<
                           " has been set to: " << data);
        }
        else if (setName == "abs")
        {
            data = "";
            ILOG_INFO_ONCE("'data' option for " << setName <<
                           " has been set to: <empty> (i.e. is absolute)");
        }
        else if (setName == "config")
        {
            char* ptr = getenv("IMPALAROOT");
            data = (ptr) ? String(ptr)+"/src/" : ".";
            ILOG_INFO_ONCE("'data' option for " << setName <<
                           " has been set to: " << data);
        }
        else
        {
            CmdOptions& options = CmdOptions::GetInstance();
            data = StringReplaceAll(options.GetString("data"), ":", ";", false);
            String additionalData = options.GetString("data::"+setName, "");
            if (additionalData.empty() && !setName.empty())
                additionalData = "../" + FileNameBase(setName);
            if (!additionalData.empty())
            {
                data = additionalData + ";" + data;
                ILOG_INFO_ONCE("'data' option for " << setName <<
                               " has been extended: " << data);
            }
        }

        fs = new FileSystem(data, loc.GetHost());
        mMap.Add(loc.ToString(), fs);
        return fs;
    }

    Util::SimpleMapDelete<String, FileSystem*> mMap;

    ILOG_VAR_DEC;

};

ILOG_VAR_INIT(RepositoryInFileSystem, Impala.Persistency);

} // namespace Persistency
} // namespace Impala

#endif

---