DtSharedMemoryTaskElement.h

Go to the documentation of this file.

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


#pragma once

#include <vrvVideoStream/vrvVideoStream.h>
#include <vrvVideoStream/DtImageTaskElement.h>

#include <boost/interprocess/shared_memory_object.hpp>

#include <string>

namespace makVrv
{
   class DtVideoFrameBuffer;

   class DT_DLL_VRVVIDEOSTREAM DtSharedMemoryTaskElement : public DtImageTaskElement
   {
   public:
      struct DtSharedMemoryHeader
      {
         int currentFrame;
         bool readingFrame[3];
         int frameSize[3];
         int bufferSize;
         int width;
         int height;
         int format;
         int bpp;
         int packing;
      };

   public: 
      friend class DtSharedMemoryTaskElementCreator;

      virtual ~DtSharedMemoryTaskElement();

      virtual DtUnicode sharedMemoryName() const;

      virtual void setSharedMemoryName( const DtUnicode& name );

      virtual int bufferSize() const;

      virtual void setBufferSize( int bufferSize );
      
      virtual void setFromRecord( const makArchives::DtImageTaskRecord& config );
      
      virtual bool configure();

   protected:
      DtSharedMemoryTaskElement( DtDe& de, DtProcessImageTask* owningTask );

      void handleProcessFrame(DtVideoFrameBuffer* frame);

   private:
      DtSharedMemoryTaskElement();

      DtSharedMemoryTaskElement( const DtSharedMemoryTaskElement& orig );

      DtSharedMemoryTaskElement& operator=( const DtSharedMemoryTaskElement& rhs );

   protected:
      DtUnicode mySharedMemoryName;
      int myBufferSize;

      boost::interprocess::shared_memory_object* mySharedMemoryObj;
      boost::interprocess::mapped_region* myMappedRegion;
      DtSharedMemoryHeader* myHeader;
      char* myOffsets[3];
   };

   class DT_DLL_VRVVIDEOSTREAM DtSharedMemoryTaskElementCreator 
      : public DtImageTaskElementCreator
   {
   public:
      friend class DtVideoStreamManager;

      DtSharedMemoryTaskElementCreator();

      virtual ~DtSharedMemoryTaskElementCreator();

   protected:
      virtual DtImageTaskElement* create( DtDe& de, 
         DtProcessImageTask* owningTask );
   };
}