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

---

ThreadVirtual.h

Go to the documentation of this file.

#ifndef Impala_Core_Trec_ThreadVirtual_h
#define Impala_Core_Trec_ThreadVirtual_h

#include "Core/Trec/Thread.h"
#include "Core/VideoSet/TableShots.h"
#include "Core/Column/Find.h"

/*

Virtual thread: a thread consisting of the concationation of other threads,
this only works for static threads.

*/

namespace Impala
{
namespace Core
{
namespace Trec
{


class ThreadVirtual : public Thread
{
public:

    ThreadVirtual(std::string threadName) :
        Thread("virtual_" + threadName)
    {
    }


    virtual int
    GetShot(int position)
    {
        if ((position < 0) || (position >= GetLength()))
            return -1;

        for (int i=0; i<mThreads.size();i++)
        {
            if (position < mThreads[i]->GetLength())
                return mThreads[i]->GetShot(position);
            else
                position -= mThreads[i]->GetLength();
        }
        return -1;
    }

    virtual int
    GetLength()
    {
        int length = 0;
        for (int i=0;i<mThreads.size();i++)
            length += mThreads[i]->GetLength();
        return length;
    }

    virtual int
    GetShotAt(int shot, int offset)
    {
        int r = GetShotPosition(shot);
        return GetShot(r + offset);
    }

    virtual int
    GetShotPosition(int shot)
    {
        int pos = 0;
        for (int i=0; i<mThreads.size();i++)
        {
            int r = mThreads[i]->GetShotPosition(shot);
            if (r != -1)
                return pos + r;
            else
                pos += mThreads[i]->GetLength();
        }
        return -1;
    }

    virtual int
    GetType()
    {
        return VIRTUAL;
    }

    // add/remove threads to virtual thread
    void
    AddThread(Thread *t)
    {
        if (t && !HasThread(t))
            mThreads.push_back(t);
    }

    void
    RemoveThread(Thread *t)
    {
        std::vector<Thread*>::iterator i;
        bool somethingerased = true;
        while (somethingerased)
        {
            somethingerased = false;
            for (i = mThreads.begin(); i != mThreads.end(); i++)
            {
                if ((*i) == t)
                {
                    mThreads.erase(i);
                    somethingerased = true;
                    break;
                }
            }
        }
    }

    bool
    HasThread(Thread *t)
    {
        for (int i=0; i < mThreads.size(); i++)
        {
            if (mThreads[i] == t)
                return true;
        }
        return false;
    }


private:

    std::vector<Thread*>    mThreads;
    ILOG_VAR_DEC;

};

ILOG_VAR_INIT(ThreadVirtual, Core.Trec);

} // namespace Trec
} // namespace Core
} // namespace Impala

#endif

---