summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorCarl Hetherington <carl@carlh.net>2010-07-06 00:27:03 +0000
committerCarl Hetherington <carl@carlh.net>2010-07-06 00:27:03 +0000
commitff8ea4d2f2443a2b6cfe58025eded7524b5f4bbb (patch)
treea1e71c139996f78742a4942ea54d302cc892593e
parent91850f0eb4ab9f63bc6582d042d5495ea1968031 (diff)
Remove MMC thread protection which is pointless now that only JACK MIDI ports are used for output, which themselves can cope with multi-threaded access.
git-svn-id: svn://localhost/ardour2/branches/3.0@7378 d708f5d6-7413-0410-9779-e7cbd77b26cf
-rw-r--r--libs/ardour/audioengine.cc1
-rw-r--r--libs/ardour/session_process.cc2
-rw-r--r--libs/midi++2/midi++/mmc.h11
-rw-r--r--libs/midi++2/mmc.cc39
4 files changed, 2 insertions, 51 deletions
diff --git a/libs/ardour/audioengine.cc b/libs/ardour/audioengine.cc
index 33a76fa7b4..fb81ccd144 100644
--- a/libs/ardour/audioengine.cc
+++ b/libs/ardour/audioengine.cc
@@ -148,7 +148,6 @@ _thread_init_callback (void * /*arg*/)
SessionEvent::create_per_thread_pool (X_("Audioengine"), 512);
MIDI::Port::set_process_thread (pthread_self());
- MIDI::MachineControl::set_sending_thread (pthread_self ());
}
typedef void (*_JackInfoShutdownCallback)(jack_status_t code, const char* reason, void *arg);
diff --git a/libs/ardour/session_process.cc b/libs/ardour/session_process.cc
index e555350088..d7e9b7c995 100644
--- a/libs/ardour/session_process.cc
+++ b/libs/ardour/session_process.cc
@@ -69,8 +69,6 @@ Session::process (nframes_t nframes)
}
}
- _mmc->flush_pending ();
-
_engine.main_thread()->get_buffers ();
(this->*process_function) (nframes);
diff --git a/libs/midi++2/midi++/mmc.h b/libs/midi++2/midi++/mmc.h
index 61415d39f2..ec48527789 100644
--- a/libs/midi++2/midi++/mmc.h
+++ b/libs/midi++2/midi++/mmc.h
@@ -98,10 +98,8 @@ class MachineControl
byte send_device_id () const { return _send_device_id; }
void enable_send (bool);
void send (MachineControlCommand const &);
- void flush_pending ();
static bool is_mmc (byte *sysex_buf, size_t len);
- static void set_sending_thread (pthread_t);
/* Signals to connect to if you want to run "callbacks"
when certain MMC commands are received.
@@ -260,14 +258,6 @@ class MachineControl
Port* _port;
bool _enable_send; ///< true if MMC sending is enabled
- /** A ringbuffer of MMC commands that were `sent' from the wrong thread, which
- are queued up and sent when flush_pending() is called.
- */
- RingBuffer<MachineControlCommand> _pending;
-
- /** The thread to use for sending MMC commands */
- static pthread_t _sending_thread;
-
void process_mmc_message (Parser &p, byte *, size_t len);
PBD::ScopedConnectionList port_connections; ///< connections to our parser for incoming data
@@ -275,7 +265,6 @@ class MachineControl
int do_locate (byte *, size_t len);
int do_step (byte *, size_t len);
int do_shuttle (byte *, size_t len);
- void send_immediately (MachineControlCommand const &);
void write_track_status (byte *, size_t len, byte reg);
void spp_start (Parser&, nframes_t);
diff --git a/libs/midi++2/mmc.cc b/libs/midi++2/mmc.cc
index 79132f0e1a..597904d293 100644
--- a/libs/midi++2/mmc.cc
+++ b/libs/midi++2/mmc.cc
@@ -30,8 +30,6 @@ using namespace std;
using namespace MIDI;
using namespace PBD;
-pthread_t MachineControl::_sending_thread;
-
static std::map<int,string> mmc_cmd_map;
static void build_mmc_cmd_map ()
{
@@ -197,7 +195,6 @@ static void build_mmc_cmd_map ()
MachineControl::MachineControl ()
: _port (0)
- , _pending (16)
{
build_mmc_cmd_map ();
@@ -640,37 +637,12 @@ MachineControl::enable_send (bool yn)
_enable_send = yn;
}
-/** Send a MMC command. It will be sent immediately if the call is made in _sending_thread,
- * otherwise it will be queued and sent next time flush_pending()
- * is called.
- * @param c command, which this method takes ownership of.
+/** Send a MMC command to a the MMC port.
+ * @param c command.
*/
void
MachineControl::send (MachineControlCommand const & c)
{
- if (pthread_self() == _sending_thread) {
- send_immediately (c);
- } else {
- _pending.write (&c, 1);
- }
-}
-
-/** Send any pending MMC commands immediately. Must be called from _sending_thread */
-void
-MachineControl::flush_pending ()
-{
- MachineControlCommand c;
- while (_pending.read (&c, 1) == 1) {
- send_immediately (c);
- }
-}
-
-/** Send a MMC immediately. Must be called from _sending_thread.
- * @param c command, which this method takes ownership of.
- */
-void
-MachineControl::send_immediately (MachineControlCommand const & c)
-{
if (_port == 0 || !_enable_send) {
// cerr << "Not delivering MMC " << _mmc->port() << " - " << session_send_mmc << endl;
return;
@@ -684,13 +656,6 @@ MachineControl::send_immediately (MachineControlCommand const & c)
}
}
-/** Set the thread that we should send MMC in */
-void
-MachineControl::set_sending_thread (pthread_t t)
-{
- _sending_thread = t;
-}
-
void
MachineControl::spp_start (Parser& parser, nframes_t timestamp)
{