DtDiGuyOctreeCullGroup.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2024 MAK Technologies, Inc.
 * All rights reserved.
 ****************************************************************************/


#pragma once

#include <osg/Group>
#include <osg/OperationThread>
#include <osg/Matrix>

#include <vrvDiGuy/vrvDiGuy.h>

#include <vrvMath/DtOctree.h>
#include <vrvMath/DtOctreeNode.h>

#include <tbb/concurrent_vector.h>
#include <tbb/mutex.h>
#include <tbb/task_arena.h>

namespace makVrv
{
   class DtOsgCullVisitor;
   class DtDiGuyScenario;
   class DtDe;
   class DtDiGuyOsgRootNode;
   class DtDiGuyInstanceDrawable;

   struct DtDiGuyCullData
   {
      DtDiGuyCullData() : myCameraMag(1.0f), myTraversalNum(0) {; }
      DtDiGuyCullData(DtOsgCullVisitor* dtcv, float culldistance);
      osg::Matrixd myProjectionMatrix;
      osg::Matrixd myViewMatrix;
      osg::Vec3d myCameraPosition;
      double myAltitude2D;
      float myCameraMag;
      unsigned int myTraversalNum;
      bool myOrthoCulling;
   };

   class DT_DLL_VRVDIGUY DtDiGuyInstanceTboUpdaterJob : public osg::Operation
   {
   public:
      friend class DtInstanceManagerTboUpdaterCreator;

      DtDiGuyInstanceTboUpdaterJob(DtDiGuyScenario& scenario, DtDe& de);

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

   private:

      DtDiGuyInstanceTboUpdaterJob();
      DtDiGuyInstanceTboUpdaterJob(const DtDiGuyInstanceTboUpdaterJob& other);
      DtDiGuyInstanceTboUpdaterJob& operator=(const DtDiGuyInstanceTboUpdaterJob& other);

   protected:

      DtDe& myDe;
      DtDiGuyScenario& myScenario;

   };


   class DT_DLL_VRVDIGUY DtDiGuyOctreeCullGroup : public osg::Group
   {
   public:

      DtDiGuyOctreeCullGroup(DtDiGuyScenario& scenario, tbb::concurrent_vector< DtDiGuyOsgRootNode*>& noninstancedarray,
         DtDiGuyInstanceDrawable& instanceDrawable);
      virtual ~DtDiGuyOctreeCullGroup();

      virtual void traverse(osg::NodeVisitor& nv);
      virtual void precull(const DtDiGuyCullData& pcd, bool async);
      virtual void setCullNeedsToRun(bool needsToRun);

      virtual  tbb::task_arena& taskArena();

      friend class DtDiGuyCullAsyncTask;
      friend class DtDiguyPreCullJob;

   protected:

      DtDiGuyScenario& myScenario;
      osg::ref_ptr<DtDiGuyInstanceTboUpdaterJob> myTboMainThreadUpdaterJob;
      DtDiGuyInstanceDrawable& myInstanceDrawable;
      tbb::concurrent_vector< DtDiGuyOsgRootNode*>& myNoninstancedNodeArray;
      tbb::mutex myAsyncMutex;
      bool myCullNeedsToRun;
      tbb::task_arena myTaskArena;
   };



   class DT_DLL_VRVDIGUY DtDiguyPreCullJob : public osg::Operation
   {
   public:
      DtDiguyPreCullJob(DtDiGuyScenario& scenario, DtDiGuyOctreeCullGroup& group);

   private:
      DtDiguyPreCullJob();
      DtDiguyPreCullJob(const DtDiguyPreCullJob &other);
      DtDiguyPreCullJob &operator=(const DtDiguyPreCullJob &other);

   public:

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

   protected:
      DtDiGuyOctreeCullGroup& myGroup;
      DtDiGuyScenario& myScenario;
      int myMaxThreadCount;

   };
}