using namespace ARDOUR;
AudioEngine* Port::_engine = 0;
-nframes_t Port::_port_offset = 0;
-nframes_t Port::_buffer_size = 0;
+pframes_t Port::_buffer_size = 0;
+bool Port::_connecting_blocked = false;
/** @param n Port short name */
Port::Port (std::string const & n, DataType t, Flags f)
assert (_name.find_first_of (':') == std::string::npos);
+ if (!_engine->connected()) {
+ throw failed_constructor ();
+ }
+
if ((_jack_port = jack_port_register (_engine->jack (), _name.c_str (), t.to_jack_type (), _flags, 0)) == 0) {
+ cerr << "Failed to register JACK port, reason is unknown from here\n";
throw failed_constructor ();
}
}
/** Port destructor */
Port::~Port ()
{
- jack_port_unregister (_engine->jack (), _jack_port);
+ if (_engine->jack ()) {
+ jack_port_unregister (_engine->jack (), _jack_port);
+ }
}
/** @return true if this port is connected to anything */
c.push_back (jc[i]);
++n;
}
- free (jc);
+
+ jack_free (jc);
}
return n;
int
Port::connect (std::string const & other)
{
- /* caller must hold process lock */
-
std::string const other_shrt = _engine->make_port_name_non_relative (other);
std::string const this_shrt = _engine->make_port_name_non_relative (_name);
int r = 0;
+ if (_connecting_blocked) {
+ return r;
+ }
+
if (sends_output ()) {
r = jack_connect (_engine->jack (), this_shrt.c_str (), other_shrt.c_str ());
} else {
int
Port::disconnect (std::string const & other)
{
- /* caller must hold process lock */
-
std::string const other_shrt = _engine->make_port_name_non_relative (other);
std::string const this_shrt = _engine->make_port_name_non_relative (_name);
_connections.erase (other);
}
-return r;
+ return r;
}
Port::recompute_total_latency () const
{
#ifdef HAVE_JACK_RECOMPUTE_LATENCY
- jack_recompute_total_latency (_engine->jack (), _jack_port);
+ jack_client_t* jack = _engine->jack();
+
+ if (!jack) {
+ return;
+ }
+
+ jack_recompute_total_latency (jack, _jack_port);
#endif
}
-nframes_t
+framecnt_t
Port::total_latency () const
{
- return jack_port_get_total_latency (_engine->jack (), _jack_port);
+ jack_client_t* jack = _engine->jack();
+
+ if (!jack) {
+ return 0;
+ }
+
+ return jack_port_get_total_latency (jack, _jack_port);
}
int
Port::reestablish ()
{
+ jack_client_t* jack = _engine->jack();
+
+ if (!jack) {
+ return -1;
+ }
+
cerr << "RE-REGISTER: " << _name.c_str() << endl;
- _jack_port = jack_port_register (_engine->jack(), _name.c_str(), type().to_jack_type(), _flags, 0);
+ _jack_port = jack_port_register (jack, _name.c_str(), type().to_jack_type(), _flags, 0);
if (_jack_port == 0) {
PBD::error << string_compose (_("could not reregister %1"), _name) << endmsg;
}
void
-Port::set_latency (nframes_t n)
+Port::set_latency (framecnt_t n)
{
jack_port_set_latency (_jack_port, n);
}
+bool
+Port::physically_connected () const
+{
+ const char** jc = jack_port_get_connections (_jack_port);
+
+ if (jc) {
+ for (int i = 0; jc[i]; ++i) {
+
+ jack_port_t* port = jack_port_by_name (_engine->jack(), jc[i]);
+
+ if (port && (jack_port_flags (port) & JackPortIsPhysical)) {
+ jack_free (jc);
+ return true;
+ }
+ }
+
+ jack_free (jc);
+ }
+
+ return false;
+}
+