summaryrefslogtreecommitdiffstats
path: root/include/ingen/QueuedInterface.hpp
diff options
context:
space:
mode:
Diffstat (limited to 'include/ingen/QueuedInterface.hpp')
-rw-r--r--include/ingen/QueuedInterface.hpp14
1 files changed, 6 insertions, 8 deletions
diff --git a/include/ingen/QueuedInterface.hpp b/include/ingen/QueuedInterface.hpp
index 97fbb731..ab2c2532 100644
--- a/include/ingen/QueuedInterface.hpp
+++ b/include/ingen/QueuedInterface.hpp
@@ -17,11 +17,10 @@
#ifndef INGEN_QUEUEDINTERFACE_HPP
#define INGEN_QUEUEDINTERFACE_HPP
-#include "ingen/Interface.hpp"
-#include "ingen/Message.hpp"
-#include "ingen/URI.hpp"
+#include <ingen/Interface.hpp>
+#include <ingen/Message.hpp>
+#include <ingen/URI.hpp>
-#include <algorithm>
#include <memory>
#include <mutex>
#include <utility>
@@ -38,20 +37,19 @@ class QueuedInterface : public Interface
public:
explicit QueuedInterface(std::shared_ptr<Interface> sink)
: _sink(std::move(sink))
- {
- }
+ {}
URI uri() const override { return URI("ingen:/QueuedInterface"); }
void message(const Message& message) override {
- std::lock_guard<std::mutex> lock(_mutex);
+ const std::lock_guard<std::mutex> lock{_mutex};
_messages.emplace_back(message);
}
void emit() {
std::vector<Message> messages;
{
- std::lock_guard<std::mutex> lock(_mutex);
+ const std::lock_guard<std::mutex> lock{_mutex};
_messages.swap(messages);
}