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

---

VideoSet.h

Go to the documentation of this file.

#ifndef Impala_Core_VideoSet_VideoSet_h
#define Impala_Core_VideoSet_VideoSet_h

#include <vector>

#include "Persistency/VideoSetsRepository.h"
#include "Core/Stream/RgbDataSrcFactory.h"
#include "Core/Array/Arrays.h"
#include "Core/Database/RawDataSet.h"
#include "Core/Array/ReadRaw.h"
#include "Core/Array/WriteRaw.h"
#include "Link/DiskImage/DiskImageFuncs.h"

namespace Impala
{
namespace Core
{
namespace VideoSet
{


class VideoSet : public Database::RawDataSet
{
public:

    typedef Persistency::VideoSetsRepository VideoSetsRepository;

    VideoSet(String setName) :
        Database::RawDataSet(setName),
        mSetId(-1)
    {
        mQuidClass = QUID_CLASS_FRAME;
        VideoSetsRepository::GetInstance().Register(this, GetSetName());
    }

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
    VideoSet(Util::Database* db, String setName, bool readSet) :
        Database::RawDataSet
            (db, setName,
             readSet ? db->GetFilePath("VideoData", setName, false, false) : ""),
        mSetId(-1)
    {
        GenerateFileNames(".mpg");
        mQuidClass = QUID_CLASS_FRAME;
        VideoSetsRepository::GetInstance().Register(this, GetSetName());
    }
#endif // REPOSITORY_USED

    int
    GetSetId()
    {
        if (mSetId == -1)
            mSetId = VideoSetsRepository::GetInstance().GetId(GetSetName());
        return mSetId;
    }

    Quid
    GetQuidVideo(int fileId, bool doIdLookup = false)
    {
        if (doIdLookup)
            fileId = GetFileId(fileId);
        return MakeQuidVideo(GetSetId(), fileId);
    }

    Quid
    GetQuidFrame(int fileId, int frameNr, bool doIdLookup = false)
    {
        if (doIdLookup)
            fileId = GetFileId(fileId);
        return MakeQuidFrame(GetSetId(), fileId, frameNr);
    }

    virtual String
    QuidToString(Quid quid, bool elaborate)
    {
        QuidObj qObj(quid);
        if (!elaborate)
            return qObj.ToString();
        String setName = "unknown";
        if ((qObj.Set() != 0) && (qObj.Set() == GetSetId()))
            setName = GetSetName();
        return "Q(" + QuidClassToString(qObj.Class()) + "," + setName + "," +
            GetFile(qObj.Object()) + "," +
            MakeString(qObj.Id()) + ")";
    }

    // Resolve the actual path to the video, only to be used for communication
    // with programs outside Impala
    String
    GetResolvedVideoPath(int fileId)
    {
        String path = FileNameConcat("VideoData", GetAsPath(fileId));
        typedef Persistency::RepositoryInFileSystem FS;
        Persistency::File file = FS::GetInstance().GetFile(GetLocator(), "",
                                                           path, false, false);
        return file.GetPath();
    }

    Stream::RgbDataSrc*
    GetVideoInLowResolution(int fileId, bool silent=false)
    {
        if ((fileId < 0) || (fileId >= NrFiles()))
            return 0;

        String path = FileNameConcat("Frames", GetAsPath(fileId)) +
                                     "/" + "images_jpg.raw";
#ifdef USE_IFILE
        path = "localfile:" + path;
#endif
        CmdOptions&  options    = CmdOptions::GetInstance();
        String       srcWndStr  = options.GetString("srcWindow");

        Stream::RgbDataSrcFactory& factory = Stream::RgbDataSrcFactory::Instance();

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
        Stream::RgbDataSrc* src =
            factory.ConstructWindow(path, "raw", srcWndStr, mDb);
#else // REPOSITORY_USED
        // need to resolve the path for LavcProtocol
        typedef Persistency::RepositoryInFileSystem FS;
        Persistency::File file =
            FS::GetInstance().GetFile(GetLocator(), "", path, false, silent);
        Persistency::RgbDataSrcLocator loc(GetLocator(), file.GetPath());
        Stream::RgbDataSrc* src = factory.ConstructWindow(loc, "raw", srcWndStr);
#endif // REPOSITORY_USED

        if (!src || !src->Valid())
        {
            if (!silent)
                ILOG_ERROR("Failed at initializing low res video data source");
            if (src)
                delete src;
            return 0;
        }

        return src;
    }

