DtIndirectTextureProcessor.h

Go to the documentation of this file.

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


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

#include <vrvOsg/DtIndirectGeometryTextures.h>
#include <vrvOsg/DtOsgThreadingUtils.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;
   class DtIndirectGlTextureObjectManager;
   class DtIndirectGlTextureObject;
   class DtIndirectLimitTextureStrategy;

   typedef DtVirtualBaseClassCreator<DtIndirectTextureProcessor, const DtIndirectLimitTextureStrategy&> DtIndirectTextureProcessorCreator;

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

   class DT_DLL_VRVOSG DtIndirectTextureProcessor : public osg::Referenced
   {
   public:
      friend DtIndirectTextureProcessorCreator;

      virtual ~DtIndirectTextureProcessor();

   protected:
      DtIndirectTextureProcessor(DtDe& de, const DtIndirectLimitTextureStrategy& indirectLimitTextureStrategy);

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

      virtual void launchTextureLoadsIfNecessary(DtOsgRenderer* renderer);

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

      virtual void ts_addTextureToLoad(osg::Texture* texture, int flags);

      virtual void ts_unloadTextures(const std::set< osg::ref_ptr<osg::Texture> >& texturesToUnload);

      virtual void ts_moveToToLoadIfNotInToLoadOrLoadingOrNotLoaded(const std::map< osg::ref_ptr<osg::Texture>, int >& texturesToUnload);

      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 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, unsigned int textureObject) const;

      virtual bool readyForBindless(const DtIndirectGlTextureObject* indirectGlTextureObject, const osg::GraphicsContext* graphicsContext) const;

      virtual void makeTexturesResidentIfNeeded(const osg::GraphicsContext* graphicsContext) const;

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

      virtual DtIndirectGlTextureObject* getTextureObject(osg::ref_ptr<osg::Texture> osgTexture, int flags) const;

   protected:

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

      virtual void addTextureToLoad(osg::Texture* texture, int flags);

      virtual osg::Operation * createTextureLoadJob();

      virtual void printStats(void) const;
   protected:

      typedef std::set<osg::ref_ptr<osg::Texture> > SetTextures;
      typedef std::map<osg::ref_ptr<osg::Texture>, int > SetTexturesAndFlags;

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

      float myTextureLoadTimeSlicePeriod;

      tbb::atomic<bool> myInJobQueue;

      friend class DtIndirectTextureLoadJob;

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

      DtIndirectTextureResidencyManager* myTextureResidencyManager;

      DtDe& myDe;

      DtIndirectGlTextureObjectManager& myIndirectTextureObjectManager;

      const DtIndirectLimitTextureStrategy& myIndirectLimitTextureStrategy;

   };


}