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

---

ImageSetRepositoryInFile.h

Go to the documentation of this file.

#ifndef Impala_Persistency_ImageSetRepositoryInFile_h
#define Impala_Persistency_ImageSetRepositoryInFile_h

#include "Persistency/RepositoryInFileSystem.h"
#include "Core/ImageSet/ImageSet.h"
#include "Persistency/ImageSetLocator.h"
#include "Basis/Timer.h"

namespace Impala
{
namespace Persistency
{


class ImageSetRepositoryInFile
{
public:

    typedef Core::ImageSet::ImageSet ImageSet;

    ImageSetRepositoryInFile()
    {
    }

    bool
    Exists(const ImageSetLocator& loc)
    {
        File f = RepFS().GetFile(loc, "ImageData", loc.GetName(), false, true);
        return f.Valid();
    }

    ImageSet*
    Get(const ImageSetLocator& loc)
    {
        ImageSet* res = new ImageSet(loc.GetName());
        res->SetProtocolAndHost(loc.GetProtocolAndHost());
        res->SetImageSetLocator(loc);
        File f = RepFS().GetFile(loc, "ImageData", loc.GetName(), false, false);
        Timer timer(1);
        //Util::IOBuffer* buf = f.GetReadBuffer();
        Util::IOBuffer* buf = f.GetReadBuffer(true, "", 0, false);
        if (buf->Valid())
        {
            while (buf->Available())
            {
                String line = buf->ReadLine();
                if (line[0] && (line[0] != '#'))
                {
                    int id = -1;
                    String name("");
                    Util::StringParser p(line);
                    while (!p.TheEnd())
                    {
                        if (p.At("<id="))
                        {
                            p.Eat('=');
                            id = p.GetInt('>', true);
                            p.Eat('>');
                        }
                        else
                        {
                            String s = p.GetString2(false);
                            name = StringReplaceAll(s, "\\", "/");
                        }
                    }
                    res->AddFile(name, id);
                }
            }
        }
        delete buf;
        ILOG_DEBUG("Done read file in " << timer.SplitTime());
        return res;
    }

    void
    Add(const ImageSetLocator& loc, ImageSet* imSet)
    {
        File f = RepFS().GetFile(loc, "ImageData", loc.GetName(), true, false);

        Util::IOBuffer* ioBuf = f.GetWriteBuffer();
        if (! ioBuf)
            return;
        for (int i=0 ; i<imSet->NrFiles() ; i++)
            ioBuf->IOBuffer::Puts("\"" + imSet->GetAsPath(i) + "\"");
        delete ioBuf;
    }

    void
    Delete(const ImageSetLocator& loc)
    {
        File f = RepFS().GetFile(loc, "ImageData", loc.GetName(), true, true);
        f.Delete();
    }

private:

    RepositoryInFileSystem&
    RepFS()
    {
        return RepositoryInFileSystem::GetInstance();
    }

    ILOG_VAR_DEC;
};

ILOG_VAR_INIT(ImageSetRepositoryInFile, Impala.Persistency);

} // namespace Persistency
} // namespace Impala

#endif

---