SharedPtr-ify engine side store.

Fix reattaching to engine.
Fix connection paths.
Remove last dependencies on client (model) library from Serialiser.
Fix Raul::PathTable::find_descendants_end.


git-svn-id: http://svn.drobilla.net/lad/ingen@847 a436a847-0d15-0410-975c-d299462d15a1

83 files changed, 358 insertions, 312 deletions

diff --git a/src/common/interface/GraphObject.hpp b/src/common/interface/GraphObject.hpp
index 7ea566f6..838ba481 100644
--- a/src/common/interface/GraphObject.hpp
+++ b/src/common/interface/GraphObject.hpp
@@ -21,8 +21,11 @@
 #include <string>
 #include <map>
 #include <raul/Deletable.hpp>
-#include <raul/Path.hpp>
+#include <raul/PathTable.hpp>
 #include <raul/Atom.hpp>
+#include <raul/SharedPtr.hpp>
+
+using Raul::PathTable;
 
 namespace Ingen {
 namespace Shared {
@@ -39,10 +42,16 @@ class GraphObject : public Raul::Deletable
 public:
 	typedef std::map<std::string, Raul::Atom> MetadataMap;
 
+	typedef PathTable< SharedPtr<GraphObject> >::const_iterator const_iterator;
+
 	virtual const Raul::Path   path()       const = 0;
 	virtual const std::string  name()       const = 0;
 	virtual const MetadataMap& metadata()   const = 0;
 	virtual bool               polyphonic() const = 0;
+	
+	virtual const_iterator         children_begin() const = 0;
+	virtual const_iterator         children_end() const = 0;
+	virtual SharedPtr<GraphObject> find_child(const string& name) const = 0;
 };
 
 
diff --git a/src/common/interface/Makefile.am b/src/common/interface/Makefile.am
index 7fc68563..ad15c212 100644
--- a/src/common/interface/Makefile.am
+++ b/src/common/interface/Makefile.am
@@ -4,6 +4,7 @@ EXTRA_DIST = \
 	DataType.hpp \
 	EngineInterface.hpp \
 	Node.hpp \
+	Patch.hpp \
 	Plugin.hpp \
 	Port.hpp \
 	README
diff --git a/src/libs/client/ConnectionModel.hpp b/src/libs/client/ConnectionModel.hpp
index 83ddbd58..5ace402f 100644
--- a/src/libs/client/ConnectionModel.hpp
+++ b/src/libs/client/ConnectionModel.hpp
@@ -62,10 +62,11 @@ private:
 		assert(_dst_port);
 		assert(_src_port->parent());
 		assert(_dst_port->parent());
+		assert(_src_port->path() != _dst_port->path());
 	}
 	
-	SharedPtr<PortModel> _src_port;
-	SharedPtr<PortModel> _dst_port;
+	const SharedPtr<PortModel> _src_port;
+	const SharedPtr<PortModel> _dst_port;
 };
 
 
diff --git a/src/libs/client/NodeModel.hpp b/src/libs/client/NodeModel.hpp
index a38c519c..9e26daaa 100644
--- a/src/libs/client/NodeModel.hpp
+++ b/src/libs/client/NodeModel.hpp
@@ -26,6 +26,7 @@
 #include <raul/Path.hpp>
 #include <raul/SharedPtr.hpp>
 #include "interface/Node.hpp"
+#include "interface/Port.hpp"
 #include "ObjectModel.hpp"
 #include "PortModel.hpp"
 #include "PluginModel.hpp"
diff --git a/src/libs/client/OSCClientReceiver.cpp b/src/libs/client/OSCClientReceiver.cpp
index b9f5a70d..0a1fa105 100644
--- a/src/libs/client/OSCClientReceiver.cpp
+++ b/src/libs/client/OSCClientReceiver.cpp
@@ -35,7 +35,7 @@ OSCClientReceiver::OSCClientReceiver(int listen_port)
   _listen_port(listen_port),
   _st(NULL)
 {
-	start(false);
+	start(true);
 }
 
 
diff --git a/src/libs/client/ObjectModel.cpp b/src/libs/client/ObjectModel.cpp
index ca38b42f..7d144faf 100644
--- a/src/libs/client/ObjectModel.cpp
+++ b/src/libs/client/ObjectModel.cpp
@@ -15,9 +15,10 @@
  * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  */
 
-#include "ObjectModel.hpp"
-#include <raul/TableImpl.hpp>
 #include <iostream>
+#include <raul/TableImpl.hpp>
+#include "interface/GraphObject.hpp"
+#include "ObjectModel.hpp"
 
 using namespace std;
 
@@ -57,7 +58,7 @@ ObjectModel::children_end() const
 }
 
 
-SharedPtr<ObjectModel>
+SharedPtr<Shared::GraphObject>
 ObjectModel::find_child(const string& name) const
 {
 	const_iterator me = _store.objects().find(_path);
@@ -65,7 +66,7 @@ ObjectModel::find_child(const string& name) const
 	const_iterator children_end = _store.objects().find_descendants_end(me);
 	const_iterator child = _store.objects().find(me, children_end, _path.base() + name);
 	if (child != _store.objects().end())
-		return child->second;
+		return PtrCast<ObjectModel>(child->second);
 	else
 		return SharedPtr<ObjectModel>();
 }
diff --git a/src/libs/client/ObjectModel.hpp b/src/libs/client/ObjectModel.hpp
index ede796e4..3c13b227 100644
--- a/src/libs/client/ObjectModel.hpp
+++ b/src/libs/client/ObjectModel.hpp
@@ -28,10 +28,11 @@
 #include <raul/Atom.hpp>
 #include <raul/Path.hpp>
 #include <raul/SharedPtr.hpp>
-#include <raul/Table.hpp>
+#include <raul/PathTable.hpp>
 #include "interface/GraphObject.hpp"
 #include "Store.hpp"
 
+using Raul::PathTable;
 using std::string;
 using Raul::Atom;
 using Raul::Path;
@@ -68,12 +69,9 @@ public:
 	SharedPtr<ObjectModel> parent()     const { return _parent; }
 	bool                   polyphonic() const { return _polyphonic; }
 
-	typedef Store::Objects::iterator       iterator;
-	typedef Store::Objects::const_iterator const_iterator;
-
-	const_iterator         children_begin() const;
-	const_iterator         children_end() const;
-	SharedPtr<ObjectModel> find_child(const string& name) const;
+	const_iterator                 children_begin() const;
+	const_iterator                 children_end() const;
+	SharedPtr<Shared::GraphObject> find_child(const string& name) const;
 
 	// Signals
 	sigc::signal<void, SharedPtr<ObjectModel> >    signal_new_child; 
