BasicDelayedEventQueue.h

Go to the documentation of this file.

#ifndef BASICDELAYEDEVENTQUEUE_H_49D837C4
#define BASICDELAYEDEVENTQUEUE_H_49D837C4

#include "BasicEventQueue.h"
#include <string>
#include <map>
#include <list>
#include <thread>
#include <mutex>
#include <condition_variable>

#include <event2/event.h>

namespace uscxml {

class USCXML_API BasicDelayedEventQueue : public BasicEventQueue, public DelayedEventQueueImpl {
public:
    BasicDelayedEventQueue(DelayedEventQueueCallbacks* callbacks);
    virtual ~BasicDelayedEventQueue();
    virtual std::shared_ptr<DelayedEventQueueImpl> create(DelayedEventQueueCallbacks* callbacks);
    virtual void enqueueDelayed(const Event& event, size_t delayMs, const std::string& eventUUID);
    virtual void cancelDelayed(const std::string& eventId);
    virtual void cancelAllDelayed();
    virtual Event dequeue(size_t blockMs) {
        return BasicEventQueue::dequeue(blockMs);
    }
    virtual void enqueue(const Event& event) {
        return BasicEventQueue::enqueue(event);
    }
    virtual void reset();

    virtual Data serialize();
    virtual void deserialize(const Data& data);

protected:
    virtual std::shared_ptr<EventQueueImpl> create() {
        ErrorEvent e("Cannot create a DelayedEventQueue without callbacks");
        throw e;
    }

    struct callbackData {
        Event userData;
        std::string eventUUID;
        bool persist;
        struct event *event;
        BasicDelayedEventQueue* eventQueue;
        timeval added;
        timeval due;
    };

    bool _isStarted;
    std::thread* _thread;

    std::map<std::string, callbackData> _callbackData;
    struct event_base* _eventLoop;
    struct event* _dummyEvent;

    static void run(void* instance);
    void start();
    void stop();

    static void timerCallback(evutil_socket_t fd, short what, void *arg);
    DelayedEventQueueCallbacks* _callbacks;
};

}

#endif /* end of include guard: BASICDELAYEDEVENTQUEUE_H_49D837C4 */