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_ */