cxImageReceiverThread.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 CXImageReceiverThread_H_
#define CXImageReceiverThread_H_
 
#include "org_custusx_core_video_Export.h"
 
 
#include <vector>
#include "boost/shared_ptr.hpp"
#include <QThread>
#include <QMutex>
#include <QDateTime>
#include "cxForwardDeclarations.h"
 
namespace cx
{
typedef boost::shared_ptr<class Streamer> StreamerPtr;
typedef boost::shared_ptr<class StreamerService> StreamerServicePtr;
typedef boost::shared_ptr<class DirectlyLinkedSender> DirectlyLinkedSenderPtr;
typedef boost::shared_ptr<class ProbeDefinition> ProbeDefinitionPtr;
 
typedef boost::shared_ptr<class ImageReceiverThread> ImageReceiverThreadPtr;
 
class org_custusx_core_video_EXPORT ImageReceiverThread: public QObject
{
Q_OBJECT
public:
        ImageReceiverThread(StreamerServicePtr streamerInterface, QObject* parent = NULL);
        virtual ~ImageReceiverThread() {}
        virtual ImagePtr getLastImageMessage(); // threadsafe, Threadsafe retrieval of last image message.
        virtual ProbeDefinitionPtr getLastSonixStatusMessage(); // threadsafe,Threadsafe retrieval of last status message.
        virtual QString hostDescription() const; // threadsafe
 
public slots:
        void initialize(); // not threadsafe, call via postevent
        void shutdown(); // not threadsafe, call via postevent
 
signals:
        void imageReceived();
        void sonixStatusReceived();
        void fps(QString, double);
        void finished(); // emitted when object has completed shutdown
 
protected:
        void addImageToQueue(ImagePtr imgMsg);
        void addSonixStatusToQueue(ProbeDefinitionPtr msg); 
 
private slots:
 
        void addImageToQueueSlot();
        void addSonixStatusToQueueSlot();
 
private:
        void reportFPS(QString streamUid);
//      bool imageComesFromSonix(ImagePtr imgMsg);
        bool attemptInitialize();
 
        std::map<QString, cx::CyclicActionLoggerPtr> mFPSTimer;
        QMutex mImageMutex;
        QMutex mSonixStatusMutex;
        std::list<ImagePtr> mMutexedImageMessageQueue;
        std::list<ProbeDefinitionPtr> mMutexedSonixStatusMessageQueue;
 
//    StreamedTimestampSynchronizer mStreamSynchronizer;
 
        StreamerServicePtr mStreamerInterface;
        StreamerPtr mImageStreamer;
        DirectlyLinkedSenderPtr mSender;
 
};
 
} //end namespace cx
 
#endif /* CXImageReceiverThread_H_ */