DtTcpTaskElement.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>

class DtInetSocket;
class DtInetTcpSocket;
class DtInetSocketMgr;

namespace makVrv
{
   class DtVideoFrameBuffer;

   class DT_DLL_VRVVIDEOSTREAM DtTcpTaskElement : public DtImageTaskElement
   {
   public: 
      friend class DtTcpTaskElementCreator;

      virtual ~DtTcpTaskElement();

      virtual void setPort( int port );

      virtual int port() const;

      virtual void setFromRecord( 
         const makArchives::DtImageTaskRecord& config );

      virtual bool configure();

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

      void handlePreFrame();

      void handleProcessFrame( DtVideoFrameBuffer* frame );

      bool handleSocketAddition( DtInetSocket* socket );

      bool handleSocketRemoval( DtInetSocket* socket );

   protected:
      static bool socketAdditionCallback(DtInetSocket* sock, void* usr);

      static bool socketRemovalCallback(DtInetSocket* sock, void* usr);

   private:
      DtTcpTaskElement();

      DtTcpTaskElement( const DtTcpTaskElement& orig );

      DtTcpTaskElement& operator=( const DtTcpTaskElement& rhs );


   protected:
      int myPort;
      DtInetSocketMgr* mySocketManager;
      DtInetTcpSocket* myConnectedSocket;
   };

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

      DtTcpTaskElementCreator();

      virtual ~DtTcpTaskElementCreator();

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