/*
- Copyright (C) 2013 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
- the Free Software Foundation; either version 2 of the License, or
- (at your option) any later version.
-
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU General Public License for more details.
-
- You should have received a copy of the GNU General Public License
- along with this program; if not, write to the Free Software
- Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
-
-*/
+ * Copyright (C) 2013-2019 Paul Davis <paul@linuxaudiosystems.com>
+ * Copyright (C) 2015-2019 Robin Gareus <robin@gareus.org>
+ * Copyright (C) 2017-2018 Ben Loftis <ben@harrisonconsoles.com>
+ *
+ * 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
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ */
#include <vector>
/* limit the possible flags that can be set */
- flags = PortFlags (flags & (Hidden|Shadow|IsTerminal));
+ flags = PortFlags (flags & (Hidden|Shadow|IsTerminal|TransportMasterPort));
try {
if (dtype == DataType::AUDIO) {
throw PortRegistrationFailure (string_compose ("unable to create port '%1': %2", portname, _("(unknown type)")));
}
+ newport->set_buffer_size (AudioEngine::instance()->samples_per_cycle());
+
RCUWriter<Ports> writer (ports);
boost::shared_ptr<Ports> ps = writer.get_copy ();
ps->insert (make_pair (make_port_name_relative (portname), newport));
/* writer goes out of scope, forces update */
-
}
catch (PortRegistrationFailure& err) {
{
boost::shared_ptr<Ports> p = ports.reader ();
- if (!Profile->get_trx()) {
- /* re-establish connections */
+ /* re-establish connections */
- DEBUG_TRACE (DEBUG::Ports, string_compose ("reconnect %1 ports\n", p->size()));
+ DEBUG_TRACE (DEBUG::Ports, string_compose ("reconnect %1 ports\n", p->size()));
- for (Ports::iterator i = p->begin(); i != p->end(); ++i) {
- i->second->reconnect ();
- }
+ for (Ports::iterator i = p->begin(); i != p->end(); ++i) {
+ i->second->reconnect ();
}
return 0;
void
PortManager::connect_callback (const string& a, const string& b, bool conn)
{
+ DEBUG_TRACE (DEBUG::BackendCallbacks, string_compose (X_("connect callback %1 + %2 connected ? %3\n"), a, b, conn));
+
boost::shared_ptr<Port> port_a;
boost::shared_ptr<Port> port_b;
Ports::iterator x;
void
PortManager::registration_callback ()
{
+ DEBUG_TRACE (DEBUG::BackendCallbacks, "port registration callback\n");
+
if (!_port_remove_in_progress) {
{
int
PortManager::graph_order_callback ()
{
+ DEBUG_TRACE (DEBUG::BackendCallbacks, "graph order callback\n");
+
if (!_port_remove_in_progress) {
GraphReordered(); /* EMIT SIGNAL */
}
if (s && s->rt_tasklist () && fabs (Port::speed_ratio ()) != 1.0) {
RTTaskList::TaskList tl;
for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
- tl.push_back (boost::bind (&Port::cycle_start, p->second, nframes));
+ if (!(p->second->flags() & TransportMasterPort)) {
+ tl.push_back (boost::bind (&Port::cycle_start, p->second, nframes));
+ }
}
s->rt_tasklist()->process (tl);
} else {
for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
- p->second->cycle_start (nframes);
+ if (!(p->second->flags() & TransportMasterPort)) {
+ p->second->cycle_start (nframes);
+ }
}
}
}
PortManager::cycle_end (pframes_t nframes, Session* s)
{
// see optimzation note in ::cycle_start()
- if (s && s->rt_tasklist () && fabs (Port::speed_ratio ()) != 1.0) {
+ if (0 && s && s->rt_tasklist () && fabs (Port::speed_ratio ()) != 1.0) {
RTTaskList::TaskList tl;
for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
- tl.push_back (boost::bind (&Port::cycle_end, p->second, nframes));
+ if (!(p->second->flags() & TransportMasterPort)) {
+ tl.push_back (boost::bind (&Port::cycle_end, p->second, nframes));
+ }
}
s->rt_tasklist()->process (tl);
} else {
for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
- p->second->cycle_end (nframes);
+ if (!(p->second->flags() & TransportMasterPort)) {
+ p->second->cycle_end (nframes);
+ }
}
}
for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
- p->second->flush_buffers (nframes);
+ /* AudioEngine::split_cycle flushes buffers until Port::port_offset.
+ * Now only flush remaining events (after Port::port_offset) */
+ p->second->flush_buffers (nframes - Port::port_offset ());
}
_cycle_ports.reset ();
PortManager::cycle_end_fade_out (gain_t base_gain, gain_t gain_step, pframes_t nframes, Session* s)
{
// see optimzation note in ::cycle_start()
- if (s && s->rt_tasklist () && fabs (Port::speed_ratio ()) != 1.0) {
+ if (0 && s && s->rt_tasklist () && fabs (Port::speed_ratio ()) != 1.0) {
RTTaskList::TaskList tl;
for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
- tl.push_back (boost::bind (&Port::cycle_end, p->second, nframes));
+ if (!(p->second->flags() & TransportMasterPort)) {
+ tl.push_back (boost::bind (&Port::cycle_end, p->second, nframes));
+ }
}
s->rt_tasklist()->process (tl);
} else {
for (Ports::iterator p = _cycle_ports->begin(); p != _cycle_ports->end(); ++p) {
- p->second->cycle_end (nframes);
+ if (!(p->second->flags() & TransportMasterPort)) {
+ p->second->cycle_end (nframes);
+ }
}
}
for (vector<string>::iterator p = ports.begin(); p != ports.end(); ++p) {
- if (port_is_mine (*p)) {
+ /* ugly hack, ideally we'd use a port-flag, or at vkbd_output_port()->name() */
+ if (port_is_mine (*p) && *p != _backend->my_name() + ":" + _("Virtual Keyboard")) {
continue;
}
if (port_is_control_only (*p)) {
flags = MidiPortControl;
+ } else if (*p == _backend->my_name() + ":" + _("Virtual Keyboard")) {
+ flags = MidiPortFlags(MidiPortSelection | MidiPortMusic);
}
MidiPortInformation mpi (_backend->name(), *p, true, flags, true);
midi_info_dirty = false;
}
+
+void
+PortManager::set_port_buffer_sizes (pframes_t n)
+{
+
+ boost::shared_ptr<Ports> all = ports.reader();
+
+ for (Ports::iterator p = all->begin(); p != all->end(); ++p) {
+ p->second->set_buffer_size (n);
+ }
+}
projects / ardour.git / blobdiff