X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=libs%2Fardour%2Fsession_events.cc;h=421c81d42cac7828793f8e7068a1074570fa9f80;hb=9a2164056752a958542f2d162ed3bf0f9c304121;hp=d48bbe3053c2b93b6de05f5d4f708a403d145512;hpb=9fdc36bac5fa1c004751c0dd42f9ff62b9d60814;p=ardour.git diff --git a/libs/ardour/session_events.cc b/libs/ardour/session_events.cc index d48bbe3053..421c81d42c 100644 --- a/libs/ardour/session_events.cc +++ b/libs/ardour/session_events.cc @@ -1,5 +1,5 @@ /* - Copyright (C) 1999-2004 Paul Davis + Copyright (C) 1999-2004 Paul Davis This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by @@ -15,80 +15,117 @@ along with this program; if not, write to the Free Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. - $Id$ */ #include #include -#include +#include "ardour/timestamps.h" -#include -#include +#include "pbd/error.h" +#include "pbd/enumwriter.h" +#include "pbd/stacktrace.h" -#include -#include -#include +#include "ardour/ardour.h" +#include "ardour/audio_diskstream.h" +#include "ardour/butler.h" +#include "ardour/debug.h" +#include "ardour/session_event.h" #include "i18n.h" +using namespace std; using namespace ARDOUR; -//using namespace sigc; - -MultiAllocSingleReleasePool Session::Event::pool ("event", sizeof (Session::Event), 512); - -static const char* event_names[] = { - "SetTransportSpeed", - "SetDiskstreamSpeed", - "Locate", - "LocateRoll", - "SetLoop", - "PunchIn", - "PunchOut", - "RangeStop", - "RangeLocate", - "Overwrite", - "SetSlaveSource", - "Audition", - "InputConfigurationChange", - "SetAudioRange", - "SetMusicRange", - "SetPlayRange", - "StopOnce", - "AutoLoop" -}; +using namespace PBD; + +PerThreadPool* SessionEvent::pool; + +void +SessionEvent::init_event_pool () +{ + pool = new PerThreadPool; +} + +void +SessionEvent::create_per_thread_pool (const std::string& name, uint32_t nitems) +{ + /* this is a per-thread call that simply creates a thread-private ptr to + a CrossThreadPool for use by this thread whenever events are allocated/released + from SessionEvent::pool() + */ + pool->create_per_thread_pool (name, sizeof (SessionEvent), nitems); +} + +void * +SessionEvent::operator new (size_t) +{ + CrossThreadPool* p = pool->per_thread_pool (); + SessionEvent* ev = static_cast (p->alloc ()); + DEBUG_TRACE (DEBUG::SessionEvents, string_compose ("%1 Allocating SessionEvent from %2 ev @ %3\n", pthread_self(), p->name(), ev)); +#ifndef NDEBUG + if (DEBUG::SessionEvents & PBD::debug_bits) { + stacktrace (cerr, 40); + } +#endif + ev->own_pool = p; + return ev; +} void -Session::add_event (jack_nframes_t frame, Event::Type type, jack_nframes_t target_frame) +SessionEvent::operator delete (void *ptr, size_t /*size*/) { - Event* ev = new Event (type, Event::Add, frame, target_frame, 0); + Pool* p = pool->per_thread_pool (); + SessionEvent* ev = static_cast (ptr); + + DEBUG_TRACE (DEBUG::SessionEvents, string_compose ( + "%1 Deleting SessionEvent @ %2 ev thread pool = %3 ev pool = %4\n", + pthread_self(), ev, p->name(), ev->own_pool->name() + )); + +#ifndef NDEBUG + if (DEBUG::SessionEvents & PBD::debug_bits) { + stacktrace (cerr, 40); + } +#endif + + if (p == ev->own_pool) { + p->release (ptr); + } else { + ev->own_pool->push (ev); + } +} + +void +SessionEventManager::add_event (framepos_t frame, SessionEvent::Type type, framepos_t target_frame) +{ + SessionEvent* ev = new SessionEvent (type, SessionEvent::Add, frame, target_frame, 0); queue_event (ev); } void -Session::remove_event (jack_nframes_t frame, Event::Type type) +SessionEventManager::remove_event (framepos_t frame, SessionEvent::Type type) { - Event* ev = new Event (type, Event::Remove, frame, 0, 0); + SessionEvent* ev = new SessionEvent (type, SessionEvent::Remove, frame, 0, 0); queue_event (ev); } void -Session::replace_event (Event::Type type, jack_nframes_t frame, jack_nframes_t target) +SessionEventManager::replace_event (SessionEvent::Type type, framepos_t frame, framepos_t target) { - Event* ev = new Event (type, Event::Replace, frame, target, 0); + SessionEvent* ev = new SessionEvent (type, SessionEvent::Replace, frame, target, 0); queue_event (ev); } void -Session::clear_events (Event::Type type) +SessionEventManager::clear_events (SessionEvent::Type type) { - Event* ev = new Event (type, Event::Clear, 0, 0, 0); + SessionEvent* ev = new SessionEvent (type, SessionEvent::Clear, 0, 0, 0); queue_event (ev); } void -Session::dump_events () const +SessionEventManager::dump_events () const { cerr << "EVENT DUMP" << endl; for (Events::const_iterator i = events.begin(); i != events.end(); ++i) { @@ -96,11 +133,11 @@ Session::dump_events () const } cerr << "Next event: "; - if ((Events::const_iterator) next_event == events.end()) { + if ((Events::const_iterator) next_event == events.end()) { cerr << "none" << endl; } else { - cerr << "at " << (*next_event)->action_frame << ' ' - << (*next_event)->type << " target = " + cerr << "at " << (*next_event)->action_frame << ' ' + << (*next_event)->type << " target = " << (*next_event)->target_frame << endl; } cerr << "Immediate events pending:\n"; @@ -111,34 +148,24 @@ Session::dump_events () const } void -Session::queue_event (Event* ev) -{ - if (_state_of_the_state & Loading) { - merge_event (ev); - } else { - pending_events.write (&ev, 1); - } -} - -void -Session::merge_event (Event* ev) +SessionEventManager::merge_event (SessionEvent* ev) { switch (ev->action) { - case Event::Remove: + case SessionEvent::Remove: _remove_event (ev); delete ev; return; - case Event::Replace: + case SessionEvent::Replace: _replace_event (ev); return; - case Event::Clear: + case SessionEvent::Clear: _clear_event_type (ev->type); delete ev; return; - - case Event::Add: + + case SessionEvent::Add: break; } @@ -148,33 +175,33 @@ Session::merge_event (Event* ev) process_event (ev); return; } - + switch (ev->type) { - case Event::AutoLoop: - case Event::StopOnce: + case SessionEvent::AutoLoop: + case SessionEvent::StopOnce: _clear_event_type (ev->type); break; default: for (Events::iterator i = events.begin(); i != events.end(); ++i) { if ((*i)->type == ev->type && (*i)->action_frame == ev->action_frame) { - error << string_compose(_("Session: cannot have two events of type %1 at the same frame (%2)."), - event_names[ev->type], ev->action_frame) << endmsg; + error << string_compose(_("Session: cannot have two events of type %1 at the same frame (%2)."), + enum_2_string (ev->type), ev->action_frame) << endmsg; return; } } } events.insert (events.begin(), ev); - events.sort (Event::compare); + events.sort (SessionEvent::compare); next_event = events.begin(); set_next_event (); } +/** @return true when @a ev is deleted. */ bool -Session::_replace_event (Event* ev) +SessionEventManager::_replace_event (SessionEvent* ev) { - // returns true when we deleted the passed in event bool ret = false; Events::iterator i; @@ -196,20 +223,20 @@ Session::_replace_event (Event* ev) events.insert (events.begin(), ev); } - events.sort (Event::compare); + events.sort (SessionEvent::compare); next_event = events.end(); set_next_event (); return ret; } +/** @return true when @a ev is deleted. */ bool -Session::_remove_event (Session::Event* ev) +SessionEventManager::_remove_event (SessionEvent* ev) { - // returns true when we deleted the passed in event bool ret = false; Events::iterator i; - + for (i = events.begin(); i != events.end(); ++i) { if ((*i)->type == ev->type && (*i)->action_frame == ev->action_frame) { if ((*i) == ev) { @@ -233,10 +260,10 @@ Session::_remove_event (Session::Event* ev) } void -Session::_clear_event_type (Event::Type type) +SessionEventManager::_clear_event_type (SessionEvent::Type type) { Events::iterator i, tmp; - + for (i = events.begin(); i != events.end(); ) { tmp = i; @@ -269,166 +296,3 @@ Session::_clear_event_type (Event::Type type) set_next_event (); } -void -Session::set_next_event () -{ - if (events.empty()) { - next_event = events.end(); - return; - } - - if (next_event == events.end()) { - next_event = events.begin(); - } - - if ((*next_event)->action_frame > _transport_frame) { - next_event = events.begin(); - } - - for (; next_event != events.end(); ++next_event) { - if ((*next_event)->action_frame >= _transport_frame) { - break; - } - } -} - -void -Session::process_event (Event* ev) -{ - bool remove = true; - bool del = true; - - /* if we're in the middle of a state change (i.e. waiting - for the butler thread to complete the non-realtime - part of the change), we'll just have to queue this - event for a time when the change is complete. - */ - - if (non_realtime_work_pending()) { - immediate_events.insert (immediate_events.end(), ev); - _remove_event (ev); - return; - } - - switch (ev->type) { - case Event::SetLoop: - set_auto_loop (ev->yes_or_no); - break; - - case Event::Locate: - if (ev->yes_or_no) { - // cerr << "forced locate to " << ev->target_frame << endl; - locate (ev->target_frame, false, true, false); - } else { - // cerr << "soft locate to " << ev->target_frame << endl; - start_locate (ev->target_frame, false, true, false); - } - break; - - case Event::LocateRoll: - if (ev->yes_or_no) { - // cerr << "forced locate to+roll " << ev->target_frame << endl; - locate (ev->target_frame, true, true, false); - } else { - // cerr << "soft locate to+roll " << ev->target_frame << endl; - start_locate (ev->target_frame, true, true, false); - } - break; - - case Event::SetTransportSpeed: - set_transport_speed (ev->speed, ev->yes_or_no); - break; - - case Event::PunchIn: - // cerr << "PunchIN at " << transport_frame() << endl; - if (punch_in && record_status() == Enabled) { - enable_record (); - } - remove = false; - del = false; - break; - - case Event::PunchOut: - // cerr << "PunchOUT at " << transport_frame() << endl; - if (punch_out) { - step_back_from_record (); - } - remove = false; - del = false; - break; - - case Event::StopOnce: - if (!non_realtime_work_pending()) { - stop_transport (ev->yes_or_no); - _clear_event_type (Event::StopOnce); - } - remove = false; - del = false; - break; - - case Event::RangeStop: - if (!non_realtime_work_pending()) { - stop_transport (ev->yes_or_no); - } - remove = false; - del = false; - break; - - case Event::RangeLocate: - start_locate (ev->target_frame, true, true, false); - remove = false; - del = false; - break; - - case Event::AutoLoop: - if (auto_loop) { - start_locate (ev->target_frame, true, false, seamless_loop); - } - remove = false; - del = false; - break; - - case Event::Overwrite: - overwrite_some_buffers (static_cast(ev->ptr)); - break; - - case Event::SetDiskstreamSpeed: - set_diskstream_speed (static_cast (ev->ptr), ev->speed); - break; - - case Event::SetSlaveSource: - set_slave_source (ev->slave, ev->target_frame); - break; - - case Event::Audition: - set_audition (static_cast (ev->ptr)); - break; - - case Event::InputConfigurationChange: - post_transport_work = PostTransportWork (post_transport_work | PostTransportInputChange); - schedule_butler_transport_work (); - break; - - case Event::SetAudioRange: - current_audio_range = ev->audio_range; - setup_auto_play (); - break; - - case Event::SetPlayRange: - set_play_range (ev->yes_or_no); - break; - - default: - fatal << string_compose(_("Programming error: illegal event type in process_event (%1)"), ev->type) << endmsg; - /*NOTREACHED*/ - break; - }; - - if (remove) { - del = del && !_remove_event (ev); - } - - if (del) { - delete ev; - } -}