    Stream::RgbDataSrc*
    GetVideo(int fileId)
    {
        if ((fileId < 0) || (fileId >= NrFiles()))
            return 0;

        String dirOfFile = GetDirOfFile(fileId);
        String path;

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
        if (Link::DiskImage::DiskImageUsed() && 
            dirOfFile.find("//#") != String::npos)
        {
            String imagePath = mDb->GetFilePath(GetSectionOfFile(fileId),
                                                false, false);
            if (imagePath.empty())
            {
                ILOG_ERROR("disk image file not found");
                return 0;
            }
            path = "diskimage:" + imagePath + ':' + GetDirOfFile(fileId) + '/'
                + GetFileOrDir(fileId, ".mpg");
        }
        else
        {
            path = mDb->GetFilePath("VideoData", GetSectionOfFile(fileId),
                                    dirOfFile,
                                    GetFileOrDir(fileId, ".mpg"), false,
                                    false);
        }
#else // REPOSITORY_USED
        path = FileNameConcat("VideoData", GetAsPath(fileId));
#endif // REPOSITORY_USED

        CmdOptions& options = CmdOptions::GetInstance();

#ifdef USE_IFILE
        path = "localfile:" + path;
#endif

        Stream::RgbDataSrcFactory& factory =
            Stream::RgbDataSrcFactory::Instance();
#ifndef REPOSITORY_USED // Here comes the deprecated stuff
        Stream::RgbDataSrc* src =
            factory.ConstructWindow(path, options.GetString("src"),
                                    options.GetString("srcWindow"), mDb);
#else // REPOSITORY_USED
        // need to resolve the path for LavcProtocol
        typedef Persistency::RepositoryInFileSystem FS;
        Persistency::File file = FS::GetInstance().GetFile(GetLocator(), "",
                                                           path, false, false);
        //Persistency::RgbDataSrcLocator loc(GetLocator(), path);
        Persistency::RgbDataSrcLocator loc(GetLocator(), file.GetPath());
        Stream::RgbDataSrc* src =
            factory.ConstructWindow(loc, options.GetString("src"),
                                    options.GetString("srcWindow"));
#endif // REPOSITORY_USED

        if (!src || !src->Valid())
        {
            ILOG_ERROR("Failed at initializing data source");
            if (src)
                delete src;
            return 0;
        }

        return src;
    }

    // This function does not really belong here.
    // Should move to Persistency layer after RgbDataSrc refactoring.
    void
    DeleteVideoInfoFile(int fileId)
    {
        if ((fileId < 0) || (fileId >= NrFiles()))
            return;

        String path = FileNameConcat("VideoData", GetAsPath(fileId) + ".info");
        typedef Persistency::RepositoryInFileSystem FS;
        Persistency::File file = FS::GetInstance().GetFile(GetLocator(), "",
                                                           path, true, true);
        file.Delete();
    }

    int
    Diff(VideoSet* arg)
    {
        if (NrFiles() != arg->NrFiles())
        {
            ILOG_ERROR("Diff: nrFiles differs: " << NrFiles() << " vs " <<
                       arg->NrFiles());
            return 1;
        }
        int nDiff = 0;
        for (int i=0 ; i<NrFiles() ; i++)
        {
            if (GetAsPath(i) != arg->GetAsPath(i))
            {
                ILOG_DEBUG("File " << i << " differs " << GetAsPath(i) <<
                           " vs " << arg->GetAsPath(i));
                nDiff++;
            }
            else if (GetQuidVideo(i, false) != arg->GetQuidVideo(i, false))
            {
                ILOG_DEBUG("Quid " << i << " differs " << GetQuidVideo(i, false)
                           << " vs " << arg->GetQuidVideo(i, false));
                nDiff++;
            }
        }
        if (nDiff > 0)
            ILOG_ERROR("Found " << nDiff << " differences");
        return nDiff;
    }

    // I/O part

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
    void
    SaveVideoSet()
    {
        Save(GetFilePathVideoData(mSetName, true, false));
    }

    void
    UpdateVideoSet()
    {
        String fName = GetFilePathVideoData(mSetName, true, true);
        if (fName.empty()) // try force override thru read
            fName = GetFilePathVideoData(mSetName, false, false);
        Save(fName);
    }
#endif // REPOSITORY_USED

private:

    int mSetId;

    ILOG_VAR_DEC;
};

ILOG_VAR_INIT(VideoSet, Impala.Core.VideoSet);

} // namespace VideoSet
} // namespace Core
} // namespace Impala

#endif

---