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