DummyGrabber.h

Go to the documentation of this file.

#ifndef __DUMMYGRABBER_H
#define __DUMMYGRABBER_H

#include <ImageGrabber.h>
#include <RocServer.h>

#include <list>
#include <string>
#include <vector>
#include <thread>
#include <atomic>
#include <condition_variable>

#include <Envi.h>

class DummyGrabberSynchronizer;

class DummyException: public std::exception {
public:
    DummyException(const std::string & _message);
    ~DummyException() throw();
    virtual const char* what() const throw();
private:
    std::string message;
};

class _DummyGrabberImpl : public _ImageGrabberImpl, public RocServer {
    friend ImageGrabber;
private:
    _DummyGrabberImpl(const std::string & _deviceName,
                      const std::string & _deviceSource,
                      zmq::context_t & _ctx,
                      const std::string & _brokerEndpoint
                     );
    ~_DummyGrabberImpl();

    int getWidth();
    int getHeight();
    int getBytesPerPixel();
    void startServing();
    void stopServing();
    void acquisition();
    void acquireBuffer(int bufferId);
    void releaseBuffer(int bufferId);
    void addEndpoint(const std::string & _endpoint);

    EnviFile dummyFile;
    zmq::context_t & ctx;
    std::string deviceName;
    std::string deviceSource;

    std::list<std::string> endpoints;
    volatile bool enableAcquisition;
    std::thread acquisitionThread;

    std::vector<std::atomic<int>*> bufferUsers;
    std::atomic<int> openBuffers;
    std::atomic<int> totalBufferUsers;
    std::condition_variable bufferFreeNotifier;

    Json::Value call(const std::string & name, const Json::Value & arguments);
    Json::Value getattr(const std::string & name);
    void setattr(const std::string & name, const Json::Value & value);

    bool shutterClosed;
    float fps;
    float tint;

    uint32_t maxValue;

    void sendStatus();

    std::string rocsHeader;
    zmq::socket_t rocsSocket;

    DummyGrabberSynchronizer& synchronizer;
};

#endif // __DUMMYGRABBER_H