diff options
author | David Robillard <d@drobilla.net> | 2011-05-18 17:45:39 +0000 |
---|---|---|
committer | David Robillard <d@drobilla.net> | 2011-05-18 17:45:39 +0000 |
commit | 177f2b48b6516ba4dee70a709ce28105f1092de2 (patch) | |
tree | 84f6d9b9a026c6d35940e99f2981bd5be537548a /src/server/EventSource.hpp | |
parent | 27e3187270807c5e126a2e4bf66211de0f784a28 (diff) | |
download | ingen-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.hpp | 14 |
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 |