cxVideoConnection.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 CXOPENIGTLINKRTSOURCE_H_
#define CXOPENIGTLINKRTSOURCE_H_

#include "org_custusx_core_video_Export.h"

#include <vector>
#include <map>
#include <boost/array.hpp>
#include "cxForwardDeclarations.h"

typedef vtkSmartPointer<class vtkImageImport> vtkImageImportPtr;
typedef vtkSmartPointer<class vtkImageAlgorithm> vtkImageAlgorithmPtr;
typedef boost::shared_ptr<QThread> QThreadPtr;

namespace cx
{
typedef boost::shared_ptr<class ProbeDefinition> ProbeDefinitionPtr;
typedef boost::shared_ptr<class StreamerService> StreamerServicePtr;
typedef boost::shared_ptr<class ImageReceiverThread> ImageReceiverThreadPtr;
typedef boost::shared_ptr<class BasicVideoSource> BasicVideoSourcePtr;
typedef boost::shared_ptr<class VideoServiceBackend> VideoServiceBackendPtr;

class org_custusx_core_video_EXPORT VideoConnection : public QObject
{
        Q_OBJECT

public:
        explicit VideoConnection(VideoServiceBackendPtr backend);
        virtual ~VideoConnection();
        virtual bool isConnected() const;
        void disconnectServer();
    void runDirectLinkClient(StreamerServicePtr service);
        std::vector<VideoSourcePtr> getVideoSources();

signals:
        bool connected(bool);
        void fps(QString source, int fps);
        void videoSourcesChanged();

private slots:
        void onConnected();
        void onDisconnected();
        void imageReceivedSlot();
        void statusReceivedSlot();
        void fpsSlot(QString, double fps);
        void connectVideoToProbe();
        void useUnusedProbeDefinitionSlot();

private:
        void waitForClientFinished();
        StreamerServicePtr getStreamerInterface();
        void updateImage(ImagePtr message); // called by receiving thread when new data arrives.
        void stopClient(); 
        void resetProbe();
        void updateStatus(ProbeDefinitionPtr message);
        void startAllSources();
        void stopAllSources();
        void removeSourceFromProbe(ToolPtr tool);

        QPointer<ImageReceiverThread> mClient;
        QPointer<QThread> mThread;

        double mFPS;
        std::vector<ProbeDefinitionPtr> mUnusedProbeDefinitionVector;
        std::vector<BasicVideoSourcePtr> mSources;
        VideoServiceBackendPtr mBackend;
        StreamerServicePtr mStreamerInterface;
};
typedef boost::shared_ptr<VideoConnection> VideoConnectionPtr;

} // namespace cx

#endif /* CXOPENIGTLINKRTSOURCE_H_ */