DtWebSocketTaskElement.h

Go to the documentation of this file.

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


#pragma once

#include <vrvWebSocket/vrvWebSocket.h>

#include <vrvVideoStream/DtImageTaskElement.h>

#include <string>

struct libwebsocket_context;

namespace makVrv
{
   class DT_DLL_VRVWEBSOCKET DtWebSocketTaskElement 
      : public DtImageTaskElement
   {
   public: 
      friend class DtWebSocketTaskElementCreator;

      virtual ~DtWebSocketTaskElement();

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

      virtual bool configure();

      DtLocklessQueue<std::string>& queue() {return *myCommandQueue;}

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

      void handlePreFrame();

      void handleProcessFrame(DtVideoFrameBuffer* frame);

      bool generateAndWriteHtml();

   protected:
      libwebsocket_context* myContext;
      DtLocklessQueue<std::string>* myCommandQueue;
      int myPort;
   };

   class DT_DLL_VRVWEBSOCKET DtWebSocketTaskElementCreator 
      : public DtImageTaskElementCreator
   {
   public:
      friend class DtVideoStreamManager;

      DtWebSocketTaskElementCreator();

      virtual ~DtWebSocketTaskElementCreator();

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