Use RCU for MIDI Manager's port list.

git-svn-id: svn://localhost/ardour2/branches/3.0@10128 d708f5d6-7413-0410-9779-e7cbd77b26cf
This commit is contained in:
Carl Hetherington 2011-09-26 20:35:09 +00:00
parent e5a9ea3ed9
commit d6112f1213
5 changed files with 39 additions and 20 deletions

View file

@ -117,8 +117,8 @@ MidiTracer::ports_changed ()
string const c = _port_combo.get_active_text ();
_port_combo.clear ();
Manager::PortList const & p = Manager::instance()->get_midi_ports ();
for (Manager::PortList::const_iterator i = p.begin(); i != p.end(); ++i) {
boost::shared_ptr<const Manager::PortList> p = Manager::instance()->get_midi_ports ();
for (Manager::PortList::const_iterator i = p->begin(); i != p->end(); ++i) {
_port_combo.append_text ((*i)->name());
}

View file

@ -130,9 +130,9 @@ MidiControlUI::reset_ports ()
{
clear_ports ();
MIDI::Manager::PortList plist = MIDI::Manager::instance()->get_midi_ports ();
boost::shared_ptr<const MIDI::Manager::PortList> plist = MIDI::Manager::instance()->get_midi_ports ();
for (MIDI::Manager::PortList::iterator i = plist.begin(); i != plist.end(); ++i) {
for (MIDI::Manager::PortList::const_iterator i = plist->begin(); i != plist->end(); ++i) {
int fd;
if ((fd = (*i)->selectable ()) >= 0) {

View file

@ -212,9 +212,9 @@ RCConfiguration::get_state ()
MIDI::Manager* mm = MIDI::Manager::instance();
if (mm) {
const MIDI::Manager::PortList& ports = mm->get_midi_ports();
boost::shared_ptr<const MIDI::Manager::PortList> ports = mm->get_midi_ports();
for (MIDI::Manager::PortList::const_iterator i = ports.begin(); i != ports.end(); ++i) {
for (MIDI::Manager::PortList::const_iterator i = ports->begin(); i != ports->end(); ++i) {
root->add_child_nocopy((*i)->get_state());
}
}

View file

@ -36,6 +36,7 @@ using namespace PBD;
Manager *Manager::theManager = 0;
Manager::Manager (jack_client_t* jack)
: _ports (new PortList)
{
_mmc = new MachineControl (this, jack);
@ -52,7 +53,9 @@ Manager::~Manager ()
delete _mmc;
/* This will delete our MTC etc. ports */
for (PortList::iterator p = _ports.begin(); p != _ports.end(); ++p) {
boost::shared_ptr<PortList> pr = _ports.reader ();
for (PortList::iterator p = pr->begin(); p != pr->end(); ++p) {
delete *p;
}
@ -64,7 +67,9 @@ Manager::~Manager ()
Port *
Manager::add_port (Port* p)
{
_ports.push_back (p);
RCUWriter<PortList> writer (_ports);
boost::shared_ptr<PortList> pw = writer.get_copy ();
pw->push_back (p);
PortsChanged (); /* EMIT SIGNAL */
@ -74,7 +79,9 @@ Manager::add_port (Port* p)
void
Manager::cycle_start (pframes_t nframes)
{
for (PortList::iterator p = _ports.begin(); p != _ports.end(); ++p) {
boost::shared_ptr<PortList> pr = _ports.reader ();
for (PortList::iterator p = pr->begin(); p != pr->end(); ++p) {
(*p)->cycle_start (nframes);
}
}
@ -82,7 +89,9 @@ Manager::cycle_start (pframes_t nframes)
void
Manager::cycle_end()
{
for (PortList::iterator p = _ports.begin(); p != _ports.end(); ++p) {
boost::shared_ptr<PortList> pr = _ports.reader ();
for (PortList::iterator p = pr->begin(); p != pr->end(); ++p) {
(*p)->cycle_end ();
}
}
@ -91,7 +100,9 @@ Manager::cycle_end()
void
Manager::reestablish (jack_client_t* jack)
{
for (PortList::const_iterator p = _ports.begin(); p != _ports.end(); ++p) {
boost::shared_ptr<PortList> pr = _ports.reader ();
for (PortList::const_iterator p = pr->begin(); p != pr->end(); ++p) {
(*p)->reestablish (jack);
}
}
@ -100,7 +111,9 @@ Manager::reestablish (jack_client_t* jack)
void
Manager::reconnect ()
{
for (PortList::const_iterator p = _ports.begin(); p != _ports.end(); ++p) {
boost::shared_ptr<PortList> pr = _ports.reader ();
for (PortList::const_iterator p = pr->begin(); p != pr->end(); ++p) {
(*p)->reconnect ();
}
}
@ -108,12 +121,14 @@ Manager::reconnect ()
Port*
Manager::port (string const & n)
{
PortList::const_iterator p = _ports.begin();
while (p != _ports.end() && (*p)->name() != n) {
boost::shared_ptr<PortList> pr = _ports.reader ();
PortList::const_iterator p = pr->begin();
while (p != pr->end() && (*p)->name() != n) {
++p;
}
if (p == _ports.end()) {
if (p == pr->end()) {
return 0;
}
@ -130,8 +145,10 @@ Manager::create (jack_client_t* jack)
void
Manager::set_port_states (list<XMLNode*> s)
{
boost::shared_ptr<PortList> pr = _ports.reader ();
for (list<XMLNode*>::iterator i = s.begin(); i != s.end(); ++i) {
for (PortList::const_iterator j = _ports.begin(); j != _ports.end(); ++j) {
for (PortList::const_iterator j = pr->begin(); j != pr->end(); ++j) {
(*j)->set_state (**i);
}
}

View file

@ -24,6 +24,8 @@
#include <string>
#include "pbd/rcu.h"
#include "midi++/types.h"
#include "midi++/port.h"
@ -64,7 +66,7 @@ class Manager {
typedef std::list<Port *> PortList;
const PortList& get_midi_ports() const { return _ports; }
boost::shared_ptr<const PortList> get_midi_ports() const { return _ports.reader (); }
static void create (jack_client_t* jack);
@ -91,7 +93,7 @@ class Manager {
MIDI::Port* _midi_clock_input_port;
MIDI::Port* _midi_clock_output_port;
std::list<Port*> _ports;
SerializedRCUManager<PortList> _ports;
};
} // namespace MIDI