DtIndirectTextureProcessor.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 2020 VT-MAK Technologies, Inc.
** All rights reserved.
******************************************************************************/


#pragma once
#include <vrvOsg/vrvOsg.h>

#include <vrvOsg/DtIndirectGeometryTextures.h>
#include <vrvOsg/DtOsgThreadingUtils.h>
#include <vrvOsg/DtMeifConverter.h>

#include <vrvCore/DtVirtualBaseClassCreator.h>

#include <tbb/atomic.h>

#include <boost/thread/condition_variable.hpp>

#include <string>

namespace makVrv
{
   class DtOsgCullVisitor;
   class DtOsgRenderer;
   class DtIndirectTextureResidencyManager;
   class DtWindow;
   class DtIndirectTextureProcessor;

   typedef DtVirtualBaseClassCreator<DtIndirectTextureProcessor> DtIndirectTextureProcessorCreator;

   template <>
   inline const char* creatorTypeName<DtIndirectTextureProcessor>(void) { return "DtIndirectTextureProcessorCreator"; }

   class DT_DLL_VRVOSG DtIndirectTextureProcessor : public osg::Referenced
   {
   public:
      // Inner class for creating a job that runs in the main thread.
      class LoadingJob : public osg::Operation
      {
      public:
         LoadingJob(DtIndirectTextureProcessor * proc);
         virtual ~LoadingJob();

         virtual void operator () (osg::Object * sv);

         virtual void release();

      protected:
         osg::ref_ptr <DtIndirectTextureProcessor> myTextureProcessor;
      };


      friend DtIndirectTextureProcessorCreator;

      virtual ~DtIndirectTextureProcessor();

   protected:

      DtIndirectTextureProcessor(DtDe& de);

   private:
      DtIndirectTextureProcessor() = delete;
      DtIndirectTextureProcessor(const DtIndirectTextureProcessor &other) = delete;
      DtIndirectTextureProcessor &operator=(const DtIndirectTextureProcessor &other);

   public:

      virtual void launchTextureLoadsIfNecessary(DtOsgRenderer* renderer);

      virtual void ts_addTexturesToLoad(int beforeTextureIndex, int afterTextureIndex, OsgTexturesArray& textures);

      virtual void ts_addTextureToLoad(osg::Texture* texture);

      virtual unsigned int streamTexturesToGpu(const osg::RenderInfo& renderInfo);

      virtual unsigned int texturesUpdatedFrameNum() const;

      virtual int numTexturesRemaining() const;

      virtual void releaseGLObjects(osg::State* state) const;

      virtual bool ts_setCompressionDisabledHint(osg::Image* image, bool val) const;

      virtual bool ts_compressionDisabledHint(osg::Image* image) const;

      virtual void stopWork();

      virtual int numTexturesToLoad() const;

      virtual int numTexturesLoading() const;

      virtual bool texureFailed(osg::Texture* texture) const;

      virtual bool inJobQueue() const;

      virtual boost::condition_variable& waitCondition();

      virtual bool inTextureToGCMap(const osg::GraphicsContext* graphicsContext, osg::Texture::TextureObject* textureObject) const;

      virtual void makeTexturesResidentIfNeeded(const osg::RenderInfo& renderInfo) const;

      virtual void setTextureLoadTimeSlicePeriod(float period);
      virtual float textureLoadTimeSlicePeriod(void) const;

   protected:

      // internal
      virtual void addTexturesToLoad(const DtIndirectGeometryTextures* osgGeometryTextures);

      virtual void addTextureToLoad(osg::Texture* texture);

      virtual osg::Operation * createJob();

      virtual void printStats(void) const;
   protected:

      typedef std::set<osg::ref_ptr<osg::Texture> > SetTextures;

      mutable SetTextures myMutableTexturesToLoad;
      mutable SetTextures myMutableTexturesLoading;
      mutable SetTextures myMutableTexturesLoaded;
      mutable SetTextures myMutableTexturesFailed;

      float myTextureLoadTimeSlicePeriod;

      tbb::atomic<bool> myInJobQueue;

      mutable unsigned int myTexturesUpdatedFrameNum;
      unsigned int myLastFrameNumber;
      DtMeifConverter myImageCompressor;
      bool myStopWork;
      mutable OpenThreads::Mutex myWorkMutex;
      boost::condition_variable myWaitCondition;

      DtIndirectTextureResidencyManager* myTextureResidencyManager;

      DtDe& myDe;
   };


}