diff --git a/src/libs/client/PatchModel.cpp b/src/libs/client/PatchModel.cpp
index 3997ac77..a0f0aa4b 100644
--- a/src/libs/client/PatchModel.cpp
+++ b/src/libs/client/PatchModel.cpp
@@ -31,8 +31,6 @@ void
 PatchModel::add_child(SharedPtr<ObjectModel> c)
 {
 	assert(c->parent().get() == this);
-	
-	//ObjectModel::add_child(c);
 
 	SharedPtr<PortModel> pm = PtrCast<PortModel>(c);
 	if (pm) {
@@ -45,13 +43,6 @@ PatchModel::add_child(SharedPtr<ObjectModel> c)
 		signal_new_node.emit(nm);
 }
 
-/*
-SharedPtr<NodeModel>
-PatchModel::get_node(const string& name) const
-{
-	return PtrCast<NodeModel>(get_child(name));
-}
-*/
 
 bool
 PatchModel::remove_child(SharedPtr<ObjectModel> o)
@@ -67,10 +58,11 @@ PatchModel::remove_child(SharedPtr<ObjectModel> o)
 	// since they can't possibly exist anymore
 	for (Connections::iterator j = _connections.begin(); j != _connections.end() ; ) {
 
-		list<SharedPtr<ConnectionModel> >::iterator next = j;
+		Connections::iterator next = j;
 		++next;
 
-		SharedPtr<ConnectionModel> cm = (*j);
+		SharedPtr<ConnectionModel> cm = PtrCast<ConnectionModel>(*j);
+		assert(cm);
 
 		if (cm->src_port_path().parent() == o->path()
 				|| cm->src_port_path() == o->path()
@@ -106,9 +98,10 @@ PatchModel::clear()
 SharedPtr<ConnectionModel>
 PatchModel::get_connection(const string& src_port_path, const string& dst_port_path) const
 {
-	for (list<SharedPtr<ConnectionModel> >::const_iterator i = _connections.begin(); i != _connections.end(); ++i)
+	for (Connections::const_iterator i = _connections.begin(); i != _connections.end(); ++i)
 		if ((*i)->src_port_path() == src_port_path && (*i)->dst_port_path() == dst_port_path)
-			return (*i);
+			return PtrCast<ConnectionModel>(*i);
+
 	return SharedPtr<ConnectionModel>();
 }
 
@@ -129,18 +122,19 @@ PatchModel::add_connection(SharedPtr<ConnectionModel> cm)
 	assert(cm->dst_port());
 	assert(cm->src_port()->parent());
 	assert(cm->dst_port()->parent());
+	assert(cm->src_port_path() != cm->dst_port_path());
 	assert(cm->src_port()->parent().get() == this
 	       || cm->src_port()->parent()->parent().get() == this);
 	assert(cm->dst_port()->parent().get() == this
 	       || cm->dst_port()->parent()->parent().get() == this);
 	
 	SharedPtr<ConnectionModel> existing = get_connection(cm->src_port_path(), cm->dst_port_path());
-	
+
 	if (existing) {
 		assert(cm->src_port() == existing->src_port());
 		assert(cm->dst_port() == existing->dst_port());
 	} else {
-		_connections.push_back(cm);
+		_connections.push_back(new Connections::Node(cm));
 		signal_new_connection.emit(cm);
 	}
 }
@@ -149,11 +143,12 @@ PatchModel::add_connection(SharedPtr<ConnectionModel> cm)
 void
 PatchModel::remove_connection(const string& src_port_path, const string& dst_port_path)
 {
-	for (list<SharedPtr<ConnectionModel> >::iterator i = _connections.begin(); i != _connections.end(); ++i) {
-		SharedPtr<ConnectionModel> cm = (*i);
+	for (Connections::iterator i = _connections.begin(); i != _connections.end(); ++i) {
+		SharedPtr<ConnectionModel> cm = PtrCast<ConnectionModel>(*i);
+		assert(cm);
 		if (cm->src_port_path() == src_port_path && cm->dst_port_path() == dst_port_path) {
 			signal_removed_connection.emit(cm);
-			_connections.erase(i); // cuts our reference
+			delete _connections.erase(i); // cuts our reference
 			assert(!get_connection(src_port_path, dst_port_path)); // no duplicates
 			return;
 		}
diff --git a/src/libs/client/PatchModel.hpp b/src/libs/client/PatchModel.hpp
index 642bf34f..5d375faf 100644
--- a/src/libs/client/PatchModel.hpp
+++ b/src/libs/client/PatchModel.hpp
@@ -22,8 +22,10 @@
 #include <list>
 #include <string>
 #include <sigc++/sigc++.h>
-#include "NodeModel.hpp"
 #include <raul/SharedPtr.hpp>
+#include "interface/Patch.hpp"
+#include "NodeModel.hpp"
+
 #include "ConnectionModel.hpp"
 
 using std::list; using std::string;
@@ -38,22 +40,21 @@ class Store;
  *
  * \ingroup IngenClient
  */
-class PatchModel : public NodeModel
+class PatchModel : public NodeModel, public Ingen::Shared::Patch
 {
 public:
-	typedef std::list<SharedPtr<ConnectionModel> > Connections;
-
 	const Connections& connections() const { return _connections; }
 	
-	SharedPtr<ConnectionModel> get_connection(const string& src_port_path, const string& dst_port_path) const;
-	//SharedPtr<NodeModel>       get_node(const string& node_name) const;
+	SharedPtr<ConnectionModel> get_connection(const string& src_port_path,
+	                                          const string& dst_port_path) const;
 	
 	void set_filename(const string& filename) { _filename = filename; }
 
-	size_t        poly()       const { return _poly; }
-	const string& filename()   const { return _filename; }
-	bool          enabled()    const { return _enabled; }
-	bool          polyphonic() const;
+	size_t        poly()               const { return _poly; }
+	const string& filename()           const { return _filename; }
+	bool          enabled()            const { return _enabled; }
+	uint32_t      internal_polyphony() const { return _poly; }
+	bool          polyphonic()         const;
 
 	/** "editable" = arranging,connecting,adding,deleting,etc
 	 * not editable (control mode) you can just change controllers (performing)
@@ -96,13 +97,10 @@ private:
 	void add_connection(SharedPtr<ConnectionModel> cm);
 	void remove_connection(const string& src_port_path, const string& dst_port_path);
 	
-	void rename_node(const Path& old_path, const Path& new_path);
-	void rename_node_port(const Path& old_path, const Path& new_path);
-
 	Connections _connections;
 	string      _filename;
 	bool        _enabled;
-	size_t      _poly;
+	uint32_t    _poly;
 	bool        _editable;
 };
 
diff --git a/src/libs/client/PortModel.hpp b/src/libs/client/PortModel.hpp
index 06f04e78..5455c1f9 100644
--- a/src/libs/client/PortModel.hpp
+++ b/src/libs/client/PortModel.hpp
@@ -38,7 +38,7 @@ namespace Client {
  *
  * \ingroup IngenClient
  */
-class PortModel : public ObjectModel, public Shared::Port
+class PortModel : public ObjectModel, public Ingen::Shared::Port
 {
 public:
 	enum Direction { INPUT, OUTPUT };
diff --git a/src/libs/client/Serializer.cpp b/src/libs/client/Serializer.cpp
index e37391d7..e15ce4dc 100644
--- a/src/libs/client/Serializer.cpp
+++ b/src/libs/client/Serializer.cpp
@@ -35,11 +35,12 @@
 #include <raul/RDFWorld.hpp>
 #include <raul/TableImpl.hpp>
 #include "interface/EngineInterface.hpp"
+#include "interface/Plugin.hpp"
+#include "interface/Patch.hpp"
+#include "interface/Node.hpp"
 #include "interface/Port.hpp"
 #include "interface/Connection.hpp"
-#include "PatchModel.hpp"
 #include "Serializer.hpp"
-#include "Store.hpp"
 
 using namespace std;
 using namespace Raul;
@@ -218,7 +219,7 @@ Serializer::serialize(SharedPtr<GraphObject> object) throw (std::logic_error)
 	if (!_model)
 		throw std::logic_error("serialize called without serialization in progress");
 
-	SharedPtr<PatchModel> patch = PtrCast<PatchModel>(object);
+	SharedPtr<Shared::Patch> patch = PtrCast<Shared::Patch>(object);
 	if (patch) {
 		serialize_patch(patch);
 		return;
@@ -230,7 +231,7 @@ Serializer::serialize(SharedPtr<GraphObject> object) throw (std::logic_error)
 		return;
 	}
 	
-	SharedPtr<Port> port = PtrCast<Port>(object);
+	SharedPtr<Shared::Port> port = PtrCast<Shared::Port>(object);
 	if (port) {
 		serialize_port(port.get(), path_to_node_id(port->path()));
 		return;
@@ -255,7 +256,7 @@ Serializer::patch_path_to_rdf_id(const Path& path)
 
 
 void
-Serializer::serialize_patch(SharedPtr<PatchModel> patch)
+Serializer::serialize_patch(SharedPtr<Shared::Patch> patch)
 {
 	assert(_model);
 
@@ -275,7 +276,7 @@ Serializer::serialize_patch(SharedPtr<PatchModel> patch)
 	_model->add_statement(
 		patch_id,
 		"ingen:polyphony",
-		Atom((int)patch->poly()));
+		Atom((int)patch->internal_polyphony()));
 	
 	_model->add_statement(
 		patch_id,
@@ -292,9 +293,9 @@ Serializer::serialize_patch(SharedPtr<PatchModel> patch)
 		}
 	}
 
-	for (Store::Objects::const_iterator n = patch->children_begin(); n != patch->children_end(); ++n) {
-		SharedPtr<PatchModel> patch = PtrCast<PatchModel>(n->second);
-		SharedPtr<NodeModel> node   = PtrCast<NodeModel>(n->second);
+	for (GraphObject::const_iterator n = patch->children_begin(); n != patch->children_end(); ++n) {
+		SharedPtr<Shared::Patch> patch = PtrCast<Shared::Patch>(n->second);
+		SharedPtr<Shared::Node>  node  = PtrCast<Shared::Node>(n->second);
 		if (patch) {
 			_model->add_statement(patch_id, "ingen:node", patch_path_to_rdf_id(patch->path()));
 			serialize_patch(patch);
@@ -312,7 +313,8 @@ Serializer::serialize_patch(SharedPtr<PatchModel> patch)
 		serialize_port(p, port_id);
 	}
 
-	for (PatchModel::Connections::const_iterator c = patch->connections().begin(); c != patch->connections().end(); ++c) {
+	for (Shared::Patch::Connections::const_iterator c = patch->connections().begin();
+			c != patch->connections().end(); ++c) {
 		serialize_connection(*c);
 	}
 }
@@ -360,11 +362,6 @@ Serializer::serialize_node(SharedPtr<Shared::Node> node, const RDF::Node& node_i
 
 	//serialize_plugin(node->plugin());
 	
-	/*_model->add_statement(_serializer,
-		node_uri_ref.c_str(),
-		"ingen:name",
-		Atom(node->path().name()));*/
-
 	for (uint32_t i=0; i < node->num_ports(); ++i) {
 		Port* p = node->port(i);
 		assert(p);
diff --git a/src/libs/client/Serializer.hpp b/src/libs/client/Serializer.hpp
index 7a739f94..f8b99750 100644
--- a/src/libs/client/Serializer.hpp
+++ b/src/libs/client/Serializer.hpp
@@ -37,6 +37,7 @@ namespace Ingen {
 namespace Shared {
 	class Plugin;
 	class GraphObject;
+	class Patch;
 	class Node;
 	class Port;
 	class Connection;
@@ -44,8 +45,6 @@ namespace Shared {
 
 namespace Client {
 
-class PatchModel;
-
 
 /** Serializes Ingen objects (patches, nodes, etc) to RDF.
  *
@@ -73,7 +72,7 @@ private:
 
 	void serialize_plugin(SharedPtr<Shared::Plugin> p);
 
-	void serialize_patch(SharedPtr<PatchModel> p);
+	void serialize_patch(SharedPtr<Shared::Patch> p);
 	void serialize_node(SharedPtr<Shared::Node> n, const Raul::RDF::Node& id);
 	void serialize_port(const Shared::Port* p, const Raul::RDF::Node& id);
 	
diff --git a/src/libs/client/Store.cpp b/src/libs/client/Store.cpp
index e1744ac0..ae07fa08 100644
--- a/src/libs/client/Store.cpp
+++ b/src/libs/client/Store.cpp
@@ -222,7 +222,7 @@ Store::add_object(SharedPtr<ObjectModel> object)
 	// one (with precedence to the new values).
 	Objects::iterator existing = _objects.find(object->path());
 	if (existing != _objects.end()) {
-		existing->second->set(object);
+		PtrCast<ObjectModel>(existing->second)->set(object);
 	} else {
 
 		if (object->path() != "/") {
@@ -253,7 +253,11 @@ Store::add_object(SharedPtr<ObjectModel> object)
 
 	}
 
-	//cout << "[Store] Added " << object->path() << endl;
+	/*cout << "[Store] Added " << object->path() << " {" << endl;
+	for (Objects::iterator i = _objects.begin(); i != _objects.end(); ++i) {
+		cout << "\t" << i->first << endl;
+	}
+	cout << "}" << endl;*/
 }
 
 
@@ -264,10 +268,11 @@ Store::remove_object(const Path& path)
 
 	if (i != _objects.end()) {
 		assert((*i).second->path() == path);
-		SharedPtr<ObjectModel> result = (*i).second;
+		SharedPtr<ObjectModel> result = PtrCast<ObjectModel>((*i).second);
+		assert(result);
 		//_objects.erase(i);
 		Objects::iterator descendants_end = _objects.find_descendants_end(i);
-		Table<Path,SharedPtr<ObjectModel> > removed = _objects.yank(i, descendants_end);
+		Table<Path, SharedPtr<Shared::GraphObject> > removed = _objects.yank(i, descendants_end);
 		/*cout << "[Store] Removing " << i->first << " {" << endl;
 		for (Objects::iterator i = removed.begin(); i != removed.end(); ++i) {
 			cout << "\t" << i->first << endl;
@@ -317,8 +322,10 @@ Store::object(const Path& path)
 	if (i == _objects.end()) {
 		return SharedPtr<ObjectModel>();
 	} else {
-		assert(i->second->path() == "/" || i->second->parent());
-		return i->second;
+		SharedPtr<ObjectModel> model = PtrCast<ObjectModel>(i->second);
+		assert(model);
+		assert(model->path() == "/" || model->parent());
+		return model;
 	}
 }
 
@@ -358,11 +365,11 @@ Store::rename_event(const Path& old_path, const Path& new_path)
 
 	Objects::iterator descendants_end = _objects.find_descendants_end(parent);
 	
-	Table<Path,SharedPtr<ObjectModel> > removed = _objects.yank(parent, descendants_end);
+	Table<Path, SharedPtr<Shared::GraphObject> > removed = _objects.yank(parent, descendants_end);
 	
 	assert(removed.size() > 0);
 
-	for (Table<Path,SharedPtr<ObjectModel> >::iterator i = removed.begin(); i != removed.end(); ++i) {
+	for (Table<Path, SharedPtr<Shared::GraphObject> >::iterator i = removed.begin(); i != removed.end(); ++i) {
 		const Path& child_old_path = i->first;
 		assert(Path::descendant_comparator(old_path, child_old_path));
 		
@@ -373,7 +380,7 @@ Store::rename_event(const Path& old_path, const Path& new_path)
 			child_new_path = new_path.base() + child_old_path.substr(old_path.length()+1);
 
 		cerr << "[Store] Renamed " << child_old_path << " -> " << child_new_path << endl;
-		i->second->set_path(child_new_path);
+		PtrCast<ObjectModel>(i->second)->set_path(child_new_path);
 		i->first = child_new_path;
 	}
 
diff --git a/src/libs/client/Store.hpp b/src/libs/client/Store.hpp
index 26aac803..dad403d0 100644
--- a/src/libs/client/Store.hpp
+++ b/src/libs/client/Store.hpp
@@ -34,6 +34,9 @@ using Raul::Path;
 using Raul::Atom;
 
 namespace Ingen {
+
+namespace Shared { class GraphObject; }
+
 namespace Client {
 
 class SigClientInterface;
@@ -63,10 +66,11 @@ public:
 	typedef Raul::Table<string, SharedPtr<PluginModel> > Plugins;
 	const Plugins& plugins() const { return _plugins; }
 
-	typedef Raul::PathTable<SharedPtr<ObjectModel> > Objects;
+	typedef Raul::PathTable< SharedPtr<Shared::GraphObject> > Objects;
 	const Objects& objects() const { return _objects; }
 
 	sigc::signal<void, SharedPtr<ObjectModel> > signal_new_object; 
+
 private:
 
 	void add_object(SharedPtr<ObjectModel> object);
diff --git a/src/libs/engine/AudioDriver.hpp b/src/libs/engine/AudioDriver.hpp
index cb4c4150..6b5ea8dc 100644
--- a/src/libs/engine/AudioDriver.hpp
+++ b/src/libs/engine/AudioDriver.hpp
@@ -26,7 +26,7 @@
 
 namespace Ingen {
 
-class Patch;
+class PatchImpl;
 class AudioDriver;
 class PortImpl;
 class ProcessContext;
@@ -41,8 +41,8 @@ class AudioDriver : public Driver
 public:
 	AudioDriver() : Driver(DataType::AUDIO) {}
 	
-	virtual void   set_root_patch(Patch* patch) = 0;
-	virtual Patch* root_patch()                 = 0;
+	virtual void       set_root_patch(PatchImpl* patch) = 0;
+	virtual PatchImpl* root_patch()                 = 0;
 	
 	virtual void        add_port(DriverPort* port)    = 0;
 	virtual DriverPort* remove_port(const Raul::Path& path) = 0;
diff --git a/src/libs/engine/ClientBroadcaster.cpp b/src/libs/engine/ClientBroadcaster.cpp
index 18025939..2360dd09 100644
--- a/src/libs/engine/ClientBroadcaster.cpp
+++ b/src/libs/engine/ClientBroadcaster.cpp
@@ -23,7 +23,7 @@
 #include "ObjectStore.hpp"
 #include "NodeFactory.hpp"
 #include "util.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "NodeImpl.hpp"
 #include "PluginImpl.hpp"
 #include "PortImpl.hpp"
@@ -256,7 +256,7 @@ ClientBroadcaster::send_program_remove(const string& node_path, int bank, int pr
  * Sends all objects underneath Patch - contained Nodes, etc.
  */
 void
-ClientBroadcaster::send_patch(const Patch* const p, bool recursive)
+ClientBroadcaster::send_patch(const PatchImpl* p, bool recursive)
 {
 	for (Clients::const_iterator i = _clients.begin(); i != _clients.end(); ++i)
 		ObjectSender::send_patch((*i).second, p, recursive);
diff --git a/src/libs/engine/ClientBroadcaster.hpp b/src/libs/engine/ClientBroadcaster.hpp
index f4a97397..d7621555 100644
--- a/src/libs/engine/ClientBroadcaster.hpp
+++ b/src/libs/engine/ClientBroadcaster.hpp
@@ -34,7 +34,7 @@ namespace Ingen {
 class NodeImpl;
 class PortImpl;
 class PluginImpl;
-class Patch;
+class PatchImpl;
 class ConnectionImpl;
 using Shared::ClientInterface;
 
@@ -63,8 +63,8 @@ public:
 	void send_error(const string& msg);
 
 	void send_plugins(const std::list<PluginImpl*>& plugin_list);
-	void send_patch(const Patch* const p, bool recursive);
-	void send_node(const NodeImpl* const node, bool recursive);
+	void send_patch(const PatchImpl* p, bool recursive);
+	void send_node(const NodeImpl* node, bool recursive);
 	void send_port(const PortImpl* port);
 	void send_destroyed(const string& path);
 	void send_polyphonic(const string& path, bool polyphonic);
diff --git a/src/libs/engine/ConnectionImpl.cpp b/src/libs/engine/ConnectionImpl.cpp
index 49e8f7f7..4114e7ae 100644
--- a/src/libs/engine/ConnectionImpl.cpp
+++ b/src/libs/engine/ConnectionImpl.cpp
@@ -47,6 +47,8 @@ ConnectionImpl::ConnectionImpl(PortImpl* src_port, PortImpl* dst_port)
 {
 	assert(src_port);
 	assert(dst_port);
+	assert(src_port != dst_port);
+	assert(src_port->path() != dst_port->path());
 	assert(src_port->type() == dst_port->type());
 
 	/*assert((src_port->parent_node()->poly() == dst_port->parent_node()->poly())
diff --git a/src/libs/engine/ConnectionImpl.hpp b/src/libs/engine/ConnectionImpl.hpp
index 87b9f7e7..b3da1b54 100644
--- a/src/libs/engine/ConnectionImpl.hpp
+++ b/src/libs/engine/ConnectionImpl.hpp
@@ -52,7 +52,7 @@ public:
 	PortImpl* dst_port() const { return _dst_port; }
 	
 	const Raul::Path src_port_path() const { return _src_port->path(); }
-	const Raul::Path dst_port_path() const { return _src_port->path(); }
+	const Raul::Path dst_port_path() const { return _dst_port->path(); }
 
 	/** Used by some (recursive) events to prevent double disconnections */
 	bool pending_disconnection()       { return _pending_disconnection; }
diff --git a/src/libs/engine/Engine.cpp b/src/libs/engine/Engine.cpp
index b5e14eb0..44cac86c 100644
--- a/src/libs/engine/Engine.cpp
+++ b/src/libs/engine/Engine.cpp
@@ -21,6 +21,7 @@
 #include <unistd.h>
 #include <raul/Deletable.hpp>
 #include <raul/Maid.hpp>
+#include <raul/SharedPtr.hpp>
 #include "Engine.hpp"	
 #include CONFIG_H_PATH
 #include "tuning.hpp"
@@ -28,7 +29,7 @@
 #include "JackAudioDriver.hpp"
 #include "NodeFactory.hpp"
 #include "ClientBroadcaster.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "ObjectStore.hpp"
 #include "MidiDriver.hpp"
 #include "OSCDriver.hpp"
@@ -76,10 +77,10 @@ Engine::~Engine()
 {
 	deactivate();
 
-	for (ObjectStore::Objects::const_iterator i = _object_store->objects().begin();
+	for (ObjectStore::Objects::iterator i = _object_store->objects().begin();
 			i != _object_store->objects().end(); ++i) {
-		if ( ! i->second->parent())
-			delete i->second;
+		if ( ! PtrCast<GraphObjectImpl>(i->second)->parent() )
+			i->second.reset();
 	}
 
 	delete _object_store;
@@ -215,7 +216,7 @@ Engine::activate(size_t parallelism)
 
 	// Create root patch
 
-	Patch* root_patch = new Patch(*this, "", 1, NULL,
+	PatchImpl* root_patch = new PatchImpl(*this, "", 1, NULL,
 			_audio_driver->sample_rate(), _audio_driver->buffer_size(), 1);
 	root_patch->activate();
 	_object_store->add(root_patch);
diff --git a/src/libs/engine/Engine.hpp b/src/libs/engine/Engine.hpp
index f7e82c06..355d8c4d 100644
--- a/src/libs/engine/Engine.hpp
+++ b/src/libs/engine/Engine.hpp
@@ -37,7 +37,7 @@ class MidiDriver;
 class OSCDriver;
 class NodeFactory;
 class ClientBroadcaster;
-class Patch;
+class PatchImpl;
 class ObjectStore;
 class EventSource;
 class PostProcessor;
diff --git a/src/libs/engine/GraphObjectImpl.cpp b/src/libs/engine/GraphObjectImpl.cpp
index d0820f61..62474bfc 100644
--- a/src/libs/engine/GraphObjectImpl.cpp
+++ b/src/libs/engine/GraphObjectImpl.cpp
@@ -16,16 +16,37 @@
  */
 
 #include "GraphObjectImpl.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "ObjectStore.hpp"
 
 namespace Ingen {
 
 
-Patch*
+PatchImpl*
 GraphObjectImpl::parent_patch() const
 {
-	return dynamic_cast<Patch*>((NodeImpl*)_parent);
+	return dynamic_cast<PatchImpl*>((NodeImpl*)_parent);
+}
+	
+
+GraphObjectImpl::const_iterator
+GraphObjectImpl::children_begin() const
+{
+	throw;
+}
+
+
+GraphObjectImpl::const_iterator
+GraphObjectImpl::children_end() const
+{
+	throw;
+}
+
+
+SharedPtr<GraphObject>
+GraphObjectImpl::find_child(const string& name) const
+{
+	throw;
 }
 
 
diff --git a/src/libs/engine/GraphObjectImpl.hpp b/src/libs/engine/GraphObjectImpl.hpp
index ccfc0319..1793366e 100644
--- a/src/libs/engine/GraphObjectImpl.hpp
+++ b/src/libs/engine/GraphObjectImpl.hpp
@@ -35,7 +35,7 @@ namespace Raul { class Maid; }
 
 namespace Ingen {
 
-class Patch;
+class PatchImpl;
 class ProcessContext;
 
 
@@ -79,7 +79,7 @@ public:
 	const MetadataMap& metadata() const { return _metadata; }
 
 	/** The Patch this object is a child of. */
-	virtual Patch* parent_patch() const;
+	virtual PatchImpl* parent_patch() const;
 	
 	/** Path is dynamically generated from parent to ease renaming */
 	const Path path() const {
@@ -90,6 +90,10 @@ public:
 		else
 			return Path(_parent->path() +"/"+ _name);
 	}
+	
+	const_iterator         children_begin() const;
+	const_iterator         children_end() const;
+	SharedPtr<GraphObject> find_child(const string& name) const;
 
 protected:
 	GraphObjectImpl(GraphObjectImpl* parent, const string& name, bool polyphonic=false)
diff --git a/src/libs/engine/JackAudioDriver.cpp b/src/libs/engine/JackAudioDriver.cpp
index a99a6112..0c824935 100644
--- a/src/libs/engine/JackAudioDriver.cpp
+++ b/src/libs/engine/JackAudioDriver.cpp
@@ -29,7 +29,7 @@
 #include "EventSource.hpp"
 #include "PostProcessor.hpp"
 #include "NodeImpl.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "PortImpl.hpp"
 #include "MidiDriver.hpp"
 #include "DuplexPort.hpp"
diff --git a/src/libs/engine/JackAudioDriver.hpp b/src/libs/engine/JackAudioDriver.hpp
index ea955d05..82d07f16 100644
--- a/src/libs/engine/JackAudioDriver.hpp
+++ b/src/libs/engine/JackAudioDriver.hpp
@@ -30,7 +30,7 @@
 namespace Ingen {
 
 class Engine;
-class Patch;
+class PatchImpl;
 class PortImpl;
 class DuplexPort;
 class JackAudioDriver;
@@ -91,8 +91,8 @@ public:
 	
 	DriverPort* driver_port(const Raul::Path& path);
 	
-	Patch* root_patch()                 { return _root_patch; }
-	void   set_root_patch(Patch* patch) { _root_patch = patch; }
+	PatchImpl* root_patch()                     { return _root_patch; }
+	void       set_root_patch(PatchImpl* patch) { _root_patch = patch; }
 	
 	ProcessContext& context() { return _process_context; }
 	
@@ -141,7 +141,7 @@ private:
 	Raul::List<JackAudioPort*> _ports;
 	ProcessContext             _process_context;
 
-	Patch* _root_patch;
+	PatchImpl* _root_patch;
 };
 
 
diff --git a/src/libs/engine/LADSPANode.cpp b/src/libs/engine/LADSPANode.cpp
index 9c2da41e..ce61eb5d 100644
--- a/src/libs/engine/LADSPANode.cpp
+++ b/src/libs/engine/LADSPANode.cpp
@@ -36,7 +36,7 @@ namespace Ingen {
  * Object is not usable until instantiate() is called with success.
  * (It _will_ crash!)
  */
-LADSPANode::LADSPANode(const PluginImpl* plugin, const string& path, bool polyphonic, Patch* parent, const LADSPA_Descriptor* descriptor, SampleRate srate, size_t buffer_size)
+LADSPANode::LADSPANode(const PluginImpl* plugin, const string& path, bool polyphonic, PatchImpl* parent, const LADSPA_Descriptor* descriptor, SampleRate srate, size_t buffer_size)
 : NodeBase(plugin, path, polyphonic, parent, srate, buffer_size),
   _descriptor(descriptor),
   _instances(NULL)
diff --git a/src/libs/engine/LADSPANode.hpp b/src/libs/engine/LADSPANode.hpp
index 493645a5..8675a6fd 100644
--- a/src/libs/engine/LADSPANode.hpp
+++ b/src/libs/engine/LADSPANode.hpp
@@ -37,7 +37,7 @@ public:
 	LADSPANode(const PluginImpl*        plugin,
 	           const string&            name,
 	           bool                     polyphonic,
-	           Patch*                   parent,
+	           PatchImpl*               parent,
 	           const LADSPA_Descriptor* descriptor,
 	           SampleRate               srate,
 	           size_t                   buffer_size);
diff --git a/src/libs/engine/LV2Node.cpp b/src/libs/engine/LV2Node.cpp
index ed330d6d..e3b6c06b 100644
--- a/src/libs/engine/LV2Node.cpp
+++ b/src/libs/engine/LV2Node.cpp
@@ -43,7 +43,7 @@ namespace Ingen {
 LV2Node::LV2Node(const PluginImpl* plugin,
                  const string&     name,
                  bool              polyphonic,
-                 Patch*            parent,
+                 PatchImpl*        parent,
                  SampleRate        srate,
                  size_t            buffer_size)
 	: NodeBase(plugin, name, polyphonic, parent, srate, buffer_size)
diff --git a/src/libs/engine/LV2Node.hpp b/src/libs/engine/LV2Node.hpp
index 9e303be9..7fd9bf6d 100644
--- a/src/libs/engine/LV2Node.hpp
+++ b/src/libs/engine/LV2Node.hpp
@@ -37,7 +37,7 @@ public:
 	LV2Node(const PluginImpl* plugin,
 	        const string&     name,
 	        bool              polyphonic,
-	        Patch*            parent,
+	        PatchImpl*        parent,
 	        SampleRate        srate,
 	        size_t            buffer_size);
 	
diff --git a/src/libs/engine/Makefile.am b/src/libs/engine/Makefile.am
index a98a1e48..68f9739a 100644
--- a/src/libs/engine/Makefile.am
+++ b/src/libs/engine/Makefile.am
@@ -77,8 +77,8 @@ libingen_engine_la_SOURCES = \
 	ObjectStore.hpp \
 	OutputPort.cpp \
 	OutputPort.hpp \
-	Patch.cpp \
-	Patch.hpp \
+	PatchImpl.cpp \
+	PatchImpl.hpp \
 	PluginImpl.cpp \
 	PluginImpl.hpp \
 	PortImpl.cpp \
diff --git a/src/libs/engine/MidiControlNode.cpp b/src/libs/engine/MidiControlNode.cpp
index 5bc14182..27047263 100644
--- a/src/libs/engine/MidiControlNode.cpp
+++ b/src/libs/engine/MidiControlNode.cpp
@@ -30,7 +30,7 @@
 namespace Ingen {
 
 	
-MidiControlNode::MidiControlNode(const string& path, bool polyphonic, Patch* parent, SampleRate srate, size_t buffer_size)
+MidiControlNode::MidiControlNode(const string& path, bool polyphonic, PatchImpl* parent, SampleRate srate, size_t buffer_size)
 : NodeBase(new PluginImpl(Plugin::Internal, "ingen:control_node"), path, false, parent, srate, buffer_size),
   _learning(false)
 {
diff --git a/src/libs/engine/MidiControlNode.hpp b/src/libs/engine/MidiControlNode.hpp
index 0bee3db9..ab377248 100644
--- a/src/libs/engine/MidiControlNode.hpp
+++ b/src/libs/engine/MidiControlNode.hpp
@@ -39,7 +39,7 @@ class OutputPort;
 class MidiControlNode : public NodeBase
 {
 public:
-	MidiControlNode(const std::string& path, bool polyphonic, Patch* parent, SampleRate srate, size_t buffer_size);
+	MidiControlNode(const std::string& path, bool polyphonic, PatchImpl* parent, SampleRate srate, size_t buffer_size);
 	
 	void process(ProcessContext& context);
 	
diff --git a/src/libs/engine/MidiNoteNode.cpp b/src/libs/engine/MidiNoteNode.cpp
index 146a0978..7337ade5 100644
--- a/src/libs/engine/MidiNoteNode.cpp
+++ b/src/libs/engine/MidiNoteNode.cpp
@@ -27,7 +27,7 @@
 #include "OutputPort.hpp"
 #include "PluginImpl.hpp"
 #include "AudioDriver.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "ProcessContext.hpp"
 #include "util.hpp"
 
@@ -37,7 +37,7 @@ using std::cerr; using std::cout; using std::endl;
 namespace Ingen {
 
 
-MidiNoteNode::MidiNoteNode(const string& path, bool polyphonic, Patch* parent, SampleRate srate, size_t buffer_size)
+MidiNoteNode::MidiNoteNode(const string& path, bool polyphonic, PatchImpl* parent, SampleRate srate, size_t buffer_size)
 : NodeBase(new PluginImpl(Plugin::Internal, "ingen:note_node"), path, polyphonic, parent, srate, buffer_size),
   _voices(new Raul::Array<Voice>(_polyphony)),
   _prepared_voices(NULL),
diff --git a/src/libs/engine/MidiNoteNode.hpp b/src/libs/engine/MidiNoteNode.hpp
index 1030bec5..ee708afd 100644
--- a/src/libs/engine/MidiNoteNode.hpp
+++ b/src/libs/engine/MidiNoteNode.hpp
@@ -39,7 +39,7 @@ class OutputPort;
 class MidiNoteNode : public NodeBase
 {
 public:
-	MidiNoteNode(const std::string& path, bool polyphonic, Patch* parent, SampleRate srate, size_t buffer_size);
+	MidiNoteNode(const std::string& path, bool polyphonic, PatchImpl* parent, SampleRate srate, size_t buffer_size);
 	~MidiNoteNode();
 	
 	bool prepare_poly(uint32_t poly);
diff --git a/src/libs/engine/MidiTriggerNode.cpp b/src/libs/engine/MidiTriggerNode.cpp
index 6d7da38a..f5009a80 100644
--- a/src/libs/engine/MidiTriggerNode.cpp
+++ b/src/libs/engine/MidiTriggerNode.cpp
@@ -28,7 +28,7 @@
 namespace Ingen {
 
 
-MidiTriggerNode::MidiTriggerNode(const string& path, bool polyphonic, Patch* parent, SampleRate srate, size_t buffer_size)
+MidiTriggerNode::MidiTriggerNode(const string& path, bool polyphonic, PatchImpl* parent, SampleRate srate, size_t buffer_size)
 : NodeBase(new PluginImpl(Plugin::Internal, "ingen:trigger_node"), path, false, parent, srate, buffer_size)
 {
 	_ports = new Raul::Array<PortImpl*>(5);
diff --git a/src/libs/engine/MidiTriggerNode.hpp b/src/libs/engine/MidiTriggerNode.hpp
index 46bd4c6d..308f4a9e 100644
--- a/src/libs/engine/MidiTriggerNode.hpp
+++ b/src/libs/engine/MidiTriggerNode.hpp
@@ -41,7 +41,7 @@ class OutputPort;
 class MidiTriggerNode : public NodeBase
 {
 public:
-	MidiTriggerNode(const std::string& path, bool polyphonic, Patch* parent, SampleRate srate, size_t buffer_size);
+	MidiTriggerNode(const std::string& path, bool polyphonic, PatchImpl* parent, SampleRate srate, size_t buffer_size);
 
 	void process(ProcessContext& context);
 	
diff --git a/src/libs/engine/NodeBase.cpp b/src/libs/engine/NodeBase.cpp
index d5e75970..2d0adabc 100644
--- a/src/libs/engine/NodeBase.cpp
+++ b/src/libs/engine/NodeBase.cpp
@@ -25,7 +25,7 @@
 #include "PluginImpl.hpp"
 #include "ClientBroadcaster.hpp"
 #include "PortImpl.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "ObjectStore.hpp"
 
 using namespace std;
@@ -33,10 +33,10 @@ using namespace std;
 namespace Ingen {
 
 
-NodeBase::NodeBase(const PluginImpl* plugin, const string& name, bool polyphonic, Patch* parent, SampleRate srate, size_t buffer_size)
+NodeBase::NodeBase(const PluginImpl* plugin, const string& name, bool polyphonic, PatchImpl* parent, SampleRate srate, size_t buffer_size)
 : NodeImpl(parent, name, polyphonic),
   _plugin(plugin),
-  _polyphony((polyphonic && parent) ? parent->internal_poly() : 1),
+  _polyphony((polyphonic && parent) ? parent->internal_polyphony() : 1),
   _srate(srate),
   _buffer_size(buffer_size),
   _activated(false),
@@ -50,7 +50,7 @@ NodeBase::NodeBase(const PluginImpl* plugin, const string& name, bool polyphonic
 {
 	assert(_plugin);
 	assert(_polyphony > 0);
-	assert(_parent == NULL || (_polyphony == parent->internal_poly() || _polyphony == 1));
+	assert(_parent == NULL || (_polyphony == parent->internal_polyphony() || _polyphony == 1));
 }
 
 
diff --git a/src/libs/engine/NodeBase.hpp b/src/libs/engine/NodeBase.hpp
index 9aa26310..5838614d 100644
--- a/src/libs/engine/NodeBase.hpp
+++ b/src/libs/engine/NodeBase.hpp
@@ -31,7 +31,7 @@ using std::string;
 namespace Ingen {
 
 class PluginImpl;
-class Patch;
+class PatchImpl;
 class ObjectStore;
 
 namespace Shared {
@@ -51,7 +51,7 @@ public:
 	NodeBase(const PluginImpl* plugin,
 	         const string&     name,
 	         bool              poly,
-	         Patch*            parent,
+	         PatchImpl*        parent,
 	         SampleRate        rate,
 	         size_t            buffer_size);
 
@@ -103,7 +103,7 @@ public:
 	virtual void              plugin(const PluginImpl* pi) { _plugin = pi; }
 	
 	/** A node's parent is always a patch, so static cast should be safe */
-	inline Patch* parent_patch() const { return (Patch*)_parent; }
+	inline PatchImpl* parent_patch() const { return (PatchImpl*)_parent; }
 	
 protected:
 	virtual void signal_input_ready();
diff --git a/src/libs/engine/NodeFactory.cpp b/src/libs/engine/NodeFactory.cpp
index cef8e9a4..09d69e18 100644
--- a/src/libs/engine/NodeFactory.cpp
+++ b/src/libs/engine/NodeFactory.cpp
@@ -28,7 +28,7 @@
 #include "MidiControlNode.hpp"
 #include "TransportNode.hpp"
 #include "PluginImpl.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #ifdef HAVE_SLV2
 #include "LV2Node.hpp"
 #include <slv2/slv2.h>
@@ -55,7 +55,7 @@ NodeFactory::NodeFactory(Ingen::Shared::World* world)
 	// Add builtin plugin types to _internal_plugins list
 	// FIXME: ewwww, definitely a better way to do this!
 
-	Patch* parent = new Patch(*world->local_engine, "dummy", 1, NULL, 1, 1, 1);
+	PatchImpl* parent = new PatchImpl(*world->local_engine, "dummy", 1, NULL, 1, 1, 1);
 
 	NodeImpl* n = NULL;
 	n = new MidiNoteNode("foo", 1, parent, 1, 1);
@@ -173,7 +173,7 @@ NodeImpl*
 NodeFactory::load_plugin(const PluginImpl* a_plugin,
                          const string&     name,
                          bool              polyphonic,
-                         Patch*            parent)
+                         PatchImpl*        parent)
 {
 	assert(parent != NULL);
 	assert(a_plugin);
@@ -244,7 +244,7 @@ NodeImpl*
 NodeFactory::load_internal_plugin(const string& uri,
                                   const string& name,
                                   bool          polyphonic,
-                                  Patch*        parent,
+                                  PatchImpl*    parent,
                                   SampleRate    srate,
                                   size_t        buffer_size)
 {
@@ -319,7 +319,7 @@ NodeImpl*
 NodeFactory::load_lv2_plugin(const string& plug_uri,
                              const string& node_name,
                              bool          polyphonic,
-                             Patch*        parent,
+                             PatchImpl*    parent,
                              SampleRate    srate,
                              size_t        buffer_size)
 {
@@ -456,7 +456,7 @@ NodeImpl*
 NodeFactory::load_ladspa_plugin(const string& uri,
                                 const string& name,
                                 bool          polyphonic,
-                                Patch*        parent,
+                                PatchImpl*    parent,
                                 SampleRate    srate,
                                 size_t        buffer_size)
 {
diff --git a/src/libs/engine/NodeFactory.hpp b/src/libs/engine/NodeFactory.hpp
index 47bd4993..2dacc82a 100644
--- a/src/libs/engine/NodeFactory.hpp
+++ b/src/libs/engine/NodeFactory.hpp
@@ -37,7 +37,7 @@ using std::string; using std::list;
 namespace Ingen {
 
 class NodeImpl;
-class Patch;
+class PatchImpl;
 class PluginImpl;
 
 
@@ -58,7 +58,7 @@ public:
 	~NodeFactory();
 
 	void  load_plugins();
-	NodeImpl* load_plugin(const PluginImpl* info, const string& name, bool polyphonic, Patch* parent);
+	NodeImpl* load_plugin(const PluginImpl* info, const string& name, bool polyphonic, PatchImpl* parent);
 	
 	const list<PluginImpl*>& plugins() { return _plugins; }
 	
@@ -68,15 +68,15 @@ public:
 private:
 #ifdef HAVE_LADSPA
 	void load_ladspa_plugins();
-	NodeImpl* load_ladspa_plugin(const string& plugin_uri, const string& name, bool polyphonic, Patch* parent, SampleRate srate, size_t buffer_size);
+	NodeImpl* load_ladspa_plugin(const string& plugin_uri, const string& name, bool polyphonic, PatchImpl* parent, SampleRate srate, size_t buffer_size);
 #endif
 
 #ifdef HAVE_SLV2
 	void load_lv2_plugins();
-	NodeImpl* load_lv2_plugin(const string& plugin_uri, const string& name, bool polyphonic, Patch* parent, SampleRate srate, size_t buffer_size);
+	NodeImpl* load_lv2_plugin(const string& plugin_uri, const string& name, bool polyphonic, PatchImpl* parent, SampleRate srate, size_t buffer_size);
 #endif
 
-	NodeImpl* load_internal_plugin(const string& plug_label, const string& name, bool polyphonic, Patch* parent, SampleRate srate, size_t buffer_size);
+	NodeImpl* load_internal_plugin(const string& plug_label, const string& name, bool polyphonic, PatchImpl* parent, SampleRate srate, size_t buffer_size);
 
 	Glib::Module* library(const string& path);
 	
diff --git a/src/libs/engine/NodeImpl.hpp b/src/libs/engine/NodeImpl.hpp
index f139cde0..39692cc9 100644
--- a/src/libs/engine/NodeImpl.hpp
+++ b/src/libs/engine/NodeImpl.hpp
@@ -34,7 +34,7 @@ using namespace Shared;
 
 class Buffer;
 class PluginImpl;
-class Patch;
+class PatchImpl;
 class PortImpl;
 
 
@@ -49,7 +49,7 @@ class PortImpl;
  *
  * \ingroup engine
  */
-class NodeImpl : public GraphObjectImpl, public Ingen::Shared::Node
+class NodeImpl : public GraphObjectImpl, virtual public Ingen::Shared::Node
 {
 public:
 	NodeImpl(GraphObjectImpl* parent, const std::string& name, bool poly)
@@ -144,7 +144,7 @@ public:
 	virtual void                   dependants(Raul::List<NodeImpl*>* l) = 0;
 	
 	/** The Patch this Node belongs to. */
-	virtual Patch* parent_patch() const = 0;
+	virtual PatchImpl* parent_patch() const = 0;
 
 	/** Information about the Plugin this Node is an instance of.
 	 * Not the best name - not all nodes come from plugins (ie Patch)
diff --git a/src/libs/engine/OSCClientSender.cpp b/src/libs/engine/OSCClientSender.cpp
index 2f63621c..45c0e804 100644
--- a/src/libs/engine/OSCClientSender.cpp
+++ b/src/libs/engine/OSCClientSender.cpp
@@ -23,7 +23,7 @@
 #include "ObjectStore.hpp"
 #include "NodeFactory.hpp"
 #include "util.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "NodeImpl.hpp"
 #include "PluginImpl.hpp"
 #include "PortImpl.hpp"
diff --git a/src/libs/engine/OSCEngineReceiver.hpp b/src/libs/engine/OSCEngineReceiver.hpp
index 918c15e2..bdc346d6 100644
--- a/src/libs/engine/OSCEngineReceiver.hpp
+++ b/src/libs/engine/OSCEngineReceiver.hpp
@@ -31,7 +31,7 @@ namespace Ingen {
 
 class JackDriver;
 class NodeFactory;
-class Patch;
+class PatchImpl;
 
 
 /* Some boilerplate killing macros... */
diff --git a/src/libs/engine/ObjectSender.cpp b/src/libs/engine/ObjectSender.cpp
index 208e1333..87f35b2c 100644
--- a/src/libs/engine/ObjectSender.cpp
+++ b/src/libs/engine/ObjectSender.cpp
@@ -18,7 +18,7 @@
 #include "ObjectSender.hpp"
 #include "interface/ClientInterface.hpp"
 #include "ObjectStore.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "NodeImpl.hpp"
 #include "PortImpl.hpp"
 #include "PortImpl.hpp"
@@ -31,9 +31,9 @@ namespace Ingen {
 
 
 void
-ObjectSender::send_patch(ClientInterface* client, const Patch* patch, bool recursive)
+ObjectSender::send_patch(ClientInterface* client, const PatchImpl* patch, bool recursive)
 {
-	client->new_patch(patch->path(), patch->internal_poly());
+	client->new_patch(patch->path(), patch->internal_polyphony());
 	
 	if (recursive) {
 
@@ -54,7 +54,7 @@ ObjectSender::send_patch(ClientInterface* client, const Patch* patch, bool recur
 		}
 
 		// Send connections
-		for (Patch::Connections::const_iterator j = patch->connections().begin();
+		for (PatchImpl::Connections::const_iterator j = patch->connections().begin();
 				j != patch->connections().end(); ++j)
 			client->connection((*j)->src_port_path(), (*j)->dst_port_path());
 
@@ -79,7 +79,7 @@ ObjectSender::send_node(ClientInterface* client, const NodeImpl* node, bool recu
 	assert(node->path().length() > 0);
 	
 	if (plugin->type() == Plugin::Patch) {
-		send_patch(client, (Patch*)node, recursive);
+		send_patch(client, (PatchImpl*)node, recursive);
 		return;
 	}
 
diff --git a/src/libs/engine/ObjectSender.hpp b/src/libs/engine/ObjectSender.hpp
index e1274708..7176dcaa 100644
--- a/src/libs/engine/ObjectSender.hpp
+++ b/src/libs/engine/ObjectSender.hpp
@@ -26,7 +26,7 @@ namespace Shared {
 	class ClientInterface;
 } using Shared::ClientInterface;
 
-class Patch;
+class PatchImpl;
 class NodeImpl;
 class PortImpl;
 class PluginImpl;
@@ -46,7 +46,7 @@ public:
 	
 	// FIXME: Make all object parameters const
 	
-	static void send_patch(ClientInterface* client, const Patch* patch, bool recursive);
+	static void send_patch(ClientInterface* client, const PatchImpl* patch, bool recursive);
 	static void send_node(ClientInterface* client, const NodeImpl* node, bool recursive);
 	static void send_port(ClientInterface* client, const PortImpl* port);
 };
diff --git a/src/libs/engine/ObjectStore.cpp b/src/libs/engine/ObjectStore.cpp
index 719770ed..7b9f29fe 100644
--- a/src/libs/engine/ObjectStore.cpp
+++ b/src/libs/engine/ObjectStore.cpp
@@ -21,7 +21,7 @@
 #include <raul/PathTable.hpp>
 #include <raul/TableImpl.hpp>
 #include "ObjectStore.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "NodeImpl.hpp"
 #include "PortImpl.hpp"
 #include "ThreadManager.hpp"
@@ -34,11 +34,11 @@ namespace Ingen {
 
 /** Find the Patch at the given path.
  */
-Patch*
+PatchImpl*
 ObjectStore::find_patch(const Path& path) 
 {
 	GraphObjectImpl* const object = find_object(path);
-	return dynamic_cast<Patch*>(object);
+	return dynamic_cast<PatchImpl*>(object);
 }
 
 
@@ -68,7 +68,7 @@ GraphObjectImpl*
 ObjectStore::find_object(const Path& path)
 {
 	Objects::iterator i = _objects.find(path);
-	return ((i == _objects.end()) ? NULL : i->second);
+	return ((i == _objects.end()) ? NULL : dynamic_cast<GraphObjectImpl*>(i->second.get()));
 }
 
 
@@ -94,7 +94,7 @@ ObjectStore::add(GraphObjectImpl* o)
 /** Add a family of objects to the store. Not realtime safe.
  */
 void
-ObjectStore::add(const Table<Path,GraphObjectImpl*>& table)
+ObjectStore::add(const Table<Path, SharedPtr<Shared::GraphObject> >& table)
 {
 	assert(ThreadManager::current_thread_id() == THREAD_PRE_PROCESS);
 
@@ -102,7 +102,7 @@ ObjectStore::add(const Table<Path,GraphObjectImpl*>& table)
 	_objects.cram(table);
 	
 	cerr << "[ObjectStore] Adding Table:" << endl;
-	for (Table<Path,GraphObjectImpl*>::const_iterator i = table.begin(); i != table.end(); ++i) {
+	for (Objects::const_iterator i = table.begin(); i != table.end(); ++i) {
 		cerr << i->first << " = " << i->second->path() << endl;
 	}
 }
@@ -113,7 +113,7 @@ ObjectStore::add(const Table<Path,GraphObjectImpl*>& table)
  * Returned is a vector containing all descendants of the object removed
  * including the object itself, in lexicographically sorted order by Path.
  */
-Table<Path,GraphObjectImpl*>
+Table<Path, SharedPtr<Shared::GraphObject> >
 ObjectStore::remove(const Path& path)
 {
 	return remove(_objects.find(path));
@@ -125,7 +125,7 @@ ObjectStore::remove(const Path& path)
  * Returned is a vector containing all descendants of the object removed
  * including the object itself, in lexicographically sorted order by Path.
  */
-Table<Path,GraphObjectImpl*>
+Table<Path, SharedPtr<Shared::GraphObject> >
 ObjectStore::remove(Objects::iterator object)
 {
 	assert(ThreadManager::current_thread_id() == THREAD_PRE_PROCESS);
@@ -133,8 +133,8 @@ ObjectStore::remove(Objects::iterator object)
 	if (object != _objects.end()) {
 		Objects::iterator descendants_end = _objects.find_descendants_end(object);
 		cout << "[ObjectStore] Removing " << object->first << " {" << endl;
-		Table<Path,GraphObjectImpl*> removed = _objects.yank(object, descendants_end);
-		for (Table<Path,GraphObjectImpl*>::iterator i = removed.begin(); i != removed.end(); ++i) {
+		Table<Path, SharedPtr<Shared::GraphObject> > removed = _objects.yank(object, descendants_end);
+		for (Objects::iterator i = removed.begin(); i != removed.end(); ++i) {
 			cout << "\t" << i->first << endl;
 		}
 		cout << "}" << endl;
@@ -143,7 +143,7 @@ ObjectStore::remove(Objects::iterator object)
 
 	} else {
 		cerr << "[ObjectStore] WARNING: Removing " << object->first << " failed." << endl;
-		return Table<Path,GraphObjectImpl*>();
+		return Objects();
 	}
 }
 
diff --git a/src/libs/engine/ObjectStore.hpp b/src/libs/engine/ObjectStore.hpp
index 66d182ba..cc83d85a 100644
--- a/src/libs/engine/ObjectStore.hpp
+++ b/src/libs/engine/ObjectStore.hpp
@@ -20,13 +20,16 @@
 
 #include <string>
 #include <raul/PathTable.hpp>
+#include <raul/SharedPtr.hpp>
 
 using std::string;
 using namespace Raul;
 
 namespace Ingen {
 
-class Patch;
+namespace Shared { class GraphObject; }
+
+class PatchImpl;
 class NodeImpl;
 class PortImpl;
 class GraphObjectImpl;
@@ -44,9 +47,9 @@ class GraphObjectImpl;
 class ObjectStore
 {
 public:
-	typedef Raul::PathTable<GraphObjectImpl*> Objects;
+	typedef Raul::PathTable< SharedPtr<Shared::GraphObject> > Objects;
 
-	Patch*           find_patch(const Path& path);
+	PatchImpl*       find_patch(const Path& path);
 	NodeImpl*        find_node(const Path& path);
 	PortImpl*        find_port(const Path& path);
 	GraphObjectImpl* find_object(const Path& path);
@@ -54,11 +57,11 @@ public:
 	Objects::iterator find(const Path& path) { return _objects.find(path); }
 	
 	void add(GraphObjectImpl* o);
-	void add(const Table<Path,GraphObjectImpl*>& family);
+	void add(const Table<Path, SharedPtr<Shared::GraphObject> >& family);
 	//void add(TreeNode<GraphObjectImpl*>* o);
 
-	Table<Path,GraphObjectImpl*> remove(const Path& path);
-	Table<Path,GraphObjectImpl*> remove(Objects::iterator i);
+	Table<Path, SharedPtr<Shared::GraphObject> > remove(const Path& path);
+	Table<Path, SharedPtr<Shared::GraphObject> > remove(Objects::iterator i);
 
 	const Objects& objects() const { return _objects; }
 	Objects&       objects()       { return _objects; }
diff --git a/src/libs/engine/Patch.cpp b/src/libs/engine/PatchImpl.cpp
index 8256f0c5..3e4c78c7 100644
--- a/src/libs/engine/Patch.cpp
+++ b/src/libs/engine/PatchImpl.cpp
@@ -20,7 +20,7 @@
 #include <iostream>
 #include "ThreadManager.hpp"
 #include "NodeImpl.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "PluginImpl.hpp"
 #include "PortImpl.hpp"
 #include "ConnectionImpl.hpp"
@@ -33,7 +33,7 @@ using namespace std;
 namespace Ingen {
 
 
-Patch::Patch(Engine& engine, const string& path, uint32_t poly, Patch* parent, SampleRate srate, size_t buffer_size, uint32_t internal_poly) 
+PatchImpl::PatchImpl(Engine& engine, const string& path, uint32_t poly, PatchImpl* parent, SampleRate srate, size_t buffer_size, uint32_t internal_poly) 
 : NodeBase(new PluginImpl(Plugin::Patch, "ingen:patch"), path, poly, parent, srate, buffer_size),
   _engine(engine),
   _internal_poly(internal_poly),
@@ -50,7 +50,7 @@ Patch::Patch(Engine& engine, const string& path, uint32_t poly, Patch* parent, S
 }
 
 
-Patch::~Patch()
+PatchImpl::~PatchImpl()
 {
 	assert(!_activated);
 	
@@ -70,7 +70,7 @@ Patch::~Patch()
 
 
 void
-Patch::activate()
+PatchImpl::activate()
 {
 	NodeBase::activate();
 
@@ -82,7 +82,7 @@ Patch::activate()
 
 
 void
-Patch::deactivate()
+PatchImpl::deactivate()
 {
 	if (_activated) {
 	
@@ -99,7 +99,7 @@ Patch::deactivate()
 
 
 void
-Patch::disable()
+PatchImpl::disable()
 {
 	_process = false;
 
@@ -109,7 +109,7 @@ Patch::disable()
 
 	
 bool
-Patch::prepare_internal_poly(uint32_t poly)
+PatchImpl::prepare_internal_poly(uint32_t poly)
 {
 	/* TODO: ports?  internal/external poly? */
 
@@ -126,7 +126,7 @@ Patch::prepare_internal_poly(uint32_t poly)
 
 
 bool
-Patch::apply_internal_poly(Raul::Maid& maid, uint32_t poly)
+PatchImpl::apply_internal_poly(Raul::Maid& maid, uint32_t poly)
 {
 	/* TODO: ports?  internal/external poly? */
 
@@ -147,7 +147,7 @@ Patch::apply_internal_poly(Raul::Maid& maid, uint32_t poly)
  * Calls all Nodes in (roughly, if parallel) the order _compiled_patch specifies.
  */
 void
-Patch::process(ProcessContext& context)
+PatchImpl::process(ProcessContext& context)
 {
 	if (_compiled_patch == NULL || _compiled_patch->size() == 0 || !_process)
 		return;
@@ -165,7 +165,7 @@ Patch::process(ProcessContext& context)
 
 
 void
-Patch::process_parallel(ProcessContext& context)
+PatchImpl::process_parallel(ProcessContext& context)
 {
 	size_t n_slaves = _engine.process_slaves().size();
 
@@ -233,7 +233,7 @@ Patch::process_parallel(ProcessContext& context)
 
 	
 void
-Patch::process_single(ProcessContext& context)
+PatchImpl::process_single(ProcessContext& context)
 {
 	CompiledPatch* const cp = _compiled_patch;
 
@@ -243,7 +243,7 @@ Patch::process_single(ProcessContext& context)
 	
 
 void
-Patch::set_buffer_size(size_t size)
+PatchImpl::set_buffer_size(size_t size)
 {
 	NodeBase::set_buffer_size(size);
 	assert(_buffer_size == size);
@@ -257,7 +257,7 @@ Patch::set_buffer_size(size_t size)
 
 
 void
-Patch::add_node(List<NodeImpl*>::Node* ln)
+PatchImpl::add_node(List<NodeImpl*>::Node* ln)
 {
 	assert(ln != NULL);
 	assert(ln->elem() != NULL);
@@ -271,8 +271,8 @@ Patch::add_node(List<NodeImpl*>::Node* ln)
 /** Remove a node.
  * Realtime Safe.  Preprocessing thread.
  */
-Patch::Nodes::Node*
-Patch::remove_node(const string& name)
+PatchImpl::Nodes::Node*
+PatchImpl::remove_node(const string& name)
 {
 	for (List<NodeImpl*>::iterator i = _nodes.begin(); i != _nodes.end(); ++i)
 		if ((*i)->name() == name)
@@ -284,8 +284,8 @@ Patch::remove_node(const string& name)
 
 /** Remove a connection.  Realtime safe.
  */
-Patch::Connections::Node*
-Patch::remove_connection(const PortImpl* src_port, const PortImpl* dst_port)
+PatchImpl::Connections::Node*
+PatchImpl::remove_connection(const PortImpl* src_port, const PortImpl* dst_port)
 {
 	bool found = false;
 	Connections::Node* connection = NULL;
@@ -299,14 +299,14 @@ Patch::remove_connection(const PortImpl* src_port, const PortImpl* dst_port)
 	}
 
 	if ( ! found)
-		cerr << "WARNING:  [Patch::remove_connection] Connection not found !" << endl;
+		cerr << "WARNING:  [PatchImpl::remove_connection] Connection not found !" << endl;
 
 	return connection;
 }
 
 
 uint32_t
-Patch::num_ports() const
+PatchImpl::num_ports() const
 {
 	ThreadID context = ThreadManager::current_thread_id();
 
@@ -320,10 +320,10 @@ Patch::num_ports() const
 /** Create a port.  Not realtime safe.
  */
 PortImpl*
-Patch::create_port(const string& name, DataType type, size_t buffer_size, bool is_output)
+PatchImpl::create_port(const string& name, DataType type, size_t buffer_size, bool is_output)
 {
 	if (type == DataType::UNKNOWN) {
-		cerr << "[Patch::create_port] Unknown port type " << type.uri() << endl;
+		cerr << "[PatchImpl::create_port] Unknown port type " << type.uri() << endl;
 		return NULL;
 	}
 
@@ -341,7 +341,7 @@ Patch::create_port(const string& name, DataType type, size_t buffer_size, bool i
  * Realtime safe.  Preprocessing thread only.
  */
 List<PortImpl*>::Node*
-Patch::remove_port(const string& name)
+PatchImpl::remove_port(const string& name)
 {
 	assert(ThreadManager::current_thread_id() == THREAD_PRE_PROCESS);
 
@@ -363,14 +363,14 @@ Patch::remove_port(const string& name)
 	}
 
 	if ( ! found)
-		cerr << "WARNING:  [Patch::remove_port] Port not found !" << endl;
+		cerr << "WARNING:  [PatchImpl::remove_port] Port not found !" << endl;
 
 	return ret;
 }
 
 
 Raul::Array<PortImpl*>*
-Patch::build_ports_array() const
+PatchImpl::build_ports_array() const
 {
 	assert(ThreadManager::current_thread_id() == THREAD_PRE_PROCESS);
 
@@ -399,7 +399,7 @@ Patch::build_ports_array() const
  * Not realtime safe.
  */
 CompiledPatch*
-Patch::compile() const
+PatchImpl::compile() const
 {
 	assert(ThreadManager::current_thread_id() == THREAD_PRE_PROCESS);
 
diff --git a/src/libs/engine/Patch.hpp b/src/libs/engine/PatchImpl.hpp
index 8b9f9ad7..94a9ebf3 100644
--- a/src/libs/engine/Patch.hpp
+++ b/src/libs/engine/PatchImpl.hpp
@@ -15,16 +15,17 @@
  * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  */
 
-#ifndef PATCH_H
-#define PATCH_H
+#ifndef PATCHIMPL_H
+#define PATCHIMPL_H
 
 #include <cstdlib>
 #include <string>
 #include <raul/List.hpp>
 #include <raul/SharedPtr.hpp>
+#include "interface/DataType.hpp"
+#include "interface/Patch.hpp"
 #include "NodeBase.hpp"
 #include "PluginImpl.hpp"
-#include "interface/DataType.hpp"
 #include "CompiledPatch.hpp"
 
 using std::string;
@@ -49,18 +50,18 @@ class CompiledPatch;
  *
  * \ingroup engine
  */
-class Patch : public NodeBase
+class PatchImpl : public NodeBase, public Ingen::Shared::Patch
 {
 public:
-	Patch(Engine&       engine,
+	PatchImpl(Engine&   engine,
 	      const string& name,
 	      uint32_t      poly,
-	      Patch*        parent,
+	      PatchImpl*    parent,
 	      SampleRate    srate,
 	      size_t        buffer_size,
 	      uint32_t      local_poly);
 
-	virtual ~Patch();
+	virtual ~PatchImpl();
 
 	void activate();
 	void deactivate();
@@ -87,7 +88,6 @@ public:
 	
 	// Patch specific stuff not inherited from Node
 	
-	typedef List< SharedPtr<Shared::Connection> > Connections;
 	typedef List<NodeImpl*>                       Nodes;
 	
 	void         add_node(Nodes::Node* tn);
@@ -123,7 +123,7 @@ public:
 	void enable() { _process = true; }
 	void disable();
 
-	uint32_t internal_poly() const { return _internal_poly; }
+	uint32_t internal_polyphony() const { return _internal_poly; }
 
 private:
 	inline void compile_recursive(NodeImpl* n, CompiledPatch* output) const;
@@ -144,7 +144,7 @@ private:
 
 /** Private helper for compile */
 inline void
-Patch::compile_recursive(NodeImpl* n, CompiledPatch* output) const
+PatchImpl::compile_recursive(NodeImpl* n, CompiledPatch* output) const
 {
 	if (n == NULL || n->traversed())
 		return;
@@ -162,4 +162,4 @@ Patch::compile_recursive(NodeImpl* n, CompiledPatch* output) const
 
 } // namespace Ingen
 
-#endif // PATCH_H
+#endif // PATCHIMPL_H
diff --git a/src/libs/engine/PluginImpl.cpp b/src/libs/engine/PluginImpl.cpp
index 710c6385..e8b090ef 100644
--- a/src/libs/engine/PluginImpl.cpp
+++ b/src/libs/engine/PluginImpl.cpp
@@ -24,7 +24,7 @@
 namespace Ingen {
 
 NodeImpl*
-PluginImpl::instantiate(const string& name, bool polyphonic, Ingen::Patch* parent, SampleRate srate, size_t buffer_size)
+PluginImpl::instantiate(const string& name, bool polyphonic, Ingen::PatchImpl* parent, SampleRate srate, size_t buffer_size)
 {
 	assert(_type == Internal);
 
diff --git a/src/libs/engine/PluginImpl.hpp b/src/libs/engine/PluginImpl.hpp
index 13f17ca6..86d3cc5b 100644
--- a/src/libs/engine/PluginImpl.hpp
+++ b/src/libs/engine/PluginImpl.hpp
@@ -36,7 +36,7 @@ using Ingen::Shared::Plugin;
 
 namespace Ingen {
 
-class Patch;
+class PatchImpl;
 class NodeImpl;
 
 
@@ -117,7 +117,7 @@ public:
 	void       slv2_plugin(SLV2Plugin p) { _slv2_plugin = p; }	
 #endif
 
-	NodeImpl* instantiate(const string& name, bool polyphonic, Ingen::Patch* parent, SampleRate srate, size_t buffer_size);
+	NodeImpl* instantiate(const string& name, bool polyphonic, Ingen::PatchImpl* parent, SampleRate srate, size_t buffer_size);
 
 private:
 	Plugin::Type  _type;
diff --git a/src/libs/engine/TransportNode.cpp b/src/libs/engine/TransportNode.cpp
index dca8eecb..6a9fa73d 100644
--- a/src/libs/engine/TransportNode.cpp
+++ b/src/libs/engine/TransportNode.cpp
@@ -27,7 +27,7 @@
 namespace Ingen {
 
 
-TransportNode::TransportNode(const string& path, bool polyphonic, Patch* parent, SampleRate srate, size_t buffer_size)
+TransportNode::TransportNode(const string& path, bool polyphonic, PatchImpl* parent, SampleRate srate, size_t buffer_size)
 : NodeBase(new PluginImpl(Plugin::Internal, "ingen:transport_node"), path, false, parent, srate, buffer_size)
 {
 #if 0
diff --git a/src/libs/engine/TransportNode.hpp b/src/libs/engine/TransportNode.hpp
index e79d5737..af0ed207 100644
--- a/src/libs/engine/TransportNode.hpp
+++ b/src/libs/engine/TransportNode.hpp
@@ -34,7 +34,7 @@ namespace Ingen {
 class TransportNode : public NodeBase
 {
 public:
-	TransportNode(const std::string& path, bool polyphonic, Patch* parent, SampleRate srate, size_t buffer_size);
+	TransportNode(const std::string& path, bool polyphonic, PatchImpl* parent, SampleRate srate, size_t buffer_size);
 
 	virtual void process(ProcessContext& context);
 };
diff --git a/src/libs/engine/events/AllNotesOffEvent.cpp b/src/libs/engine/events/AllNotesOffEvent.cpp
index f3491dac..2e1f45fa 100644
--- a/src/libs/engine/events/AllNotesOffEvent.cpp
+++ b/src/libs/engine/events/AllNotesOffEvent.cpp
@@ -25,7 +25,7 @@ namespace Ingen {
 
 /** Note off with patch explicitly passed - triggered by MIDI.
  */
-AllNotesOffEvent::AllNotesOffEvent(Engine& engine, SharedPtr<Responder> responder, SampleCount timestamp, Patch* patch)
+AllNotesOffEvent::AllNotesOffEvent(Engine& engine, SharedPtr<Responder> responder, SampleCount timestamp, PatchImpl* patch)
 : Event(engine, responder, timestamp),
   _patch(patch)
 {
@@ -36,8 +36,8 @@ AllNotesOffEvent::AllNotesOffEvent(Engine& engine, SharedPtr<Responder> responde
  */
 AllNotesOffEvent::AllNotesOffEvent(Engine& engine, SharedPtr<Responder> responder, SampleCount timestamp, const string& patch_path)
 : Event(engine, responder, timestamp),
-  _patch(NULL),
-  _patch_path(patch_path)
+  _patch_path(patch_path),
+  _patch(NULL)
 {
 }
 
diff --git a/src/libs/engine/events/AllNotesOffEvent.hpp b/src/libs/engine/events/AllNotesOffEvent.hpp
index 4c2a9309..3e4d56b3 100644
--- a/src/libs/engine/events/AllNotesOffEvent.hpp
+++ b/src/libs/engine/events/AllNotesOffEvent.hpp
@@ -24,7 +24,7 @@ using std::string;
 
 namespace Ingen {
 
-class Patch;
+class PatchImpl;
 
 
 /** A note off event for all active voices.
@@ -34,15 +34,15 @@ class Patch;
 class AllNotesOffEvent : public Event
 {
 public:
-	AllNotesOffEvent(Engine& engine, SharedPtr<Responder> responder, SampleCount timestamp, Patch* patch);
+	AllNotesOffEvent(Engine& engine, SharedPtr<Responder> responder, SampleCount timestamp, PatchImpl* patch);
 	AllNotesOffEvent(Engine& engine, SharedPtr<Responder> responder, SampleCount timestamp, const string& patch_path);
 	
 	void execute(ProcessContext& context);
 	void post_process();
 
 private:
-	Patch* _patch;
-	string _patch_path;
+	const string _patch_path;
+	PatchImpl*   _patch;
 };
 
 
diff --git a/src/libs/engine/events/ClearPatchEvent.cpp b/src/libs/engine/events/ClearPatchEvent.cpp
index 0d76724a..211ca79e 100644
--- a/src/libs/engine/events/ClearPatchEvent.cpp
+++ b/src/libs/engine/events/ClearPatchEvent.cpp
@@ -19,7 +19,7 @@
 #include "ClearPatchEvent.hpp"
 #include "Responder.hpp"
 #include "Engine.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "ClientBroadcaster.hpp"
 #include "util.hpp"
 #include "ObjectStore.hpp"
@@ -92,7 +92,7 @@ ClearPatchEvent::post_process()
 		_patch->nodes().clear();
 
 		// Delete all connections
-		for (Patch::Connections::iterator i = _patch->connections().begin(); i != _patch->connections().end(); ++i)
+		for (PatchImpl::Connections::iterator i = _patch->connections().begin(); i != _patch->connections().end(); ++i)
 			(*i).reset();
 
 		_patch->connections().clear();
diff --git a/src/libs/engine/events/ClearPatchEvent.hpp b/src/libs/engine/events/ClearPatchEvent.hpp
index b1174c04..afe66eed 100644
--- a/src/libs/engine/events/ClearPatchEvent.hpp
+++ b/src/libs/engine/events/ClearPatchEvent.hpp
@@ -26,7 +26,7 @@ using std::string;
 
 namespace Ingen {
 
-class Patch;
+class PatchImpl;
 
 
 /** Delete all nodes from a patch.
@@ -43,9 +43,9 @@ public:
 	void post_process();
 
 private:
-	string _patch_path;
-	Patch* _patch;
-	bool   _process;
+	const string _patch_path;
+	PatchImpl*   _patch;
+	bool         _process;
 };
 
 
diff --git a/src/libs/engine/events/ConnectionEvent.cpp b/src/libs/engine/events/ConnectionEvent.cpp
index 3a954781..ee2c1694 100644
--- a/src/libs/engine/events/ConnectionEvent.cpp
+++ b/src/libs/engine/events/ConnectionEvent.cpp
@@ -25,7 +25,7 @@
 #include "ConnectionImpl.hpp"
 #include "InputPort.hpp"
 #include "OutputPort.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "ClientBroadcaster.hpp"
 #include "PortImpl.hpp"
 #include "ObjectStore.hpp"
@@ -98,13 +98,13 @@ ConnectionEvent::pre_process()
 
 		assert(src_node->parent() == dst_node || dst_node->parent() == src_node);
 		if (src_node->parent() == dst_node)
-			_patch = dynamic_cast<Patch*>(dst_node);
+			_patch = dynamic_cast<PatchImpl*>(dst_node);
 		else
-			_patch = dynamic_cast<Patch*>(src_node);
+			_patch = dynamic_cast<PatchImpl*>(src_node);
 	
 	// Connection from a patch input to a patch output (pass through)
-	} else if (src_node == dst_node && dynamic_cast<Patch*>(src_node)) {
-		_patch = dynamic_cast<Patch*>(src_node);
+	} else if (src_node == dst_node && dynamic_cast<PatchImpl*>(src_node)) {
+		_patch = dynamic_cast<PatchImpl*>(src_node);
 	
 	// Normal connection between nodes with the same parent
 	} else {
@@ -126,7 +126,7 @@ ConnectionEvent::pre_process()
 	}
 
 	_connection = SharedPtr<ConnectionImpl>(new ConnectionImpl(_src_port, _dst_port));
-	_patch_listnode = new Patch::Connections::Node(_connection);
+	_patch_listnode = new PatchImpl::Connections::Node(_connection);
 	_port_listnode = new InputPort::Connections::Node(_connection);
 	
 	// Need to be careful about patch port connections here and adding a node's
diff --git a/src/libs/engine/events/ConnectionEvent.hpp b/src/libs/engine/events/ConnectionEvent.hpp
index 1d46be6f..89407957 100644
--- a/src/libs/engine/events/ConnectionEvent.hpp
+++ b/src/libs/engine/events/ConnectionEvent.hpp
@@ -21,7 +21,7 @@
 #include <string>
 #include <raul/Path.hpp>
 #include "QueuedEvent.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "InputPort.hpp"
 #include "types.hpp"
 using std::string;
@@ -33,7 +33,7 @@ namespace Raul {
 
 namespace Ingen {
 	
-class Patch;
+class PatchImpl;
 class NodeImpl;
 class ConnectionImpl;
 class MidiMessage;
@@ -71,7 +71,7 @@ private:
 	Raul::Path _src_port_path;
 	Raul::Path _dst_port_path;
 	
-	Patch*      _patch;
+	PatchImpl*  _patch;
 	PortImpl*   _src_port;
 	PortImpl*   _dst_port;
 	OutputPort* _src_output_port;
@@ -80,7 +80,7 @@ private:
 	CompiledPatch* _compiled_patch; ///< New process order for Patch
 	
 	SharedPtr<ConnectionImpl>     _connection;
-	Patch::Connections::Node*     _patch_listnode;
+	PatchImpl::Connections::Node* _patch_listnode;
 	InputPort::Connections::Node* _port_listnode;
 
 	ErrorType _error;
diff --git a/src/libs/engine/events/CreateNodeEvent.cpp b/src/libs/engine/events/CreateNodeEvent.cpp
index a863e008..a0a8d08f 100644
--- a/src/libs/engine/events/CreateNodeEvent.cpp
+++ b/src/libs/engine/events/CreateNodeEvent.cpp
@@ -20,11 +20,11 @@
 #include <raul/Path.hpp>
 #include "CreateNodeEvent.hpp"
 #include "Responder.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "NodeImpl.hpp"
 #include "PluginImpl.hpp"
 #include "Engine.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "NodeFactory.hpp"
 #include "ClientBroadcaster.hpp"
 #include "ObjectStore.hpp"
@@ -91,7 +91,7 @@ CreateNodeEvent::pre_process()
 		
 			// This can be done here because the audio thread doesn't touch the
 			// node tree - just the process order array
-			_patch->add_node(new Patch::Nodes::Node(_node));
+			_patch->add_node(new PatchImpl::Nodes::Node(_node));
 			//_node->add_to_store(_engine.object_store());
 			_engine.object_store()->add(_node);
 			
diff --git a/src/libs/engine/events/CreateNodeEvent.hpp b/src/libs/engine/events/CreateNodeEvent.hpp
index 75dfe3d7..6c3f2a94 100644
--- a/src/libs/engine/events/CreateNodeEvent.hpp
+++ b/src/libs/engine/events/CreateNodeEvent.hpp
@@ -28,7 +28,7 @@ template<typename T> class TreeNode;
 
 namespace Ingen {
 
-class Patch;
+class PatchImpl;
 class NodeImpl;
 class CompiledPatch;
 
@@ -69,7 +69,7 @@ private:
 	string         _plugin_lib;
 	string         _plugin_label;
 	bool           _poly;
-	Patch*         _patch;
+	PatchImpl*     _patch;
 	NodeImpl*      _node;
 	CompiledPatch* _compiled_patch; ///< Patch's new process order
 	bool           _node_already_exists;
diff --git a/src/libs/engine/events/CreatePatchEvent.cpp b/src/libs/engine/events/CreatePatchEvent.cpp
index 3d08a44b..8642dc1d 100644
--- a/src/libs/engine/events/CreatePatchEvent.cpp
+++ b/src/libs/engine/events/CreatePatchEvent.cpp
@@ -19,7 +19,7 @@
 #include <raul/Path.hpp>
 #include "CreatePatchEvent.hpp"
 #include "Responder.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "NodeImpl.hpp"
 #include "PluginImpl.hpp"
 #include "Engine.hpp"
@@ -65,13 +65,13 @@ CreatePatchEvent::pre_process()
 	}
 	
 	uint32_t poly = 1;
-	if (_parent != NULL && _poly > 1 && _poly == static_cast<int>(_parent->internal_poly()))
+	if (_parent != NULL && _poly > 1 && _poly == static_cast<int>(_parent->internal_polyphony()))
 		poly = _poly;
 	
-	_patch = new Patch(_engine, _path.name(), poly, _parent, _engine.audio_driver()->sample_rate(), _engine.audio_driver()->buffer_size(), _poly);
+	_patch = new PatchImpl(_engine, _path.name(), poly, _parent, _engine.audio_driver()->sample_rate(), _engine.audio_driver()->buffer_size(), _poly);
 		
 	if (_parent != NULL) {
-		_parent->add_node(new Patch::Nodes::Node(_patch));
+		_parent->add_node(new PatchImpl::Nodes::Node(_patch));
 
 		if (_parent->enabled())
 			_compiled_patch = _parent->compile();
diff --git a/src/libs/engine/events/CreatePatchEvent.hpp b/src/libs/engine/events/CreatePatchEvent.hpp
index 15b67ffb..bcbcf35b 100644
--- a/src/libs/engine/events/CreatePatchEvent.hpp
+++ b/src/libs/engine/events/CreatePatchEvent.hpp
@@ -29,7 +29,7 @@ template<typename T> class TreeNode;
 
 namespace Ingen {
 	
-class Patch;
+class PatchImpl;
 class CompiledPatch;
 
 
@@ -49,12 +49,12 @@ public:
 private:
 	enum ErrorType { NO_ERROR, OBJECT_EXISTS, PARENT_NOT_FOUND, INVALID_POLY };
 	
-	Raul::Path        _path;
-	Patch*            _patch;
-	Patch*            _parent;
-	CompiledPatch*    _compiled_patch;
-	int               _poly;
-	ErrorType         _error;
+	Raul::Path     _path;
+	PatchImpl*     _patch;
+	PatchImpl*     _parent;
+	CompiledPatch* _compiled_patch;
+	int            _poly;
+	ErrorType      _error;
 };
 
 
diff --git a/src/libs/engine/events/CreatePortEvent.cpp b/src/libs/engine/events/CreatePortEvent.cpp
index cba4dd77..27dcf7bc 100644
--- a/src/libs/engine/events/CreatePortEvent.cpp
+++ b/src/libs/engine/events/CreatePortEvent.cpp
@@ -21,10 +21,10 @@
 #include <raul/Maid.hpp>
 #include "Responder.hpp"
 #include "CreatePortEvent.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "PluginImpl.hpp"
 #include "Engine.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "QueuedEventSource.hpp"
 #include "ObjectStore.hpp"
 #include "ClientBroadcaster.hpp"
diff --git a/src/libs/engine/events/CreatePortEvent.hpp b/src/libs/engine/events/CreatePortEvent.hpp
index d7835a25..5ddd8aa3 100644
--- a/src/libs/engine/events/CreatePortEvent.hpp
+++ b/src/libs/engine/events/CreatePortEvent.hpp
@@ -29,7 +29,7 @@ template <typename T> class Array;
 
 namespace Ingen {
 
-class Patch;
+class PatchImpl;
 class PortImpl;
 class DriverPort;
 
@@ -59,7 +59,7 @@ private:
 	string                  _type;
 	bool                    _is_output;
 	DataType                _data_type;
-	Patch*                  _patch;
+	PatchImpl*              _patch;
 	PortImpl*               _patch_port;
 	Raul::Array<PortImpl*>* _ports_array; ///< New (external) ports array for Patch
 	DriverPort*             _driver_port; ///< Driver (eg Jack) port if this is a toplevel port
diff --git a/src/libs/engine/events/DestroyEvent.cpp b/src/libs/engine/events/DestroyEvent.cpp
index 7fdda39f..cf250f2f 100644
--- a/src/libs/engine/events/DestroyEvent.cpp
+++ b/src/libs/engine/events/DestroyEvent.cpp
@@ -20,7 +20,7 @@
 #include "DestroyEvent.hpp"
 #include "Responder.hpp"
 #include "Engine.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "NodeBase.hpp"
 #include "PluginImpl.hpp"
 #include "AudioDriver.hpp"
@@ -40,8 +40,6 @@ DestroyEvent::DestroyEvent(Engine& engine, SharedPtr<Responder> responder, Frame
   _path(path),
   _store_iterator(engine.object_store()->objects().end()),
   _removed_table(NULL),
-  _node(NULL),
-  _port(NULL),
   _driver_port(NULL),
   _patch_node_listnode(NULL),
   _patch_port_listnode(NULL),
@@ -67,10 +65,10 @@ DestroyEvent::pre_process()
 	_store_iterator = _engine.object_store()->find(_path);
 
 	if (_store_iterator != _engine.object_store()->objects().end())  {
-		_node = dynamic_cast<NodeImpl*>(_store_iterator->second);
+		_node = PtrCast<NodeImpl>(_store_iterator->second);
 
 		if (!_node)
-			_port = dynamic_cast<PortImpl*>(_store_iterator->second);
+			_port = PtrCast<PortImpl>(_store_iterator->second);
 	}
 			
 	if (_store_iterator != _engine.object_store()->objects().end()) {
@@ -81,9 +79,9 @@ DestroyEvent::pre_process()
 		assert(_node->parent_patch());
 		_patch_node_listnode = _node->parent_patch()->remove_node(_path.name());
 		if (_patch_node_listnode) {
-			assert(_patch_node_listnode->elem() == _node);
+			assert(_patch_node_listnode->elem() == _node.get());
 			
-			_disconnect_node_event = new DisconnectNodeEvent(_engine, _node);
+			_disconnect_node_event = new DisconnectNodeEvent(_engine, _node.get());
 			_disconnect_node_event->pre_process();
 			
 			if (_node->parent_patch()->enabled()) {
@@ -92,7 +90,7 @@ DestroyEvent::pre_process()
 #ifndef NDEBUG
 				// Be sure node is removed from process order, so it can be destroyed
 				for (size_t i=0; i < _compiled_patch->size(); ++i) {
-					assert(_compiled_patch->at(i).node() != _node);
+					assert(_compiled_patch->at(i).node() != _node.get());
 					// FIXME: check providers/dependants too
 				}
 #endif
@@ -102,11 +100,11 @@ DestroyEvent::pre_process()
 		assert(_port->parent_patch());
 		_patch_port_listnode = _port->parent_patch()->remove_port(_path.name());
 		if (_patch_port_listnode) {
-			assert(_patch_port_listnode->elem() == _port);
+			assert(_patch_port_listnode->elem() == _port.get());
 			
 			//_port->remove_from_store();
 
-			_disconnect_port_event = new DisconnectPortEvent(_engine, _port->parent_patch(), _port);
+			_disconnect_port_event = new DisconnectPortEvent(_engine, _port->parent_patch(), _port.get());
 			_disconnect_port_event->pre_process();
 			
 			if (_port->parent_patch()->enabled()) {
@@ -187,7 +185,8 @@ DestroyEvent::post_process()
 			_disconnect_node_event->post_process();
 		_engine.broadcaster()->send_destroyed(_path);
 		_engine.maid()->push(_patch_node_listnode);
-		_engine.maid()->push(_node);
+		//_engine.maid()->push(_node);
+		_node.reset();
 	} else if (_patch_port_listnode) {	
 		assert(_port);
 		_responder->respond_ok();
@@ -195,7 +194,8 @@ DestroyEvent::post_process()
 			_disconnect_port_event->post_process();
 		_engine.broadcaster()->send_destroyed(_path);
 		_engine.maid()->push(_patch_port_listnode);
-		_engine.maid()->push(_port);
+		//_engine.maid()->push(_port);
+		_port.reset();
 	} else {
 		_responder->respond_error("Unable to destroy object");
 	}
diff --git a/src/libs/engine/events/DestroyEvent.hpp b/src/libs/engine/events/DestroyEvent.hpp
index e253167f..10e59751 100644
--- a/src/libs/engine/events/DestroyEvent.hpp
+++ b/src/libs/engine/events/DestroyEvent.hpp
@@ -22,7 +22,7 @@
 #include <raul/Path.hpp>
 #include "QueuedEvent.hpp"
 #include "ObjectStore.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 
 using std::string;
 
@@ -58,18 +58,18 @@ public:
 	void post_process();
 
 private:
-	Path                           _path;
-	ObjectStore::Objects::iterator _store_iterator;
-	Table<Path,GraphObjectImpl*>   _removed_table;
-	NodeImpl*                      _node;  ///< Same as _object if it is a Node, otherwise NULL
-	PortImpl*                      _port;  ///< Same as _object if it is a Port, otherwise NULL
-	DriverPort*                    _driver_port;
-	Patch::Nodes::Node*            _patch_node_listnode;
-	Raul::List<PortImpl*>::Node*   _patch_port_listnode;
-	Raul::Array<PortImpl*>*        _ports_array; ///< New (external) ports array for Patch
-	CompiledPatch*                 _compiled_patch;  ///< Patch's new process order
-	DisconnectNodeEvent*           _disconnect_node_event;
-	DisconnectPortEvent*           _disconnect_port_event;
+	Path                                         _path;
+	ObjectStore::Objects::iterator               _store_iterator;
+	Table<Path, SharedPtr<Shared::GraphObject> > _removed_table;
+	SharedPtr<NodeImpl>                          _node;  ///< Non-NULL iff a node
+	SharedPtr<PortImpl>                          _port;  ///< Non-NULL iff a port
+	DriverPort*                                  _driver_port;
+	PatchImpl::Nodes::Node*                      _patch_node_listnode;
+	Raul::List<PortImpl*>::Node*                 _patch_port_listnode;
+	Raul::Array<PortImpl*>*                      _ports_array; ///< New (external) ports for Patch
+	CompiledPatch*                               _compiled_patch;  ///< Patch's new process order
+	DisconnectNodeEvent*                         _disconnect_node_event;
+	DisconnectPortEvent*                         _disconnect_port_event;
 };
 
 
diff --git a/src/libs/engine/events/DisconnectNodeEvent.cpp b/src/libs/engine/events/DisconnectNodeEvent.cpp
index f085e974..4fa92af0 100644
--- a/src/libs/engine/events/DisconnectNodeEvent.cpp
+++ b/src/libs/engine/events/DisconnectNodeEvent.cpp
@@ -28,7 +28,7 @@
 #include "NodeImpl.hpp"
 #include "ObjectStore.hpp"
 #include "OutputPort.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "PortImpl.hpp"
 #include "Responder.hpp"
 #include "util.hpp"
@@ -88,7 +88,7 @@ DisconnectNodeEvent::pre_process()
 		}
 	}
 
-	for (Patch::Connections::const_iterator i = _patch->connections().begin(); i != _patch->connections().end(); ++i) {
+	for (PatchImpl::Connections::const_iterator i = _patch->connections().begin(); i != _patch->connections().end(); ++i) {
 		ConnectionImpl* c = (ConnectionImpl*)i->get();
 		if ((c->src_port()->parent_node() == _node || c->dst_port()->parent_node() == _node) && !c->pending_disconnection()) {
 			DisconnectionEvent* ev = new DisconnectionEvent(_engine, SharedPtr<Responder>(new Responder()), _time,
diff --git a/src/libs/engine/events/DisconnectNodeEvent.hpp b/src/libs/engine/events/DisconnectNodeEvent.hpp
index cefe5a25..6d38c768 100644
--- a/src/libs/engine/events/DisconnectNodeEvent.hpp
+++ b/src/libs/engine/events/DisconnectNodeEvent.hpp
@@ -28,7 +28,7 @@ using std::string;
 namespace Ingen {
 
 class DisconnectionEvent;
-class Patch;
+class PatchImpl;
 class NodeImpl;
 class Connection;
 class PortImpl;
@@ -53,7 +53,7 @@ public:
 
 private:
 	Raul::Path                      _node_path;
-	Patch*                          _patch;
+	PatchImpl*                      _patch;
 	NodeImpl*                       _node;
 	Raul::List<DisconnectionEvent*> _disconnection_events;
 	
diff --git a/src/libs/engine/events/DisconnectPortEvent.cpp b/src/libs/engine/events/DisconnectPortEvent.cpp
index 9aaf5c45..617d86a2 100644
--- a/src/libs/engine/events/DisconnectPortEvent.cpp
+++ b/src/libs/engine/events/DisconnectPortEvent.cpp
@@ -28,7 +28,7 @@
 #include "PortImpl.hpp"
 #include "InputPort.hpp"
 #include "OutputPort.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "ClientBroadcaster.hpp"
 #include "util.hpp"
 #include "ObjectStore.hpp"
@@ -51,7 +51,7 @@ DisconnectPortEvent::DisconnectPortEvent(Engine& engine, SharedPtr<Responder> re
 }
 
 
-DisconnectPortEvent::DisconnectPortEvent(Engine& engine, Patch* patch, Port* port)
+DisconnectPortEvent::DisconnectPortEvent(Engine& engine, PatchImpl* patch, Port* port)
 : QueuedEvent(engine),
   _port_path(port->path()),
   _patch(patch),
@@ -103,7 +103,7 @@ DisconnectPortEvent::pre_process()
 		return;
 	}
 	
-	for (Patch::Connections::const_iterator i = _patch->connections().begin();
+	for (PatchImpl::Connections::const_iterator i = _patch->connections().begin();
 			i != _patch->connections().end(); ++i) {
 		ConnectionImpl* c = (ConnectionImpl*)i->get();
 		if ((c->src_port() == _port || c->dst_port() == _port) && !c->pending_disconnection()) {
diff --git a/src/libs/engine/events/DisconnectPortEvent.hpp b/src/libs/engine/events/DisconnectPortEvent.hpp
index b30151ed..de75ddf2 100644
--- a/src/libs/engine/events/DisconnectPortEvent.hpp
+++ b/src/libs/engine/events/DisconnectPortEvent.hpp
@@ -28,7 +28,7 @@ namespace Raul { template <typename T> class Array; }
 namespace Ingen {
 
 	
-class Patch;
+class PatchImpl;
 class NodeImpl;
 class Connection;
 class PortImpl;
@@ -45,7 +45,7 @@ class DisconnectPortEvent : public QueuedEvent
 {
 public:
 	DisconnectPortEvent(Engine& engine, SharedPtr<Responder> responder, SampleCount timestamp, const string& port_path);
-	DisconnectPortEvent(Engine& engine, Patch* patch, Port* port);
+	DisconnectPortEvent(Engine& engine, PatchImpl* patch, Port* port);
 	~DisconnectPortEvent();
 
 	void pre_process();
@@ -54,7 +54,7 @@ public:
 
 private:
 	Path                      _port_path;
-	Patch*                    _patch;
+	PatchImpl*                _patch;
 	Port*                     _port;
 	Raul::List<DisconnectionEvent*> _disconnection_events;
 	
diff --git a/src/libs/engine/events/DisconnectionEvent.cpp b/src/libs/engine/events/DisconnectionEvent.cpp
index 6e69c3ba..e85b4fcf 100644
--- a/src/libs/engine/events/DisconnectionEvent.cpp
+++ b/src/libs/engine/events/DisconnectionEvent.cpp
@@ -24,7 +24,7 @@
 #include "ConnectionImpl.hpp"
 #include "InputPort.hpp"
 #include "OutputPort.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "ClientBroadcaster.hpp"
 #include "PortImpl.hpp"
 #include "ObjectStore.hpp"
@@ -111,13 +111,13 @@ DisconnectionEvent::pre_process()
 
 		assert(src_node->parent() == dst_node || dst_node->parent() == src_node);
 		if (src_node->parent() == dst_node)
-			_patch = dynamic_cast<Patch*>(dst_node);
+			_patch = dynamic_cast<PatchImpl*>(dst_node);
 		else
-			_patch = dynamic_cast<Patch*>(src_node);
+			_patch = dynamic_cast<PatchImpl*>(src_node);
 	
 	// Connection from a patch input to a patch output (pass through)
-	} else if (src_node == dst_node && dynamic_cast<Patch*>(src_node)) {
-		_patch = dynamic_cast<Patch*>(src_node);
+	} else if (src_node == dst_node && dynamic_cast<PatchImpl*>(src_node)) {
+		_patch = dynamic_cast<PatchImpl*>(src_node);
 	
 	// Normal connection between nodes with the same parent
 	} else {
@@ -161,7 +161,7 @@ DisconnectionEvent::execute(ProcessContext& context)
 			= _dst_input_port->remove_connection(_src_output_port);
 		
 		if (port_connection != NULL) {
-			Patch::Connections::Node* const patch_connection
+			PatchImpl::Connections::Node* const patch_connection
 				= _patch->remove_connection(_src_port, _dst_port);
 			
 			assert(patch_connection);
diff --git a/src/libs/engine/events/DisconnectionEvent.hpp b/src/libs/engine/events/DisconnectionEvent.hpp
index 603eaf47..ea4dbbda 100644
--- a/src/libs/engine/events/DisconnectionEvent.hpp
+++ b/src/libs/engine/events/DisconnectionEvent.hpp
@@ -31,7 +31,7 @@ namespace Raul {
 
 namespace Ingen {
 	
-class Patch;
+class PatchImpl;
 class NodeImpl;
 class ConnectionImpl;
 class MidiMessage;
@@ -70,7 +70,7 @@ private:
 	Raul::Path _src_port_path;
 	Raul::Path _dst_port_path;
 	
-	Patch*      _patch;
+	PatchImpl*  _patch;
 	PortImpl*   _src_port;
 	PortImpl*   _dst_port;
 	OutputPort* _src_output_port;
diff --git a/src/libs/engine/events/EnablePatchEvent.cpp b/src/libs/engine/events/EnablePatchEvent.cpp
index e380340f..b1cda98a 100644
--- a/src/libs/engine/events/EnablePatchEvent.cpp
+++ b/src/libs/engine/events/EnablePatchEvent.cpp
@@ -18,7 +18,7 @@
 #include "EnablePatchEvent.hpp"
 #include "Responder.hpp"
 #include "Engine.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "util.hpp"
 #include "ClientBroadcaster.hpp"
 #include "ObjectStore.hpp"
diff --git a/src/libs/engine/events/EnablePatchEvent.hpp b/src/libs/engine/events/EnablePatchEvent.hpp
index fa36aae4..dad1803a 100644
--- a/src/libs/engine/events/EnablePatchEvent.hpp
+++ b/src/libs/engine/events/EnablePatchEvent.hpp
@@ -27,7 +27,7 @@ namespace Raul { template <typename T> class Array; }
 
 namespace Ingen {
 
-class Patch;
+class PatchImpl;
 class NodeImpl;
 class CompiledPatch;
 
@@ -51,7 +51,7 @@ public:
 
 private:
 	string         _patch_path;
-	Patch*         _patch;
+	PatchImpl*     _patch;
 	CompiledPatch* _compiled_patch; // Patch's new process order
 	bool           _enable;
 };
diff --git a/src/libs/engine/events/RenameEvent.cpp b/src/libs/engine/events/RenameEvent.cpp
index 72e27ec9..d0ef532a 100644
--- a/src/libs/engine/events/RenameEvent.cpp
+++ b/src/libs/engine/events/RenameEvent.cpp
@@ -20,7 +20,7 @@
 #include "Engine.hpp"
 #include "NodeImpl.hpp"
 #include "ObjectStore.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "RenameEvent.hpp"
 #include "Responder.hpp"
 #include "AudioDriver.hpp"
@@ -77,10 +77,10 @@ RenameEvent::pre_process()
 		return;
 	}
 
-	Table<Path,GraphObjectImpl*> removed = _engine.object_store()->remove(_store_iterator);
+	Table<Path, SharedPtr<Shared::GraphObject> > removed = _engine.object_store()->remove(_store_iterator);
 	assert(removed.size() > 0);
 	
-	for (Table<Path,GraphObjectImpl*>::iterator i = removed.begin(); i != removed.end(); ++i) {
+	for (Table<Path, SharedPtr<Shared::GraphObject> >::iterator i = removed.begin(); i != removed.end(); ++i) {
 		const Path& child_old_path = i->first;
 		assert(Path::descendant_comparator(_old_path, child_old_path));
 		
@@ -90,7 +90,7 @@ RenameEvent::pre_process()
 		else
 			child_new_path = _new_path.base() + child_old_path.substr(_old_path.length()+1);
 
-		i->second->set_path(child_new_path);
+		PtrCast<GraphObjectImpl>(i->second)->set_path(child_new_path);
 		i->first = child_new_path;
 	}
 
@@ -105,7 +105,7 @@ RenameEvent::execute(ProcessContext& context)
 {
 	QueuedEvent::execute(context);
 	
-	PortImpl* port = dynamic_cast<PortImpl*>(_store_iterator->second);
+	SharedPtr<PortImpl> port = PtrCast<PortImpl>(_store_iterator->second);
 	if (port && port->parent()->parent() == NULL) {
 		DriverPort* driver_port = NULL;
 
diff --git a/src/libs/engine/events/RenameEvent.hpp b/src/libs/engine/events/RenameEvent.hpp
index 1a68173f..fae3a060 100644
--- a/src/libs/engine/events/RenameEvent.hpp
+++ b/src/libs/engine/events/RenameEvent.hpp
@@ -31,7 +31,7 @@ template<typename T> class ListNode;
 namespace Ingen {
 
 class GraphObjectImpl;
-class Patch;
+class PatchImpl;
 class NodeImpl;
 class Plugin;
 class DisconnectNodeEvent;
@@ -58,7 +58,7 @@ private:
 	Path                           _old_path;
 	string                         _name;
 	Path                           _new_path;
-	Patch*                         _parent_patch;
+	PatchImpl*                     _parent_patch;
 	ObjectStore::Objects::iterator _store_iterator;
 	ErrorType                      _error;
 };
diff --git a/src/libs/engine/events/RequestAllObjectsEvent.cpp b/src/libs/engine/events/RequestAllObjectsEvent.cpp
index e4d0f083..7865cd9b 100644
--- a/src/libs/engine/events/RequestAllObjectsEvent.cpp
+++ b/src/libs/engine/events/RequestAllObjectsEvent.cpp
@@ -45,7 +45,7 @@ RequestAllObjectsEvent::post_process()
 		_responder->respond_ok();
 
 		// Everything is a child of the root patch, so this sends it all
-		Patch* root = _engine.object_store()->find_patch("/");
+		PatchImpl* root = _engine.object_store()->find_patch("/");
 		if (root && _responder->client())
 			ObjectSender::send_patch(_responder->client(), root, true);
 
diff --git a/src/libs/engine/events/RequestObjectEvent.cpp b/src/libs/engine/events/RequestObjectEvent.cpp
index 13ad936e..34c04889 100644
--- a/src/libs/engine/events/RequestObjectEvent.cpp
+++ b/src/libs/engine/events/RequestObjectEvent.cpp
@@ -22,7 +22,7 @@
 #include "Engine.hpp"
 #include "ObjectStore.hpp"
 #include "ClientBroadcaster.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "NodeImpl.hpp"
 #include "PortImpl.hpp"
 #include "ObjectSender.hpp"
@@ -65,7 +65,7 @@ RequestObjectEvent::post_process()
 		_responder->respond_error("Unable to find object requested.");
 	
 	} else if (_responder->client()) {	
-		Patch* const patch = dynamic_cast<Patch*>(_object);
+		PatchImpl* const patch = dynamic_cast<PatchImpl*>(_object);
 		if (patch) {
 			_responder->respond_ok();
 			ObjectSender::send_patch(_responder->client(), patch, true);
diff --git a/src/libs/engine/events/SetPolyphonicEvent.cpp b/src/libs/engine/events/SetPolyphonicEvent.cpp
index 51ab2dc8..ebaf9a22 100644
--- a/src/libs/engine/events/SetPolyphonicEvent.cpp
+++ b/src/libs/engine/events/SetPolyphonicEvent.cpp
@@ -19,7 +19,7 @@
 #include "SetPolyphonicEvent.hpp"
 #include "Responder.hpp"
 #include "Engine.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "ClientBroadcaster.hpp"
 #include "util.hpp"
 #include "ObjectStore.hpp"
diff --git a/src/libs/engine/events/SetPolyphonyEvent.cpp b/src/libs/engine/events/SetPolyphonyEvent.cpp
index 56e95486..7efa7386 100644
--- a/src/libs/engine/events/SetPolyphonyEvent.cpp
+++ b/src/libs/engine/events/SetPolyphonyEvent.cpp
@@ -19,7 +19,7 @@
 #include "SetPolyphonyEvent.hpp"
 #include "Responder.hpp"
 #include "Engine.hpp"
-#include "Patch.hpp"
+#include "PatchImpl.hpp"
 #include "ClientBroadcaster.hpp"
 #include "util.hpp"
 #include "ObjectStore.hpp"
@@ -44,7 +44,7 @@ void
 SetPolyphonyEvent::pre_process()
 {
 	_patch = _engine.object_store()->find_patch(_patch_path);
-	 if (_patch && _poly > _patch->internal_poly())
+	 if (_patch && _poly > _patch->internal_polyphony())
 		 _patch->prepare_internal_poly(_poly);
 
 	QueuedEvent::pre_process();
diff --git a/src/libs/engine/events/SetPolyphonyEvent.hpp b/src/libs/engine/events/SetPolyphonyEvent.hpp
index a2ac1862..8aba997a 100644
--- a/src/libs/engine/events/SetPolyphonyEvent.hpp
+++ b/src/libs/engine/events/SetPolyphonyEvent.hpp
@@ -26,7 +26,7 @@ using std::string;
 
 namespace Ingen {
 
-class Patch;
+class PatchImpl;
 
 
 /** Delete all nodes from a patch.
@@ -43,9 +43,10 @@ public:
 	void post_process();
 
 private:
-	string   _patch_path;
-	Patch*   _patch;
-	uint32_t _poly;
+	const string   _patch_path;
+	PatchImpl*     _patch;
+	const uint32_t _poly;
+
 };
 
 
diff --git a/src/libs/gui/PatchCanvas.cpp b/src/libs/gui/PatchCanvas.cpp
index ac86b3fb..7cd31cb3 100644
--- a/src/libs/gui/PatchCanvas.cpp
+++ b/src/libs/gui/PatchCanvas.cpp
@@ -209,9 +209,9 @@ PatchCanvas::build()
 	}
 
 	// Create connections
-	for (list<SharedPtr<ConnectionModel> >::const_iterator i = _patch->connections().begin();
+	for (PatchModel::Connections::const_iterator i = _patch->connections().begin();
 			i != _patch->connections().end(); ++i) {
-		connection(*i);
+		connection(PtrCast<ConnectionModel>(*i));
 	}
 }
 
@@ -306,15 +306,18 @@ PatchCanvas::get_port_view(SharedPtr<PortModel> port)
 void
 PatchCanvas::connection(SharedPtr<ConnectionModel> cm)
 {
+	assert(cm);
+	
 	const SharedPtr<FlowCanvas::Port> src = get_port_view(cm->src_port());
 	const SharedPtr<FlowCanvas::Port> dst = get_port_view(cm->dst_port());
 
-	if (src && dst)
+	if (src && dst) {
 		add_connection(boost::shared_ptr<GUI::Connection>(new GUI::Connection(shared_from_this(),
 				cm, src, dst, src->color() + 0x22222200)));
-	else
+	} else {
 		cerr << "[PatchCanvas] ERROR: Unable to find ports to connect "
 			<< cm->src_port_path() << " -> " << cm->dst_port_path() << endl;
+	}
 }