X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Flibmarklin%2Flayout.cpp;h=e67fbc26ebc0443440900293bd72555184e439f0;hb=d3907f4b0e60f246a53201b93b06e86062f1b48a;hp=7855dca7d7115333dc1b060ff4f3d57b68950bbd;hpb=e5cd9e4fbc577036a0385c985b6b65df8218d0a2;p=r2c2.git

diff --git a/source/libmarklin/layout.cpp b/source/libmarklin/layout.cpp
index 7855dca..e67fbc2 100644
--- a/source/libmarklin/layout.cpp
+++ b/source/libmarklin/layout.cpp
@@ -28,7 +28,10 @@ namespace Marklin {
 Layout::Layout(Catalogue &c, Driver *d):
 	catalogue(c),
 	driver(d)
-{ }
+{
+	if(driver)
+		driver->signal_sensor.connect(sigc::mem_fun(this, &Layout::sensor_event));
+}
 
 Layout::~Layout()
 {
@@ -209,6 +212,13 @@ void Layout::tick()
 		i->second->tick(t, dt);
 }
 
+void Layout::emergency(const string &msg)
+{
+	if(driver)
+		driver->halt(true);
+	signal_emergency.emit(msg);
+}
+
 void Layout::save(const string &fn)
 {
 	IO::BufferedFile out(fn, IO::M_WRITE);
@@ -227,6 +237,9 @@ void Layout::save(const string &fn)
 
 	for(map<string, Route *>::iterator i=routes.begin(); i!=routes.end(); ++i)
 	{
+		if(i->second->is_temporary())
+			continue;
+
 		DataFile::Statement st("route");
 		st.append(i->first);
 		i->second->save(st.sub);
@@ -277,6 +290,9 @@ void Layout::check_routes()
 {
 	for(map<string, Route *>::iterator i=routes.begin(); i!=routes.end(); ++i)
 	{
+		if(i->second->is_temporary())
+			continue;
+
 		/* We must copy the turnout map, since adding tracks to the route will
 		(temporarily) mess it up */
 		const map<unsigned, int> turnouts = i->second->get_turnouts();
@@ -312,6 +328,8 @@ void Layout::check_routes()
 		while(1)
 		{
 			// Traverse the track and get the next one
+			if(track->get_type().get_endpoints().size()<2)
+				break;
 			unsigned out_ep = track->traverse(ep, trk_path);
 			Track *next = track->get_links()[out_ep];
 			if(!next || next == start)
@@ -344,6 +362,20 @@ void Layout::check_routes()
 	}
 }
 
+void Layout::sensor_event(unsigned addr, bool state)
+{
+	if(state)
+	{
+		for(set<Block *>::iterator i=blocks.begin(); i!=blocks.end(); ++i)
+			if((*i)->get_sensor_id()==addr)
+			{
+				if(!(*i)->get_train())
+					emergency("Unreserved sensor triggered");
+				break;
+			}
+	}
+}
+
 
 Layout::Loader::Loader(Layout &l):
 	DataFile::BasicLoader<Layout>(l),