summaryrefslogtreecommitdiffstats
path: root/src/uscxml/interpreter/BasicEventQueue.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/uscxml/interpreter/BasicEventQueue.cpp')
-rw-r--r--src/uscxml/interpreter/BasicEventQueue.cpp20
1 files changed, 10 insertions, 10 deletions
diff --git a/src/uscxml/interpreter/BasicEventQueue.cpp b/src/uscxml/interpreter/BasicEventQueue.cpp
index 3cf4daf..cc5ff04 100644
--- a/src/uscxml/interpreter/BasicEventQueue.cpp
+++ b/src/uscxml/interpreter/BasicEventQueue.cpp
@@ -36,11 +36,11 @@ Event BasicEventQueue::dequeue(size_t blockMs) {
if (blockMs > 0) {
- // block for given milliseconds or until queue is filled
- auto endTime = std::chrono::system_clock::now() + std::chrono::milliseconds(blockMs);
-
- while (_queue.empty()) {
- _cond.wait_until(_mutex, endTime);
+ // block for given milliseconds or until queue is filled
+ auto endTime = std::chrono::system_clock::now() + std::chrono::milliseconds(blockMs);
+
+ while (_queue.empty()) {
+ _cond.wait_until(_mutex, endTime);
}
}
@@ -61,8 +61,8 @@ void BasicEventQueue::enqueue(const Event& event) {
}
void BasicEventQueue::reset() {
- std::lock_guard<std::recursive_mutex> lock(_mutex);
- _queue.clear();
+ std::lock_guard<std::recursive_mutex> lock(_mutex);
+ _queue.clear();
}
static void dummyCallback(evutil_socket_t fd, short what, void *arg) {
@@ -198,9 +198,9 @@ void BasicDelayedEventQueue::stop() {
}
void BasicDelayedEventQueue::reset() {
- std::lock_guard<std::recursive_mutex> lock(_mutex);
- cancelAllDelayed();
- _queue.clear();
+ std::lock_guard<std::recursive_mutex> lock(_mutex);
+ cancelAllDelayed();
+ _queue.clear();
}
} \ No newline at end of file