cxImageStreamerSonix.h

Go to the documentation of this file.

/*=========================================================================
This file is part of CustusX, an Image Guided Therapy Application.
                 
Copyright (c) SINTEF Department of Medical Technology.
All rights reserved.
                 
CustusX is released under a BSD 3-Clause license.
                 
See Lisence.txt (https://github.com/SINTEFMedtek/CustusX/blob/master/License.txt) for details.
=========================================================================*/

#ifndef CXIMAGESTREAMERSONIX_H_
#define CXIMAGESTREAMERSONIX_H_

#ifdef CX_WIN32

#include "cxGrabberExport.h"

#include "boost/shared_ptr.hpp"
#include <QTcpSocket>
#include <QStringList>
#include <QMetaType>
#include <QMutex>
#include <vtkSmartPointer.h>
#include "cxImageSenderFactory.h"

#include "cxIGTLinkImageMessage.h"
#include "cxIGTLinkUSStatusMessage.h"
#include "vtkSonixVideoSource.h"
#include "SonixHelper.h"
#include "cxStreamer.h"

class QTimer;
typedef vtkSmartPointer<class vtkSonixVideoSource> vtkSonixVideoSourcePtr;

namespace cx
{

class cxGrabber_EXPORT ImageStreamerSonix : public CommandLineStreamer
{
  Q_OBJECT

public:
  ImageStreamerSonix();
  ~ImageStreamerSonix();
  
        virtual void initialize(StringMap arguments);
        virtual bool startStreaming(SenderPtr sender);
        virtual void stopStreaming();

        virtual QString getType();
        virtual QStringList getArgumentDescription();

public slots:
  void sendOpenIGTLinkImageSlot(int sendNumberOfMessages); 
  void sendOpenIGTLinkStatusSlot(int sendNumberOfMessages); 

signals:
    void imageOnQueue(int); 
    void queueInfo(int size, int dropped); 
    void statusOnQueue(int); 

protected:
    void initializeSonixGrabber();

private slots:
  void receiveFrameSlot(Frame& frame);
  void initializeSonixSlot();

private:
  IGTLinkImageMessage::Pointer convertFrame(Frame& frame);
  IGTLinkUSStatusMessage::Pointer getFrameStatus(Frame& frame);

  void addImageToQueue(IGTLinkImageMessage::Pointer msg); 
  IGTLinkImageMessage::Pointer getLastImageMessageFromQueue(); 

  void addStatusMessageToQueue(IGTLinkUSStatusMessage::Pointer msg); 
  IGTLinkUSStatusMessage::Pointer getLastStatusMessageFromQueue(); 

  std::string createDeviceName();

  QMutex mImageMutex; 
  int mMaxqueueInfo;
  std::list<IGTLinkImageMessage::Pointer> mMutexedImageMessageQueue; 
  int mDroppedImages;

  QMutex mStatusMutex; 
  std::list<IGTLinkUSStatusMessage::Pointer> mMutexedStatusMessageQueue; 

  bool mEmitStatusMessage; 
  double mLastFrameTimestamp; 
  double mCurrentFrameTimestamp; 

  vtkSonixVideoSourcePtr  mSonixGrabber; 
  SonixHelper*          mSonixHelper; 

};

}//namespace cx

//Declaration of a frame metatype needed to be able to send frame as a signal.
//typedef cx::Frame Frame;
//Q_DECLARE_METATYPE(Frame)

#endif // CX_WIN32

#endif /* CXIMAGESTREAMERSONIX_H_ */