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

---

Archive.h

Go to the documentation of this file.

#ifndef Impala_Core_ImageSet_Archive_h
#define Impala_Core_ImageSet_Archive_h

#include "Core/ImageSet/Reporter.h"
#include "Core/ImageSet/MakeImageSet.h"
#include "Core/Array/MakeFromValue.h"
#include "Core/Array/ArrayListDelete.h"
#include "Core/Array/WriteRaw.h"
#include "Core/Array/ImageArchiveMemory.h"

namespace Impala
{
namespace Core
{
namespace ImageSet
{


class Archive : public Listener
{
    typedef Array::Array2dScalarUInt8 ImType;
public:

    Archive(Reporter* reporter, CmdOptions& options)
    {
        mReporter = reporter;
        mReporter->SetReportArray(false); // we will cause a "memory leak"
        mSplit = options.GetNrArg() > 2;
    }

    virtual
    ~Archive()
    {
        Array::ArrayListDelete(&mImList);
    }

    virtual void
    HandleNewFile(ImageSet* is, int fileId, Array::Array2dVec3UInt8* im)
    {
#ifndef REPOSITORY_USED // Here comes the deprecated stuff
        String fileName = is->GetFilePathImageData(fileId, false, false);
        Util::Database* db = is->GetDatabase();
        Util::IOBuffer* ioBuf = db->GetIOBuffer(fileName, true, false, "", 0,
                                                true);
        if (!ioBuf)
        {
            ILOG_ERROR("Unable to open file " << fileName);
            return;
        }
#else // REPOSITORY_USED
        Persistency::ImageLocator loc(is->GetLocator(),
                                      is->GetContainerDirOfFile(fileId), 
                                      is->GetFile(fileId));
        Util::IOBuffer* ioBuf =
            Persistency::ImageRepositoryInFile().GetReadBuffer(loc);
#endif // REPOSITORY_USED

        Int64 bufSize = ioBuf->Size();
        ImType* bufIm = Array::ArrayCreate<ImType>(bufSize, 1);
        Int64 nrRead = ioBuf->Read(bufIm->CPB(), ioBuf->Size());

        mImList.push_back(bufIm);
        delete ioBuf;
    }

    virtual void
    HandleDoneDir(ImageSet* is, int dirId)
    {
        if (!mSplit)
            return;
#ifndef REPOSITORY_USED // Here comes the deprecated stuff
        int fileId = is->GetFirstFileId(dirId);
        String fName = is->GetFilePathImageArchive(fileId, "images.raw", true,
                                                   false);
        Array::WriteRawListVar(mImList, fName, is->GetDatabase(), true, true);
#else // REPOSITORY_USED
        String container = is->GetContainerDir(dirId);
        Persistency::ImageArchiveLocator loc(is->GetLocator(), false,
                                             container, "images.raw", 0);
        Array::ImageArchiveMemory wrapper(&mImList);
        Persistency::ImageArchiveRepository().Add(loc, &wrapper);
#endif // REPOSITORY_USED
        Array::ArrayListDelete(&mImList);
    }

    virtual void
    HandleDoneWalk(ImageSet* is)
    {
        if (mSplit)
            return;

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
        String arName = is->GetSetNameBase() + ".raw";
        String fName = is->GetFilePathImageArchive(arName, true, false);
        ILOG_INFO("writing archive [" << fName << "]");
        Array::WriteRawListVar(mImList, fName, is->GetDatabase(), true, true);
#else // REPOSITORY_USED
        String arName = is->GetSetNameBase() + ".raw";
        Persistency::ImageArchiveLocator loc(is->GetLocator(), false,
                                             "", arName, 0);
        Array::ImageArchiveMemory wrapper(&mImList);
        Persistency::ImageArchiveRepository().Add(loc, &wrapper);
#endif // REPOSITORY_USED
    }

private:

    Reporter*            mReporter;
    bool                 mSplit;
    std::vector<ImType*> mImList;

    ILOG_VAR_DEC;
};

ILOG_VAR_INIT(Archive, Core.ImageSet);

} // namespace ImageSet
} // namespace Core
} // namespace Impala

#endif

---