DtThreadCameraStreamDataManager.h

Go to the documentation of this file.

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


#pragma once

#include <vrvOsg/vrvOsg.h>

#include <vrvCore/DtKeyedDataManagerTemplate.h>

#include <vrvUtil/DtVirtualBaseClassCreator.h>
#include <vrvUtil/DtSignalConnectionManager.h>
#include <vrvUtil/signalslib.h>

#include <osg/observer_ptr>

#include <tbb/concurrent_hash_map.h>
#include <tbb/concurrent_unordered_set.h>
#include <tbb/concurrent_vector.h>
#include <tbb/concurrent_queue.h>

#include <thread>
#include <boost/bind/bind.hpp>

namespace osg
{
   class Camera;
}

namespace makVrv
{
   class DtDe;

   class DtKeyedData;
   class DtKeyedDataUserData;

   struct DT_DLL_VRVOSG DtOsgTcsKeyType
   {
   public:
      DtOsgTcsKeyType();

      DtOsgTcsKeyType(const osg::Camera* osgCamera);

      ~DtOsgTcsKeyType();
   public:
      virtual bool valid(void) const;
   public:
      std::thread::id myThreadId;
      osg::observer_ptr<const osg::Camera> myOsgCameraObserver;
      void* myStream;

      std::string myName;
   };

   struct DtOsgTcsKeyTypeHasher
   {
      size_t hash(const DtOsgTcsKeyType& key) const;
      bool equal(const DtOsgTcsKeyType& lhs, const DtOsgTcsKeyType& rhs) const;

      static std::hash<std::thread::id> theThreadHasher;
   };

   typedef DtKeyedDataManagerTemplate< DtOsgTcsKeyType, DtOsgTcsKeyTypeHasher> DtThreadCameraStreamDataManagerBase;

   typedef DtVirtualBaseClassCreator<DtThreadCameraStreamDataManagerBase, const DtThreadCameraStreamDataManagerBase::FlushKeysLocation&> DtThreadCameraStreamDataManagerBaseCreator;

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

   class DT_DLL_VRVOSG DtThreadCameraStreamDataManager : public DtThreadCameraStreamDataManagerBase
   {
   public:
      virtual ~DtThreadCameraStreamDataManager();

      static DtThreadCameraStreamDataManager& instance(DtDe& de);
   protected:
      DtThreadCameraStreamDataManager(DtDe& de);
   private:
      DtThreadCameraStreamDataManager() = delete;
      DtThreadCameraStreamDataManager(const DtThreadCameraStreamDataManager& rhs) = delete;
      DtThreadCameraStreamDataManager& operator=(const DtThreadCameraStreamDataManager& rhs) = delete;
   };
}