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

---

VideoSetRepositoryInFile.h

Go to the documentation of this file.

#ifndef Impala_Persistency_VideoSetRepositoryInFile_h
#define Impala_Persistency_VideoSetRepositoryInFile_h

#include "Persistency/RepositoryInFileSystem.h"
#include "Core/VideoSet/VideoSet.h"

namespace Impala
{
namespace Persistency
{


class VideoSetRepositoryInFile
{
public:

    typedef Core::VideoSet::VideoSet VideoSet;

    VideoSetRepositoryInFile()
    {
    }

    bool
    Exists(const Locator& loc)
    {
        File f = RepFS().GetFile(loc, "VideoData", loc.GetDataSet(), false,
                                 true);
        return f.Valid();
    }

    VideoSet*
    Get(const Locator& loc)
    {
        VideoSet* res = new VideoSet(loc.GetDataSet());
        res->SetProtocolAndHost(loc.GetProtocolAndHost());
        File f = RepFS().GetFile(loc, "VideoData", loc.GetDataSet(), false,
                                 false);
        Timer timer(1);
        Util::IOBuffer* buf = f.GetReadBuffer(true, "");
        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;
        return res;
    }

    void
    Add(const Locator& loc, VideoSet* vidSet)
    {
        File f = RepFS().GetFile(loc, "VideoData", loc.GetDataSet(), true,
                                 false);

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

    void
    Delete(const Locator& loc)
    {
        File file = RepFS().GetFile(loc, "VideoData", loc.GetDataSet(), true,
                                    true);
        file.Delete();
    }

private:

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

    ILOG_VAR_DEC;
};

ILOG_VAR_INIT(VideoSetRepositoryInFile, Impala.Persistency);

} // namespace Persistency
} // namespace Impala

#endif

---