summaryrefslogtreecommitdiffstats
path: root/src/server/EventSource.hpp
diff options
context:
space:
mode:
authorDavid Robillard <d@drobilla.net>2011-05-18 17:45:39 +0000
committerDavid Robillard <d@drobilla.net>2011-05-18 17:45:39 +0000
commit177f2b48b6516ba4dee70a709ce28105f1092de2 (patch)
tree84f6d9b9a026c6d35940e99f2981bd5be537548a /src/server/EventSource.hpp
parent27e3187270807c5e126a2e4bf66211de0f784a28 (diff)
downloadingen-177f2b48b6516ba4dee70a709ce28105f1092de2.tar.gz
ingen-177f2b48b6516ba4dee70a709ce28105f1092de2.tar.bz2
ingen-177f2b48b6516ba4dee70a709ce28105f1092de2.zip
Use an intrusive linked list for event queue rather than Raul::List.
This avoids the need to allocate list nodes, improving performance (event throughput), and making EventSource::push_queued realtime safe. Remove unused queue_size parameter from EventSource and friends. git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@3282 a436a847-0d15-0410-975c-d299462d15a1
Diffstat (limited to 'src/server/EventSource.hpp')
-rw-r--r--src/server/EventSource.hpp14
1 files changed, 8 insertions, 6 deletions
diff --git a/src/server/EventSource.hpp b/src/server/EventSource.hpp
index 19d87ed9..5d3c1e14 100644
--- a/src/server/EventSource.hpp
+++ b/src/server/EventSource.hpp
@@ -18,9 +18,9 @@
#ifndef INGEN_ENGINE_EVENTSOURCE_HPP
#define INGEN_ENGINE_EVENTSOURCE_HPP
+#include "raul/AtomicPtr.hpp"
#include "raul/Semaphore.hpp"
#include "raul/Slave.hpp"
-#include "raul/List.hpp"
namespace Ingen {
namespace Server {
@@ -39,12 +39,12 @@ class ProcessContext;
class EventSource : protected Raul::Slave
{
public:
- explicit EventSource(size_t queue_size);
+ explicit EventSource();
virtual ~EventSource();
void process(PostProcessor& dest, ProcessContext& context, bool limit=true);
- bool empty() { return _events.empty(); }
+ bool empty() { return !_head.get(); }
/** Signal that a blocking event is finished.
*
@@ -61,9 +61,11 @@ protected:
virtual void _whipped(); ///< Prepare 1 event
private:
- Raul::List<Event*> _events;
- Raul::AtomicPtr<Raul::List<Event*>::Node> _prepared_back;
- Raul::Semaphore _blocking_semaphore;
+ Raul::AtomicPtr<QueuedEvent> _head;
+ Raul::AtomicPtr<QueuedEvent> _prepared_back;
+ Raul::AtomicPtr<QueuedEvent> _tail;
+
+ Raul::Semaphore _blocking_semaphore;
};
} // namespace Server