summaryrefslogtreecommitdiffstats
path: root/src/uscxml/concurrency/eventqueue/DelayedEventQueue.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/uscxml/concurrency/eventqueue/DelayedEventQueue.h')
-rw-r--r--src/uscxml/concurrency/eventqueue/DelayedEventQueue.h37
1 files changed, 18 insertions, 19 deletions
diff --git a/src/uscxml/concurrency/eventqueue/DelayedEventQueue.h b/src/uscxml/concurrency/eventqueue/DelayedEventQueue.h
index 024e353..8825c27 100644
--- a/src/uscxml/concurrency/eventqueue/DelayedEventQueue.h
+++ b/src/uscxml/concurrency/eventqueue/DelayedEventQueue.h
@@ -17,37 +17,36 @@ namespace uscxml {
class DelayedEventQueue {
public:
-
- struct callbackData
- {
- void *userData;
- void (*callback)(void*, const std::string eventId);
- std::string eventId;
- struct event *event;
- DelayedEventQueue* eventQueue;
- };
+
+ struct callbackData {
+ void *userData;
+ void (*callback)(void*, const std::string eventId);
+ std::string eventId;
+ struct event *event;
+ DelayedEventQueue* eventQueue;
+ };
DelayedEventQueue();
virtual ~DelayedEventQueue();
-
+
void addEvent(std::string eventId, void (*callback)(void*, const std::string eventId), uint32_t delayMs, void* userData);
void cancelEvent(std::string eventId);
-
+
void start();
void stop();
static void run(void*);
- static void timerCallback(evutil_socket_t fd, short what, void *arg);
- static void dummyCallback(evutil_socket_t fd, short what, void *arg);
+ static void timerCallback(evutil_socket_t fd, short what, void *arg);
+ static void dummyCallback(evutil_socket_t fd, short what, void *arg);
- bool _isStarted;
- tthread::thread* _thread;
- tthread::recursive_mutex _mutex;
-
- std::map<std::string, callbackData> _callbackData;
+ bool _isStarted;
+ tthread::thread* _thread;
+ tthread::recursive_mutex _mutex;
+
+ std::map<std::string, callbackData> _callbackData;
struct event_base* _eventLoop;
};
-
+
}