ossimImageChainMtAdaptor.h

Go to the documentation of this file.

//*************************************************************************************************
//                                            OSSIM
//
// License:  MIT -- See LICENSE.txt file in the top level directory for more details.
//
// Author: Oscar Kramer
//
//*************************************************************************************************
// $Id$
#ifndef ossimImageChainMtAdaptor_HEADER
#define ossimImageChainMtAdaptor_HEADER

#include <vector>
#include <ossim/imaging/ossimImageChain.h>
#include <ossim/parallel/ossimImageHandlerMtAdaptor.h>
#include <ossim/base/ossimId.h>
#include <ossim/base/ossimConnectableContainer.h>

//*************************************************************************************************
//*************************************************************************************************
class OSSIMDLLEXPORT ossimImageChainMtAdaptor : public ossimImageChain
{
   friend class ossimMultiThreadSequencer; //### FOR DEBUG ONLY

public:
   ossimImageChainMtAdaptor();

   ossimImageChainMtAdaptor(ossimImageChain* original, ossim_uint32 num_threads=0, bool use_shared_handlers=false, bool use_cache=false, ossim_uint32 cache_tile_size=64);
   ~ossimImageChainMtAdaptor();

   void setNumberOfThreads(ossim_uint32 num_threads);
   void setUseSharedHandlers(bool use_shared_handlers);
   void setCacheTileSize(ossim_uint32 cache_tile_size);
   void setUseCache(bool use_cache);

   void setOriginalChain(ossimImageChain* original);

   virtual ossimRefPtr<ossimImageData> getTile(const ossimIrect& tileRect,
                                               ossim_uint32 resLevel=0);
   
   virtual void initialize();

   virtual bool loadState(const ossimKeywordlist& kwl, const char* prefix=NULL);

   virtual bool saveState(ossimKeywordlist& kwl, const char* prefix=NULL)const;

   virtual void processEvent(ossimEvent& event);

   ossimImageSource* getClone(ossim_uint32 index);

   ossim_uint32 getNumberOfClones() const { return (ossim_uint32) m_clones.size(); }

   virtual ossimConnectableObject::ConnectableObjectList& imageChainList();
   virtual const ossimConnectableObject::ConnectableObjectList& imageChainList() const;

   virtual ossim_int32 connectMyOutputTo(ossimConnectableObject* outputObject,
                                         bool makeInputConnection=true,
                                         bool createEventFlag=true);

protected:
   void deleteReplicas();

   bool replicate();

   bool connectSharedHandlers(ossim_uint32 index);

   ossimRefPtr<ossimImageChain> m_adaptedChain;

   std::vector< ossimRefPtr<ossimImageSource> > m_clones;
   
   std::vector< ossimRefPtr<ossimConnectableContainer> > m_chainContainers;

   typedef std::vector<ossimRefPtr<ossimImageHandlerMtAdaptor> > SharedHandlerList;
   SharedHandlerList m_sharedHandlers;

   ossim_uint32 m_numThreads;

   bool d_useSharedHandlers;
   ossim_uint32 d_cacheTileSize;
   bool d_useCache;
   bool d_debugEnabled;

};
#endif /* #ifndef ossimImageChain_HEADER */