X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=libs%2Fardour%2Faudioengine.cc;h=3aa68478aad978ed930148a0fe0a07ee89fc2da6;hb=4cd2e73732f4bc5e56ba1d3533e33597fa0d3872;hp=2c16c52296a0bb8b0b0b2215ef5d97e3e3db2df7;hpb=c38e02285fda1fd7966c9e4ad85994445247e6a6;p=ardour.git diff --git a/libs/ardour/audioengine.cc b/libs/ardour/audioengine.cc index 2c16c52296..3aa68478aa 100644 --- a/libs/ardour/audioengine.cc +++ b/libs/ardour/audioengine.cc @@ -25,11 +25,17 @@ #include #include + #include "pbd/pthread_utils.h" #include "pbd/stacktrace.h" #include "pbd/unknown_type.h" +#include "pbd/epa.h" + +#include -#include "midi++/jack.h" +#include "midi++/port.h" +#include "midi++/mmc.h" +#include "midi++/manager.h" #include "ardour/amp.h" #include "ardour/audio_port.h" @@ -37,12 +43,13 @@ #include "ardour/buffer.h" #include "ardour/buffer_set.h" #include "ardour/cycle_timer.h" -#include "ardour/delivery.h" #include "ardour/event_type_map.h" #include "ardour/internal_return.h" +#include "ardour/internal_send.h" #include "ardour/io.h" #include "ardour/meter.h" #include "ardour/midi_port.h" +#include "ardour/process_thread.h" #include "ardour/port.h" #include "ardour/port_set.h" #include "ardour/session.h" @@ -61,50 +68,34 @@ AudioEngine* AudioEngine::_instance = 0; #define GET_PRIVATE_JACK_POINTER(j) jack_client_t* _priv_jack = (jack_client_t*) (j); if (!_priv_jack) { return; } #define GET_PRIVATE_JACK_POINTER_RET(j,r) jack_client_t* _priv_jack = (jack_client_t*) (j); if (!_priv_jack) { return r; } -AudioEngine::AudioEngine (string client_name) +AudioEngine::AudioEngine (string client_name, string session_uuid) : ports (new Ports) { _instance = this; /* singleton */ - session = 0; session_remove_pending = false; _running = false; _has_run = false; last_monitor_check = 0; - monitor_check_interval = max_frames; + monitor_check_interval = INT32_MAX; _processed_frames = 0; _usecs_per_cycle = 0; _jack = 0; _frame_rate = 0; _buffer_size = 0; - _freewheel_thread_registered = false; _freewheeling = false; + _pre_freewheel_mmc_enabled = false; + _main_thread = 0; + port_remove_in_progress = false; m_meter_thread = 0; g_atomic_int_set (&m_meter_exit, 0); - if (connect_to_jack (client_name)) { + if (connect_to_jack (client_name, session_uuid)) { throw NoBackendAvailable (); } Port::set_engine (this); - - // Initialize parameter metadata (e.g. ranges) - Evoral::Parameter p(NullAutomation); - p = EventTypeMap::instance().new_parameter(NullAutomation); - p = EventTypeMap::instance().new_parameter(GainAutomation); - p = EventTypeMap::instance().new_parameter(PanAutomation); - p = EventTypeMap::instance().new_parameter(PluginAutomation); - p = EventTypeMap::instance().new_parameter(SoloAutomation); - p = EventTypeMap::instance().new_parameter(MuteAutomation); - p = EventTypeMap::instance().new_parameter(MidiCCAutomation); - p = EventTypeMap::instance().new_parameter(MidiPgmChangeAutomation); - p = EventTypeMap::instance().new_parameter(MidiPitchBenderAutomation); - p = EventTypeMap::instance().new_parameter(MidiChannelPressureAutomation); - p = EventTypeMap::instance().new_parameter(FadeInAutomation); - p = EventTypeMap::instance().new_parameter(FadeOutAutomation); - p = EventTypeMap::instance().new_parameter(EnvelopeAutomation); - p = EventTypeMap::instance().new_parameter(MidiCCAutomation); } AudioEngine::~AudioEngine () @@ -135,12 +126,14 @@ _thread_init_callback (void * /*arg*/) knows about it. */ + pthread_set_name (X_("audioengine")); + PBD::notify_gui_about_thread_creation ("gui", pthread_self(), X_("Audioengine"), 4096); PBD::notify_gui_about_thread_creation ("midiui", pthread_self(), X_("Audioengine"), 128); SessionEvent::create_per_thread_pool (X_("Audioengine"), 512); - MIDI::JACK_MidiPort::set_process_thread (pthread_self()); + MIDI::Port::set_process_thread (pthread_self()); } static void @@ -149,54 +142,73 @@ ardour_jack_error (const char* msg) error << "JACK: " << msg << endmsg; } +void +AudioEngine::set_jack_callbacks () +{ + GET_PRIVATE_JACK_POINTER (_jack); + + if (jack_on_info_shutdown) { + jack_on_info_shutdown (_priv_jack, halted_info, this); + } else { + jack_on_shutdown (_priv_jack, halted, this); + } + + jack_set_thread_init_callback (_priv_jack, _thread_init_callback, this); + jack_set_process_thread (_priv_jack, _process_thread, this); + jack_set_sample_rate_callback (_priv_jack, _sample_rate_callback, this); + jack_set_buffer_size_callback (_priv_jack, _bufsize_callback, this); + jack_set_graph_order_callback (_priv_jack, _graph_order_callback, this); + jack_set_port_registration_callback (_priv_jack, _registration_callback, this); + jack_set_port_connect_callback (_priv_jack, _connect_callback, this); + jack_set_xrun_callback (_priv_jack, _xrun_callback, this); + jack_set_sync_callback (_priv_jack, _jack_sync_callback, this); + jack_set_freewheel_callback (_priv_jack, _freewheel_callback, this); + + if (_session && _session->config.get_jack_time_master()) { + jack_set_timebase_callback (_priv_jack, 0, _jack_timebase_callback, this); + } + +#ifdef HAVE_JACK_SESSION + if( jack_set_session_callback) + jack_set_session_callback (_priv_jack, _session_callback, this); +#endif + + if (jack_set_latency_callback) { + jack_set_latency_callback (_priv_jack, _latency_callback, this); + } + + jack_set_error_function (ardour_jack_error); +} + int AudioEngine::start () { - GET_PRIVATE_JACK_POINTER_RET (_jack, -1); + GET_PRIVATE_JACK_POINTER_RET (_jack, -1); if (!_running) { - nframes_t blocksize = jack_get_buffer_size (_priv_jack); + if (!jack_port_type_get_buffer_size) { + warning << _("This version of JACK is old - you should upgrade to a newer version that supports jack_port_type_get_buffer_size()") << endmsg; + } - if (session) { + if (_session) { BootMessage (_("Connect session to engine")); - - session->set_block_size (blocksize); - session->set_frame_rate (jack_get_sample_rate (_priv_jack)); - - /* page in as much of the session process code as we - can before we really start running. - */ - - session->process (blocksize); - session->process (blocksize); - session->process (blocksize); - session->process (blocksize); - session->process (blocksize); - session->process (blocksize); - session->process (blocksize); - session->process (blocksize); + _session->set_frame_rate (jack_get_sample_rate (_priv_jack)); } + /* a proxy for whether jack_activate() will definitely call the buffer size + * callback. with older versions of JACK, this function symbol will be null. + * this is reliable, but not clean. + */ + + if (!jack_port_type_get_buffer_size) { + jack_bufsize_callback (jack_get_buffer_size (_priv_jack)); + } + _processed_frames = 0; last_monitor_check = 0; - jack_on_shutdown (_priv_jack, halted, this); - jack_set_graph_order_callback (_priv_jack, _graph_order_callback, this); - jack_set_thread_init_callback (_priv_jack, _thread_init_callback, this); - jack_set_process_callback (_priv_jack, _process_callback, this); - jack_set_sample_rate_callback (_priv_jack, _sample_rate_callback, this); - jack_set_buffer_size_callback (_priv_jack, _bufsize_callback, this); - jack_set_xrun_callback (_priv_jack, _xrun_callback, this); - jack_set_sync_callback (_priv_jack, _jack_sync_callback, this); - jack_set_freewheel_callback (_priv_jack, _freewheel_callback, this); - jack_set_port_registration_callback (_priv_jack, _registration_callback, this); - - if (session && session->config.get_jack_time_master()) { - jack_set_timebase_callback (_priv_jack, 0, _jack_timebase_callback, this); - } - - jack_set_error_function (ardour_jack_error); + set_jack_callbacks (); if (jack_activate (_priv_jack) == 0) { _running = true; @@ -205,19 +217,15 @@ AudioEngine::start () } else { // error << _("cannot activate JACK client") << endmsg; } - - start_metering_thread(); - - _raw_buffer_sizes[DataType::AUDIO] = blocksize * sizeof(float); } - + return _running ? 0 : -1; } int AudioEngine::stop (bool forever) { - GET_PRIVATE_JACK_POINTER_RET (_jack, -1); + GET_PRIVATE_JACK_POINTER_RET (_jack, -1); if (_priv_jack) { if (forever) { @@ -225,20 +233,25 @@ AudioEngine::stop (bool forever) } else { jack_deactivate (_priv_jack); Stopped(); /* EMIT SIGNAL */ + MIDI::Port::JackHalted (); /* EMIT SIGNAL */ } } + if (forever) { + stop_metering_thread (); + } + return _running ? -1 : 0; } bool -AudioEngine::get_sync_offset (nframes_t& offset) const +AudioEngine::get_sync_offset (pframes_t& offset) const { #ifdef HAVE_JACK_VIDEO_SUPPORT - GET_PRIVATE_JACK_POINTER_RET (_jack, false); + GET_PRIVATE_JACK_POINTER_RET (_jack, false); jack_position_t pos; @@ -259,18 +272,18 @@ AudioEngine::get_sync_offset (nframes_t& offset) const } void -AudioEngine::_jack_timebase_callback (jack_transport_state_t state, nframes_t nframes, +AudioEngine::_jack_timebase_callback (jack_transport_state_t state, pframes_t nframes, jack_position_t* pos, int new_position, void *arg) { static_cast (arg)->jack_timebase_callback (state, nframes, pos, new_position); } void -AudioEngine::jack_timebase_callback (jack_transport_state_t state, nframes_t nframes, +AudioEngine::jack_timebase_callback (jack_transport_state_t state, pframes_t nframes, jack_position_t* pos, int new_position) { - if (_jack && session && session->synced_to_jack()) { - session->jack_timebase_callback (state, nframes, pos, new_position); + if (_jack && _session && _session->synced_to_jack()) { + _session->jack_timebase_callback (state, nframes, pos, new_position); } } @@ -283,8 +296,8 @@ AudioEngine::_jack_sync_callback (jack_transport_state_t state, jack_position_t* int AudioEngine::jack_sync_callback (jack_transport_state_t state, jack_position_t* pos) { - if (_jack && session) { - return session->jack_sync_callback (state, pos); + if (_jack && _session) { + return _session->jack_sync_callback (state, pos); } return true; @@ -300,79 +313,170 @@ AudioEngine::_xrun_callback (void *arg) return 0; } +#ifdef HAVE_JACK_SESSION +void +AudioEngine::_session_callback (jack_session_event_t *event, void *arg) +{ + AudioEngine* ae = static_cast (arg); + if (ae->connected()) { + ae->JackSessionEvent ( event ); /* EMIT SIGNAL */ + } +} +#endif + int AudioEngine::_graph_order_callback (void *arg) { AudioEngine* ae = static_cast (arg); - if (ae->connected()) { + + if (ae->connected() && !ae->port_remove_in_progress) { ae->GraphReordered (); /* EMIT SIGNAL */ } + return 0; } -/** Wrapped which is called by JACK as its process callback. It is just - * here to get us back into C++ land by calling AudioEngine::process_callback() - * @param nframes Number of frames passed by JACK. - * @param arg User argument passed by JACK, which will be the AudioEngine*. - */ -int -AudioEngine::_process_callback (nframes_t nframes, void *arg) +void* +AudioEngine::_process_thread (void *arg) { - return static_cast (arg)->process_callback (nframes); + return static_cast (arg)->process_thread (); } void AudioEngine::_freewheel_callback (int onoff, void *arg) { - static_cast(arg)->_freewheeling = onoff; + static_cast(arg)->freewheel_callback (onoff); +} + +void +AudioEngine::freewheel_callback (int onoff) +{ + _freewheeling = onoff; + + if (onoff) { + _pre_freewheel_mmc_enabled = MIDI::Manager::instance()->mmc()->send_enabled (); + MIDI::Manager::instance()->mmc()->enable_send (false); + } else { + MIDI::Manager::instance()->mmc()->enable_send (_pre_freewheel_mmc_enabled); + } } void AudioEngine::_registration_callback (jack_port_id_t /*id*/, int /*reg*/, void* arg) { AudioEngine* ae = static_cast (arg); - ae->PortRegisteredOrUnregistered (); /* EMIT SIGNAL */ + + if (!ae->port_remove_in_progress) { + ae->PortRegisteredOrUnregistered (); /* EMIT SIGNAL */ + } +} + +void +AudioEngine::_latency_callback (jack_latency_callback_mode_t mode, void* arg) +{ + return static_cast (arg)->jack_latency_callback (mode); } void -AudioEngine::split_cycle (nframes_t offset) +AudioEngine::_connect_callback (jack_port_id_t id_a, jack_port_id_t id_b, int conn, void* arg) +{ + AudioEngine* ae = static_cast (arg); + + if (ae->port_remove_in_progress) { + return; + } + + GET_PRIVATE_JACK_POINTER (ae->_jack); + + jack_port_t* jack_port_a = jack_port_by_id (_priv_jack, id_a); + jack_port_t* jack_port_b = jack_port_by_id (_priv_jack, id_b); + + boost::shared_ptr port_a; + boost::shared_ptr port_b; + + boost::shared_ptr pr = ae->ports.reader (); + Ports::iterator i = pr->begin (); + while (i != pr->end() && (port_a == 0 || port_b == 0)) { + if (jack_port_a == i->second->jack_port()) { + port_a = i->second; + } else if (jack_port_b == i->second->jack_port()) { + port_b = i->second; + } + ++i; + } + + ae->PortConnectedOrDisconnected ( + port_a, jack_port_name (jack_port_a), + port_b, jack_port_name (jack_port_b), + conn == 0 ? false : true + ); /* EMIT SIGNAL */ +} + +void +AudioEngine::split_cycle (pframes_t offset) { /* caller must hold process lock */ - Port::increment_port_offset (offset); + Port::increment_global_port_buffer_offset (offset); /* tell all Ports that we're going to start a new (split) cycle */ boost::shared_ptr p = ports.reader(); for (Ports::iterator i = p->begin(); i != p->end(); ++i) { - (*i)->cycle_split (); + i->second->cycle_split (); } } -/** Method called by JACK (via _process_callback) which says that there - * is work to be done. - * @param nframes Number of frames to process. +void* +AudioEngine::process_thread () +{ + /* JACK doesn't do this for us when we use the wait API + */ + + _thread_init_callback (0); + + _main_thread = new ProcessThread; + + while (1) { + GET_PRIVATE_JACK_POINTER_RET(_jack,0); + + pframes_t nframes = jack_cycle_wait (_priv_jack); + + if (process_callback (nframes)) { + return 0; + } + + jack_cycle_signal (_priv_jack, 0); + } + + return 0; +} + +/** Method called by our ::process_thread when there is work to be done. + * @param nframes Number of frames to process. */ int -AudioEngine::process_callback (nframes_t nframes) +AudioEngine::process_callback (pframes_t nframes) { - GET_PRIVATE_JACK_POINTER_RET(_jack,0) - // CycleTimer ct ("AudioEngine::process"); + GET_PRIVATE_JACK_POINTER_RET(_jack,0); Glib::Mutex::Lock tm (_process_lock, Glib::TRY_LOCK); + PT_TIMING_REF; + PT_TIMING_CHECK (1); + /// The number of frames that will have been processed when we've finished - nframes_t next_processed_frames; + pframes_t next_processed_frames; /* handle wrap around of total frames counter */ - if (max_frames - _processed_frames < nframes) { - next_processed_frames = nframes - (max_frames - _processed_frames); + if (max_framepos - _processed_frames < nframes) { + next_processed_frames = nframes - (max_framepos - _processed_frames); } else { next_processed_frames = _processed_frames + nframes; } - if (!tm.locked() || session == 0) { + if (!tm.locked() || _session == 0) { /* return having done nothing */ _processed_frames = next_processed_frames; return 0; @@ -380,7 +484,7 @@ AudioEngine::process_callback (nframes_t nframes) if (session_remove_pending) { /* perform the actual session removal */ - session = 0; + _session = 0; session_remove_pending = false; session_removed.signal(); _processed_frames = next_processed_frames; @@ -389,27 +493,33 @@ AudioEngine::process_callback (nframes_t nframes) /* tell all relevant objects that we're starting a new cycle */ - Delivery::CycleStart (nframes); - Port::set_port_offset (0); - InternalReturn::CycleStart (nframes); + InternalSend::CycleStart (nframes); + Port::set_global_port_buffer_offset (0); + Port::set_cycle_framecnt (nframes); /* tell all Ports that we're starting a new cycle */ boost::shared_ptr p = ports.reader(); for (Ports::iterator i = p->begin(); i != p->end(); ++i) { - (*i)->cycle_start (nframes); + i->second->cycle_start (nframes); } - if (_freewheeling) { - /* emit the Freewheel signal and stop freewheeling in the event of trouble */ - if (Freewheel (nframes)) { + /* test if we are freewheeling and there are freewheel signals connected. + ardour should act normally even when freewheeling unless /it/ is exporting */ + + + if (_freewheeling && !Freewheel.empty()) { + /* emit the Freewheel signal and stop freewheeling in the event of trouble + */ + boost::optional r = Freewheel (nframes); + if (r.get_value_or (0)) { jack_set_freewheel (_priv_jack, false); } } else { - if (session) { - session->process (nframes); + if (_session) { + _session->process (nframes); } } @@ -428,30 +538,27 @@ AudioEngine::process_callback (nframes_t nframes) for (Ports::iterator i = p->begin(); i != p->end(); ++i) { - Port *port = (*i); bool x; - if (port->_last_monitor != (x = port->monitoring_input ())) { - port->_last_monitor = x; + if (i->second->last_monitor() != (x = i->second->jack_monitoring_input ())) { + i->second->set_last_monitor (x); /* XXX I think this is dangerous, due to a likely mutex in the signal handlers ... */ - port->MonitorInputChanged (x); /* EMIT SIGNAL */ + i->second->MonitorInputChanged (x); /* EMIT SIGNAL */ } } last_monitor_check = next_processed_frames; } - if (session->silent()) { + if (_session->silent()) { boost::shared_ptr p = ports.reader(); for (Ports::iterator i = p->begin(); i != p->end(); ++i) { - Port *port = (*i); - - if (port->sends_output()) { - port->get_buffer(nframes).silence(nframes); + if (i->second->sends_output()) { + i->second->get_buffer(nframes).silence(nframes); } } } @@ -459,21 +566,24 @@ AudioEngine::process_callback (nframes_t nframes) // Finalize ports for (Ports::iterator i = p->begin(); i != p->end(); ++i) { - (*i)->cycle_end (nframes); + i->second->cycle_end (nframes); } _processed_frames = next_processed_frames; + + PT_TIMING_CHECK (2); + return 0; } int -AudioEngine::_sample_rate_callback (nframes_t nframes, void *arg) +AudioEngine::_sample_rate_callback (pframes_t nframes, void *arg) { return static_cast (arg)->jack_sample_rate_callback (nframes); } int -AudioEngine::jack_sample_rate_callback (nframes_t nframes) +AudioEngine::jack_sample_rate_callback (pframes_t nframes) { _frame_rate = nframes; _usecs_per_cycle = (int) floor ((((double) frames_per_cycle() / nframes)) * 1000000.0); @@ -483,8 +593,8 @@ AudioEngine::jack_sample_rate_callback (nframes_t nframes) monitor_check_interval = nframes / 10; last_monitor_check = 0; - if (session) { - session->set_frame_rate (nframes); + if (_session) { + _session->set_frame_rate (nframes); } SampleRateChanged (nframes); /* EMIT SIGNAL */ @@ -492,30 +602,67 @@ AudioEngine::jack_sample_rate_callback (nframes_t nframes) return 0; } +void +AudioEngine::jack_latency_callback (jack_latency_callback_mode_t mode) +{ + if (_session) { + _session->update_latency (mode == JackPlaybackLatency); + } +} + int -AudioEngine::_bufsize_callback (nframes_t nframes, void *arg) +AudioEngine::_bufsize_callback (pframes_t nframes, void *arg) { return static_cast (arg)->jack_bufsize_callback (nframes); } int -AudioEngine::jack_bufsize_callback (nframes_t nframes) +AudioEngine::jack_bufsize_callback (pframes_t nframes) { + /* if the size has not changed, this should be a no-op */ + + if (nframes == _buffer_size) { + return 0; + } + + GET_PRIVATE_JACK_POINTER_RET (_jack, 1); + _buffer_size = nframes; - _raw_buffer_sizes[DataType::AUDIO] = nframes * sizeof(float); - cout << "FIXME: Assuming maximum MIDI buffer size " << nframes * 4 << "bytes" << endl; - _raw_buffer_sizes[DataType::MIDI] = nframes * 4; _usecs_per_cycle = (int) floor ((((double) nframes / frame_rate())) * 1000000.0); last_monitor_check = 0; - boost::shared_ptr p = ports.reader(); + if (jack_port_type_get_buffer_size) { + _raw_buffer_sizes[DataType::AUDIO] = jack_port_type_get_buffer_size (_priv_jack, JACK_DEFAULT_AUDIO_TYPE); + _raw_buffer_sizes[DataType::MIDI] = jack_port_type_get_buffer_size (_priv_jack, JACK_DEFAULT_MIDI_TYPE); + } else { - for (Ports::iterator i = p->begin(); i != p->end(); ++i) { - (*i)->reset(); + /* Old version of JACK. + + These crude guesses, see below where we try to get the right answers. + + Note that our guess for MIDI deliberatey tries to overestimate + by a little. It would be nicer if we could get the actual + size from a port, but we have to use this estimate in the + event that there are no MIDI ports currently. If there are + the value will be adjusted below. + */ + + _raw_buffer_sizes[DataType::AUDIO] = nframes * sizeof (Sample); + _raw_buffer_sizes[DataType::MIDI] = nframes * 4 - (nframes/2); + } + + { + Glib::Mutex::Lock lm (_process_lock); + + boost::shared_ptr p = ports.reader(); + + for (Ports::iterator i = p->begin(); i != p->end(); ++i) { + i->second->reset(); + } } - if (session) { - session->set_block_size (_buffer_size); + if (_session) { + _session->set_block_size (_buffer_size); } return 0; @@ -536,7 +683,7 @@ AudioEngine::start_metering_thread () { if (m_meter_thread == 0) { g_atomic_int_set (&m_meter_exit, 0); - m_meter_thread = Glib::Thread::create (sigc::mem_fun(this, &AudioEngine::meter_thread), + m_meter_thread = Glib::Thread::create (boost::bind (&AudioEngine::meter_thread, this), 500000, true, true, Glib::THREAD_PRIORITY_NORMAL); } } @@ -544,12 +691,14 @@ AudioEngine::start_metering_thread () void AudioEngine::meter_thread () { + pthread_set_name (X_("meter")); + while (true) { Glib::usleep (10000); /* 1/100th sec interval */ if (g_atomic_int_get(&m_meter_exit)) { break; } - Metering::update_meters (); + Metering::Meter (); } } @@ -558,11 +707,13 @@ AudioEngine::set_session (Session *s) { Glib::Mutex::Lock pl (_process_lock); - if (!session) { + SessionHandlePtr::set_session (s); + + if (_session) { - session = s; + start_metering_thread (); - nframes_t blocksize = jack_get_buffer_size (_jack); + pframes_t blocksize = jack_get_buffer_size (_jack); /* page in as much of the session process code as we can before we really start running. @@ -571,20 +722,20 @@ AudioEngine::set_session (Session *s) boost::shared_ptr p = ports.reader(); for (Ports::iterator i = p->begin(); i != p->end(); ++i) { - (*i)->cycle_start (blocksize); + i->second->cycle_start (blocksize); } - s->process (blocksize); - s->process (blocksize); - s->process (blocksize); - s->process (blocksize); - s->process (blocksize); - s->process (blocksize); - s->process (blocksize); - s->process (blocksize); + _session->process (blocksize); + _session->process (blocksize); + _session->process (blocksize); + _session->process (blocksize); + _session->process (blocksize); + _session->process (blocksize); + _session->process (blocksize); + _session->process (blocksize); for (Ports::iterator i = p->begin(); i != p->end(); ++i) { - (*i)->cycle_end (blocksize); + i->second->cycle_end (blocksize); } } } @@ -596,13 +747,15 @@ AudioEngine::remove_session () if (_running) { - if (session) { + stop_metering_thread (); + + if (_session) { session_remove_pending = true; session_removed.wait(_process_lock); } } else { - session = 0; + SessionHandlePtr::set_session (0); } remove_all_ports (); @@ -611,7 +764,7 @@ AudioEngine::remove_session () void AudioEngine::port_registration_failure (const std::string& portname) { - GET_PRIVATE_JACK_POINTER (_jack); + GET_PRIVATE_JACK_POINTER (_jack); string full_portname = jack_client_name; full_portname += ':'; full_portname += portname; @@ -623,35 +776,29 @@ AudioEngine::port_registration_failure (const std::string& portname) if (p) { reason = string_compose (_("a port with the name \"%1\" already exists: check for duplicated track/bus names"), portname); } else { - reason = _("No more JACK ports are available. You will need to stop Ardour and restart JACK with ports if you need this many tracks."); + reason = string_compose (_("No more JACK ports are available. You will need to stop %1 and restart JACK with more ports if you need this many tracks."), PROGRAM_NAME); } throw PortRegistrationFailure (string_compose (_("AudioEngine: cannot register port \"%1\": %2"), portname, reason).c_str()); } -Port * +boost::shared_ptr AudioEngine::register_port (DataType dtype, const string& portname, bool input) { - Port* newport = 0; + boost::shared_ptr newport; try { if (dtype == DataType::AUDIO) { - newport = new AudioPort (portname, (input ? Port::IsInput : Port::IsOutput)); + newport.reset (new AudioPort (portname, (input ? Port::IsInput : Port::IsOutput))); } else if (dtype == DataType::MIDI) { - newport = new MidiPort (portname, (input ? Port::IsInput : Port::IsOutput)); + newport.reset (new MidiPort (portname, (input ? Port::IsInput : Port::IsOutput))); } else { throw PortRegistrationFailure("unable to create port (unknown type)"); } - size_t& old_buffer_size = _raw_buffer_sizes[newport->type()]; - size_t port_buffer_size = newport->raw_buffer_size(0); - if (port_buffer_size > old_buffer_size) { - old_buffer_size = port_buffer_size; - } - RCUWriter writer (ports); boost::shared_ptr ps = writer.get_copy (); - ps->insert (ps->begin(), newport); + ps->insert (make_pair (make_port_name_relative (portname), newport)); /* writer goes out of scope, forces update */ @@ -668,20 +815,20 @@ AudioEngine::register_port (DataType dtype, const string& portname, bool input) } } -Port * +boost::shared_ptr AudioEngine::register_input_port (DataType type, const string& portname) { return register_port (type, portname, true); } -Port * +boost::shared_ptr AudioEngine::register_output_port (DataType type, const string& portname) { return register_port (type, portname, false); } int -AudioEngine::unregister_port (Port& port) +AudioEngine::unregister_port (boost::shared_ptr port) { /* caller must hold process lock */ @@ -695,26 +842,23 @@ AudioEngine::unregister_port (Port& port) { RCUWriter writer (ports); boost::shared_ptr ps = writer.get_copy (); + Ports::iterator x = ps->find (make_port_name_relative (port->name())); - for (Ports::iterator i = ps->begin(); i != ps->end(); ++i) { - if ((*i) == &port) { - delete *i; - ps->erase (i); - break; - } + if (x != ps->end()) { + ps->erase (x); } /* writer goes out of scope, forces update */ } + ports.flush (); + return 0; } int AudioEngine::connect (const string& source, const string& destination) { - /* caller must hold process lock */ - int ret; if (!_running) { @@ -730,13 +874,13 @@ AudioEngine::connect (const string& source, const string& destination) string d = make_port_name_non_relative (destination); - Port* src = get_port_by_name_locked (s); - Port* dst = get_port_by_name_locked (d); + boost::shared_ptr src = get_port_by_name (s); + boost::shared_ptr dst = get_port_by_name (d); if (src) { - ret = src->connect (d); + ret = src->connect (d); } else if (dst) { - ret = dst->connect (s); + ret = dst->connect (s); } else { /* neither port is known to us, and this API isn't intended for use as a general patch bay */ ret = -1; @@ -756,8 +900,6 @@ AudioEngine::connect (const string& source, const string& destination) int AudioEngine::disconnect (const string& source, const string& destination) { - /* caller must hold process lock */ - int ret; if (!_running) { @@ -772,8 +914,8 @@ AudioEngine::disconnect (const string& source, const string& destination) string s = make_port_name_non_relative (source); string d = make_port_name_non_relative (destination); - Port* src = get_port_by_name_locked (s); - Port* dst = get_port_by_name_locked (d); + boost::shared_ptr src = get_port_by_name (s); + boost::shared_ptr dst = get_port_by_name (d); if (src) { ret = src->disconnect (d); @@ -787,9 +929,9 @@ AudioEngine::disconnect (const string& source, const string& destination) } int -AudioEngine::disconnect (Port& port) +AudioEngine::disconnect (boost::shared_ptr port) { - GET_PRIVATE_JACK_POINTER_RET (_jack,-1); + GET_PRIVATE_JACK_POINTER_RET (_jack,-1); if (!_running) { if (!_has_run) { @@ -800,17 +942,17 @@ AudioEngine::disconnect (Port& port) } } - return port.disconnect_all (); + return port->disconnect_all (); } -ARDOUR::nframes_t -AudioEngine::frame_rate () +ARDOUR::framecnt_t +AudioEngine::frame_rate () const { - GET_PRIVATE_JACK_POINTER_RET (_jack,0); + GET_PRIVATE_JACK_POINTER_RET (_jack, 0); if (_frame_rate == 0) { - return (_frame_rate = jack_get_sample_rate (_priv_jack)); + return (_frame_rate = jack_get_sample_rate (_priv_jack)); } else { - return _frame_rate; + return _frame_rate; } } @@ -821,71 +963,76 @@ AudioEngine::raw_buffer_size (DataType t) return (s != _raw_buffer_sizes.end()) ? s->second : 0; } -ARDOUR::nframes_t -AudioEngine::frames_per_cycle () +ARDOUR::pframes_t +AudioEngine::frames_per_cycle () const { - GET_PRIVATE_JACK_POINTER_RET (_jack,0); + GET_PRIVATE_JACK_POINTER_RET (_jack,0); if (_buffer_size == 0) { - return (_buffer_size = jack_get_buffer_size (_jack)); + return jack_get_buffer_size (_jack); } else { - return _buffer_size; + return _buffer_size; } } -/** @param name Full name of port (including prefix:) - * @return Corresponding Port*, or 0. This object remains the property of the AudioEngine - * so must not be deleted. +/** @param name Full or short name of port + * @return Corresponding Port or 0. */ -Port * -AudioEngine::get_port_by_name (const string& portname) -{ - string s; - if (portname.find_first_of (':') == string::npos) { - s = make_port_name_non_relative (portname); - } else { - s = portname; - } - Glib::Mutex::Lock lm (_process_lock); - return get_port_by_name_locked (s); -} - -Port * -AudioEngine::get_port_by_name_locked (const string& portname) +boost::shared_ptr +AudioEngine::get_port_by_name (const string& portname) { - /* caller must hold process lock */ - if (!_running) { if (!_has_run) { - fatal << _("get_port_by_name_locked() called before engine was started") << endmsg; + fatal << _("get_port_by_name() called before engine was started") << endmsg; /*NOTREACHED*/ } else { - return 0; + boost::shared_ptr (); } } - if (portname.substr (0, jack_client_name.length ()) != jack_client_name) { - /* not an ardour: port */ - return 0; - } - - std::string const rel = make_port_name_relative (portname); + if (!port_is_mine (portname)) { + /* not an ardour port */ + return boost::shared_ptr (); + } boost::shared_ptr pr = ports.reader(); - - for (Ports::iterator i = pr->begin(); i != pr->end(); ++i) { - if (rel == (*i)->name()) { - return *i; + std::string rel = make_port_name_relative (portname); + Ports::iterator x = pr->find (rel); + + if (x != pr->end()) { + /* its possible that the port was renamed by some 3rd party and + we don't know about it. check for this (the check is quick + and cheap), and if so, rename the port (which will alter + the port map as a side effect). + */ + const std::string check = make_port_name_relative (jack_port_name (x->second->jack_port())); + if (check != rel) { + x->second->set_name (check); } + return x->second; } - return 0; + return boost::shared_ptr (); +} + +void +AudioEngine::port_renamed (const std::string& old_relative_name, const std::string& new_relative_name) +{ + RCUWriter writer (ports); + boost::shared_ptr p = writer.get_copy(); + Ports::iterator x = p->find (old_relative_name); + + if (x != p->end()) { + boost::shared_ptr port = x->second; + p->erase (x); + p->insert (make_pair (new_relative_name, port)); + } } const char ** AudioEngine::get_ports (const string& port_name_pattern, const string& type_name_pattern, uint32_t flags) { - GET_PRIVATE_JACK_POINTER_RET (_jack,0); + GET_PRIVATE_JACK_POINTER_RET (_jack,0); if (!_running) { if (!_has_run) { fatal << _("get_ports called before engine was started") << endmsg; @@ -897,9 +1044,41 @@ AudioEngine::get_ports (const string& port_name_pattern, const string& type_name return jack_get_ports (_priv_jack, port_name_pattern.c_str(), type_name_pattern.c_str(), flags); } +void +AudioEngine::halted_info (jack_status_t code, const char* reason, void *arg) +{ + /* called from jack shutdown handler */ + + AudioEngine* ae = static_cast (arg); + bool was_running = ae->_running; + + ae->stop_metering_thread (); + + ae->_running = false; + ae->_buffer_size = 0; + ae->_frame_rate = 0; + ae->_jack = 0; + + if (was_running) { +#ifdef HAVE_JACK_ON_INFO_SHUTDOWN + switch (code) { + case JackBackendError: + ae->Halted(reason); /* EMIT SIGNAL */ + break; + default: + ae->Halted(""); /* EMIT SIGNAL */ + } +#else + ae->Halted(""); /* EMIT SIGNAL */ +#endif + } +} + void AudioEngine::halted (void *arg) { + cerr << "HALTED by JACK\n"; + /* called from jack shutdown handler */ AudioEngine* ae = static_cast (arg); @@ -910,9 +1089,11 @@ AudioEngine::halted (void *arg) ae->_running = false; ae->_buffer_size = 0; ae->_frame_rate = 0; + ae->_jack = 0; if (was_running) { - ae->Halted(); /* EMIT SIGNAL */ + ae->Halted(""); /* EMIT SIGNAL */ + MIDI::Port::JackHalted (); /* EMIT SIGNAL */ } } @@ -932,7 +1113,7 @@ AudioEngine::died () bool AudioEngine::can_request_hardware_monitoring () { - GET_PRIVATE_JACK_POINTER_RET (_jack,false); + GET_PRIVATE_JACK_POINTER_RET (_jack,false); const char ** ports; if ((ports = jack_get_ports (_priv_jack, NULL, JACK_DEFAULT_AUDIO_TYPE, JackPortCanMonitor)) == 0) { @@ -944,135 +1125,106 @@ AudioEngine::can_request_hardware_monitoring () return true; } - -uint32_t -AudioEngine::n_physical_outputs (DataType type) const +ChanCount +AudioEngine::n_physical (unsigned long flags) const { - GET_PRIVATE_JACK_POINTER_RET (_jack,0); - const char ** ports; - uint32_t i = 0; + ChanCount c; - if ((ports = jack_get_ports (_priv_jack, NULL, type.to_jack_type(), JackPortIsPhysical|JackPortIsInput)) == 0) { - return 0; + GET_PRIVATE_JACK_POINTER_RET (_jack, c); + + const char ** ports = jack_get_ports (_priv_jack, NULL, NULL, JackPortIsPhysical | flags); + if (ports == 0) { + return c; + } + + for (uint32_t i = 0; ports[i]; ++i) { + if (!strstr (ports[i], "Midi-Through")) { + DataType t (jack_port_type (jack_port_by_name (_jack, ports[i]))); + c.set (t, c.get (t) + 1); + } } - for (i = 0; ports[i]; ++i) {} free (ports); - return i; + return c; } -uint32_t -AudioEngine::n_physical_inputs (DataType type) const +ChanCount +AudioEngine::n_physical_inputs () const { - GET_PRIVATE_JACK_POINTER_RET (_jack,0); - const char ** ports; - uint32_t i = 0; - - if ((ports = jack_get_ports (_priv_jack, NULL, type.to_jack_type(), JackPortIsPhysical|JackPortIsOutput)) == 0) { - return 0; - } - - for (i = 0; ports[i]; ++i) {} - free (ports); + return n_physical (JackPortIsInput); +} - return i; +ChanCount +AudioEngine::n_physical_outputs () const +{ + return n_physical (JackPortIsOutput); } void -AudioEngine::get_physical_inputs (DataType type, vector& ins) +AudioEngine::get_physical (DataType type, unsigned long flags, vector& phy) { - GET_PRIVATE_JACK_POINTER (_jack); + GET_PRIVATE_JACK_POINTER (_jack); const char ** ports; - uint32_t i = 0; - - if ((ports = jack_get_ports (_priv_jack, NULL, type.to_jack_type(), JackPortIsPhysical|JackPortIsOutput)) == 0) { + if ((ports = jack_get_ports (_priv_jack, NULL, type.to_jack_type(), JackPortIsPhysical | flags)) == 0) { return; } if (ports) { - for (i = 0; ports[i]; ++i) { - ins.push_back (ports[i]); + for (uint32_t i = 0; ports[i]; ++i) { + if (strstr (ports[i], "Midi-Through")) { + continue; + } + phy.push_back (ports[i]); } free (ports); } } +/** Get physical ports for which JackPortIsOutput is set; ie those that correspond to + * a physical input connector. + */ void -AudioEngine::get_physical_outputs (DataType type, vector& outs) -{ - GET_PRIVATE_JACK_POINTER (_jack); - const char ** ports; - uint32_t i = 0; - - if ((ports = jack_get_ports (_priv_jack, NULL, type.to_jack_type(), JackPortIsPhysical|JackPortIsInput)) == 0) { - return; - } - - for (i = 0; ports[i]; ++i) { - outs.push_back (ports[i]); - } - free (ports); -} - -string -AudioEngine::get_nth_physical (DataType type, uint32_t n, int flag) +AudioEngine::get_physical_inputs (DataType type, vector& ins) { - GET_PRIVATE_JACK_POINTER_RET (_jack,""); - const char ** ports; - uint32_t i; - string ret; - - assert(type != DataType::NIL); - - if ((ports = jack_get_ports (_priv_jack, NULL, type.to_jack_type(), JackPortIsPhysical|flag)) == 0) { - return ret; - } - - for (i = 0; i < n && ports[i]; ++i) {} - - if (ports[i]) { - ret = ports[i]; - } - - free ((char *) ports); - - return ret; + get_physical (type, JackPortIsOutput, ins); } +/** Get physical ports for which JackPortIsInput is set; ie those that correspond to + * a physical output connector. + */ void -AudioEngine::update_total_latency (const Port& port) +AudioEngine::get_physical_outputs (DataType type, vector& outs) { - port.recompute_total_latency (); + get_physical (type, JackPortIsInput, outs); } void AudioEngine::transport_stop () { - GET_PRIVATE_JACK_POINTER (_jack); + GET_PRIVATE_JACK_POINTER (_jack); jack_transport_stop (_priv_jack); } void AudioEngine::transport_start () { - GET_PRIVATE_JACK_POINTER (_jack); + GET_PRIVATE_JACK_POINTER (_jack); jack_transport_start (_priv_jack); } void -AudioEngine::transport_locate (nframes_t where) +AudioEngine::transport_locate (framepos_t where) { - GET_PRIVATE_JACK_POINTER (_jack); - // cerr << "tell JACK to locate to " << where << endl; + GET_PRIVATE_JACK_POINTER (_jack); jack_transport_locate (_priv_jack, where); } AudioEngine::TransportState AudioEngine::transport_state () { - GET_PRIVATE_JACK_POINTER_RET (_jack, ((TransportState) JackTransportStopped)); + GET_PRIVATE_JACK_POINTER_RET (_jack, ((TransportState) JackTransportStopped)); jack_position_t pos; return (TransportState) jack_transport_query (_priv_jack, &pos); } @@ -1080,9 +1232,9 @@ AudioEngine::transport_state () int AudioEngine::reset_timebase () { - GET_PRIVATE_JACK_POINTER_RET (_jack, -1); - if (session) { - if (session->config.get_jack_time_master()) { + GET_PRIVATE_JACK_POINTER_RET (_jack, -1); + if (_session) { + if (_session->config.get_jack_time_master()) { return jack_set_timebase_callback (_priv_jack, 0, _jack_timebase_callback, this); } else { return jack_release_timebase (_jack); @@ -1094,59 +1246,73 @@ AudioEngine::reset_timebase () int AudioEngine::freewheel (bool onoff) { - GET_PRIVATE_JACK_POINTER_RET (_jack, -1); + GET_PRIVATE_JACK_POINTER_RET (_jack, -1); if (onoff != _freewheeling) { - - if (onoff) { - _freewheel_thread_registered = false; - } - - return jack_set_freewheel (_priv_jack, onoff); - + return jack_set_freewheel (_priv_jack, onoff); + } else { - /* already doing what has been asked for */ - return 0; + /* already doing what has been asked for */ + return 0; } } void AudioEngine::remove_all_ports () { - /* process lock MUST be held */ + /* make sure that JACK callbacks that will be invoked as we cleanup + * ports know that they have nothing to do. + */ + + port_remove_in_progress = true; + + /* process lock MUST be held by caller + */ { RCUWriter writer (ports); boost::shared_ptr ps = writer.get_copy (); - - for (Ports::iterator i = ps->begin(); i != ps->end(); ++i) { - delete *i; - } - ps->clear (); } - /* clear dead wood list too */ + /* clear dead wood list in RCU */ ports.flush (); + + port_remove_in_progress = false; } int -AudioEngine::connect_to_jack (string client_name) +AudioEngine::connect_to_jack (string client_name, string session_uuid) { + EnvironmentalProtectionAgency* global_epa = EnvironmentalProtectionAgency::get_global_epa (); + boost::scoped_ptr current_epa; jack_options_t options = JackNullOption; jack_status_t status; const char *server_name = NULL; + /* revert all environment settings back to whatever they were when ardour started + */ + + if (global_epa) { + current_epa.reset (new EnvironmentalProtectionAgency(true)); /* will restore settings when we leave scope */ + global_epa->restore (); + } + jack_client_name = client_name; /* might be reset below */ - _jack = jack_client_open (jack_client_name.c_str(), options, &status, server_name); +#ifdef HAVE_JACK_SESSION + if (! session_uuid.empty()) + _jack = jack_client_open (jack_client_name.c_str(), JackSessionID, &status, session_uuid.c_str()); + else +#endif + _jack = jack_client_open (jack_client_name.c_str(), options, &status, server_name); if (_jack == NULL) { // error message is not useful here return -1; } - GET_PRIVATE_JACK_POINTER_RET (_jack, -1); + GET_PRIVATE_JACK_POINTER_RET (_jack, -1); if (status & JackNameNotUnique) { jack_client_name = jack_get_client_name (_priv_jack); @@ -1158,7 +1324,7 @@ AudioEngine::connect_to_jack (string client_name) int AudioEngine::disconnect_from_jack () { - GET_PRIVATE_JACK_POINTER_RET (_jack, 0); + GET_PRIVATE_JACK_POINTER_RET (_jack, 0); if (_running) { stop_metering_thread (); @@ -1177,6 +1343,7 @@ AudioEngine::disconnect_from_jack () if (_running) { _running = false; Stopped(); /* EMIT SIGNAL */ + MIDI::Port::JackHalted (); /* EMIT SIGNAL */ } return 0; @@ -1191,7 +1358,7 @@ AudioEngine::reconnect_to_jack () Glib::usleep (250000); } - if (connect_to_jack (jack_client_name)) { + if (connect_to_jack (jack_client_name, "")) { error << _("failed to connect to JACK") << endmsg; return -1; } @@ -1201,7 +1368,7 @@ AudioEngine::reconnect_to_jack () boost::shared_ptr p = ports.reader (); for (i = p->begin(); i != p->end(); ++i) { - if ((*i)->reestablish ()) { + if (i->second->reestablish ()) { break; } } @@ -1212,34 +1379,19 @@ AudioEngine::reconnect_to_jack () return -1; } - GET_PRIVATE_JACK_POINTER_RET (_jack,-1); + GET_PRIVATE_JACK_POINTER_RET (_jack,-1); - if (session) { - session->reset_jack_connection (_priv_jack); - nframes_t blocksize = jack_get_buffer_size (_priv_jack); - session->set_block_size (blocksize); - session->set_frame_rate (jack_get_sample_rate (_priv_jack)); + MIDI::Manager::instance()->reestablish (_priv_jack); - _raw_buffer_sizes[DataType::AUDIO] = blocksize * sizeof(float); - cout << "FIXME: Assuming maximum MIDI buffer size " << blocksize * 4 << "bytes" << endl; - _raw_buffer_sizes[DataType::MIDI] = blocksize * 4; + if (_session) { + _session->reset_jack_connection (_priv_jack); + jack_bufsize_callback (jack_get_buffer_size (_priv_jack)); + _session->set_frame_rate (jack_get_sample_rate (_priv_jack)); } last_monitor_check = 0; - jack_on_shutdown (_priv_jack, halted, this); - jack_set_graph_order_callback (_priv_jack, _graph_order_callback, this); - jack_set_thread_init_callback (_priv_jack, _thread_init_callback, this); - jack_set_process_callback (_priv_jack, _process_callback, this); - jack_set_sample_rate_callback (_priv_jack, _sample_rate_callback, this); - jack_set_buffer_size_callback (_priv_jack, _bufsize_callback, this); - jack_set_xrun_callback (_priv_jack, _xrun_callback, this); - jack_set_sync_callback (_priv_jack, _jack_sync_callback, this); - jack_set_freewheel_callback (_priv_jack, _freewheel_callback, this); - - if (session && session->config.get_jack_time_master()) { - jack_set_timebase_callback (_priv_jack, 0, _jack_timebase_callback, this); - } + set_jack_callbacks (); if (jack_activate (_priv_jack) == 0) { _running = true; @@ -1251,9 +1403,11 @@ AudioEngine::reconnect_to_jack () /* re-establish connections */ for (i = p->begin(); i != p->end(); ++i) { - (*i)->reconnect (); + i->second->reconnect (); } + MIDI::Manager::instance()->reconnect (); + Running (); /* EMIT SIGNAL*/ start_metering_thread (); @@ -1262,28 +1416,19 @@ AudioEngine::reconnect_to_jack () } int -AudioEngine::request_buffer_size (nframes_t nframes) +AudioEngine::request_buffer_size (pframes_t nframes) { - GET_PRIVATE_JACK_POINTER_RET (_jack, -1); + GET_PRIVATE_JACK_POINTER_RET (_jack, -1); if (nframes == jack_get_buffer_size (_priv_jack)) { - return 0; + return 0; } - - return jack_set_buffer_size (_priv_jack, nframes); -} -void -AudioEngine::update_total_latencies () -{ -#ifdef HAVE_JACK_RECOMPUTE_LATENCIES - GET_PRIVATE_JACK_POINTER (_jack); - jack_recompute_total_latencies (_priv_jack); -#endif + return jack_set_buffer_size (_priv_jack, nframes); } string -AudioEngine::make_port_name_relative (string portname) +AudioEngine::make_port_name_relative (string portname) const { string::size_type len; string::size_type n; @@ -1304,7 +1449,7 @@ AudioEngine::make_port_name_relative (string portname) } string -AudioEngine::make_port_name_non_relative (string portname) +AudioEngine::make_port_name_non_relative (string portname) const { string str; @@ -1319,9 +1464,90 @@ AudioEngine::make_port_name_non_relative (string portname) return str; } +bool +AudioEngine::port_is_mine (const string& portname) const +{ + if (portname.find_first_of (':') != string::npos) { + if (portname.substr (0, jack_client_name.length ()) != jack_client_name) { + return false; + } + } + return true; +} + bool AudioEngine::is_realtime () const { - GET_PRIVATE_JACK_POINTER_RET (_jack,false); + GET_PRIVATE_JACK_POINTER_RET (_jack,false); return jack_is_realtime (_priv_jack); } + +int +AudioEngine::create_process_thread (boost::function f, pthread_t* thread, size_t stacksize) +{ + GET_PRIVATE_JACK_POINTER_RET (_jack, 0); + ThreadData* td = new ThreadData (this, f, stacksize); + + if (jack_client_create_thread (_priv_jack, thread, jack_client_real_time_priority (_priv_jack), + jack_is_realtime (_priv_jack), _start_process_thread, td)) { + return -1; + } + + return 0; +} + +void* +AudioEngine::_start_process_thread (void* arg) +{ + ThreadData* td = reinterpret_cast (arg); + boost::function f = td->f; + delete td; + + f (); + + return 0; +} + +bool +AudioEngine::port_is_physical (const std::string& portname) const +{ + GET_PRIVATE_JACK_POINTER_RET(_jack, false); + + jack_port_t *port = jack_port_by_name (_priv_jack, portname.c_str()); + + if (!port) { + return false; + } + + return jack_port_flags (port) & JackPortIsPhysical; +} + +void +AudioEngine::request_jack_monitors_input (const std::string& portname, bool yn) const +{ + GET_PRIVATE_JACK_POINTER(_jack); + + jack_port_t *port = jack_port_by_name (_priv_jack, portname.c_str()); + + if (!port) { + return; + } + + jack_port_request_monitor (port, yn); +} + +void +AudioEngine::update_latencies () +{ + if (jack_recompute_total_latencies) { + GET_PRIVATE_JACK_POINTER (_jack); + jack_recompute_total_latencies (_priv_jack); + } +} + +void +AudioEngine::destroy () +{ + delete _instance; + _instance = 0; +}