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

---

TableDataStore.h

Go to the documentation of this file.

//345678901234567890123456789012345678901234567890123456789012345678901234567890
#ifndef MediaTable_TableDataStore_h
#define MediaTable_TableDataStore_h

#include "TableDataView.h"
#include "TableDataSource.h"

#include "TableDataStoreListener.h"

#include "Application/videolympics/VideolympicsClient.h"

namespace Impala {
namespace Application {
namespace MediaTable {

class TableDataStore
{
public:
        typedef
    std::map<std::string, TableDataView*>                  TableDataViewsMapType;
        
    typedef
    std::pair<TableDataSource*, TableDataViewsMapType> TableDataSourceViewsType;
        
    typedef
    std::map<std::string, TableDataSourceViewsType>        TableDataSourceMapType;
        
    static void Initialize()
    {
        if (sInstance)
        {
            ILOG_WARN("TableDataStore already initialized. Skipping.");
            return;
        }
        sInstance = new TableDataStore();
    }   
        
    static TableDataStore* GetInstance()
    {
        if (!sInstance)
        {
            Initialize();
        }
        return sInstance;
    }
        
    void AddTableDataSource(std::string name, TableDataSource* source)
    {
        mTableDataSources[name].first = source;
        source->SetQuid(mNextTableDataSourceId++);
        ILOG_DEBUG("Added TableDataSource: " << name);
            DoTableDataStoreAddedTableDataSourceEvent();
    }

    TableDataView* GetTableDataView(std::string sourceAndView)
    {
        std::string::size_type loc = sourceAndView.find(":", 0 );
        if(loc != std::string::npos)
        {
                return GetTableDataView(sourceAndView.substr(0, loc),
                                                                        sourceAndView.substr(loc+1));
        }
        return 0;
    }

    TableDataView* GetTableDataView(std::string source, std::string view)
    {
        TableDataViewsMapType::iterator it;

        // Check if view already exists, otherwise return a new view
        it=mTableDataSources[source].second.find(view);
        if(it == mTableDataSources[source].second.end())
        {
                mTableDataSources[source].second[view] =
                new TableDataView(mTableDataSources[source].first);
            DoTableDataStoreAddedTableDataViewEvent();
        }
        return mTableDataSources[source].second[view];
    }

    Impala::Core::Array::Array2dVec3UInt8*
                GetImageDataByQuid(unsigned long long quid)
    {
        TableDataSourceMapType::iterator it;
        for(it = mTableDataSources.begin(); it != mTableDataSources.end(); it++)
        {
                // ToDo: This should be optimized! Now loops over all sources and all columns.
                Impala::Core::Array::Array2dVec3UInt8* img;
                img = it->second.first->GetImageDataByQuid(quid);
                if(img)
                        return img;
        }
        return 0;
    }

    std::map<std::string, std::vector<std::string> >
    GetContents()
    {
        std::map<std::string, std::vector<std::string> > contents;
        TableDataSourceMapType::iterator it;
        for(it = mTableDataSources.begin(); it != mTableDataSources.end(); it++)
        {
                        contents[it->first]; // RvB: For what purpose is this?
                                                                 //  DO: Probably to make sure the vector exists before
                                                                 //              pushing back? Does it still work without?
            TableDataViewsMapType& secsec = it->second.second;
            TableDataViewsMapType::iterator itv;
                for(itv = secsec.begin(); itv != secsec.end(); itv++)
                        contents[it->first].push_back(itv->first);
        }
        return contents;
    }

    int GetTableDataSourceCount()
    {
        return mTableDataSources.size();
    }
        
#ifdef MEDIATABLE_VIDEOLYMPICS
        Application::Videolympics::VideolympicsClient* GetVideOlympicsClient() {
                return mVideOlympicsClient;
        }
#endif                  

    void Clear()
    {
        delete sInstance;
        sInstance = new TableDataStore();
    }

    /* table listeners ******************************/
    void AddTableDataStoreListener(TableDataStoreListener* l)
    {
        mStoreListeners.push_back(l);
    }

    void DoUpdateTableDataStoreEvent()
    {
        for (int i=0; i< mStoreListeners.size(); i++)
            if (mStoreListeners[i]->GetListenTableUpdates())
                mStoreListeners[i]->UpdateTableDataStoreEvent();
    }

    void DoTableDataStoreAddedTableDataSourceEvent()
    {
        DoUpdateTableDataStoreEvent();
        for (int i=0; i< mStoreListeners.size(); i++)
            if (mStoreListeners[i]->GetListenTableUpdates())
                mStoreListeners[i]->TableDataStoreAddedTableDataSourceEvent();
    }

    void DoTableDataStoreAddedTableDataViewEvent()
    {
        DoUpdateTableDataStoreEvent();
        for (int i=0; i< mStoreListeners.size(); i++)
            if (mStoreListeners[i]->GetListenTableUpdates())
                mStoreListeners[i]->TableDataStoreAddedTableDataViewEvent();
    }

private:
    TableDataStore() // constructor: private
    {
        Init();
    }

    ~TableDataStore() // destructor: private
    {
        TableDataSourceMapType::reverse_iterator it;
        for(it = mTableDataSources.rbegin(); it != mTableDataSources.rend(); it++)
        {
            TableDataViewsMapType& secsec = it->second.second;
            TableDataViewsMapType::iterator itv;
                for(itv = secsec.begin(); itv != secsec.end(); itv++)
                        // Delete TableDataView
                        delete itv->second;
                // Delete TableDataSource
                delete it->second.first;
        }
    }

    // copy constructor: private
    TableDataStore(TableDataStore const&){};

    // assignment operator: private
    TableDataStore& operator=(TableDataStore const&){};

    void Init()
    {
        ILOG_DEBUG("Initializing TableDataStore");
        mNextTableDataSourceId = 1;
#ifdef MEDIATABLE_VIDEOLYMPICS
                InitVideOlympicsClient();
#endif          
    }

#ifdef MEDIATABLE_VIDEOLYMPICS
        void InitVideOlympicsClient()
        {
                CmdOptions& options = CmdOptions::GetInstance();
                // VideOlympics showcase event contest server connection
                if (!options.GetString("videolympicsServer").empty())
                {
                        ILOG_INFO("VideOlympics contest client: enabled.");
                        mVideOlympicsClient =
                        new Application::Videolympics::VideolympicsClient(
                                                                                                                          options.GetString("videolympicsServer"),
                                                                                                                          options.GetInt("videolympicsPort"),
                                                                                                                          options.GetInt("videolympicsTeam"));
                }
                else
                {
                        mVideOlympicsClient = NULL;
                        ILOG_DEBUG("VideOlympics contest client: disabled.");
                }
        }

        Application::Videolympics::VideolympicsClient *mVideOlympicsClient;
#endif
        
    TableDataSourceMapType                                      mTableDataSources;
    int                                                                         mNextTableDataSourceId;

    std::vector<TableDataStoreListener*>        mStoreListeners;

    static TableDataStore*                  sInstance;
        
    ILOG_VAR_DEC;
};

TableDataStore* TableDataStore::sInstance = 0;

ILOG_VAR_INIT(TableDataStore, Application.MediaTable);

} // namespace MediaTable
} // namespace Application
} // namespace Impala
#endif // TableDataStore_h

---