X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Flibr2c2%2Ftrainrouter.cpp;h=4b7e1bc9ca54395a3a9221c71230e93eb9832dec;hb=0ac334781fcb5029e4ea9236a8e93f43169eb7f2;hp=2fac984f03eba6ba23ee1c1ffad0c735d755aaf1;hpb=3de7ae761b9a1fd1c1cd40457cc7067f4cf57c36;p=r2c2.git

diff --git a/source/libr2c2/trainrouter.cpp b/source/libr2c2/trainrouter.cpp
index 2fac984..4b7e1bc 100644
--- a/source/libr2c2/trainrouter.cpp
+++ b/source/libr2c2/trainrouter.cpp
@@ -18,7 +18,9 @@ TrainRouter::TrainRouter(Train &t):
 	arriving(0),
 	destination(0),
 	destination_changed(false),
-	metrics_stale(false)
+	metrics_stale(false),
+	current_sequence(0),
+	sequence_check_pending(false)
 {
 	train.get_layout().signal_block_reserved.connect(sigc::mem_fun(this, &TrainRouter::block_reserved));
 	train.signal_advanced.connect(sigc::mem_fun(this, &TrainRouter::train_advanced));
@@ -65,8 +67,8 @@ bool TrainRouter::set_route(const Route *r)
 	destination = 0;
 	waypoints.clear();
 	sequence_points.clear();
-	pending_sequence_checks.clear();
 	current_sequence = 0;
+	sequence_check_pending = false;
 
 	route_changed();
 
@@ -195,8 +197,8 @@ void TrainRouter::tick(const Time::TimeDelta &dt)
 				routes.push_back(create_lead_route(0, planned_routes.front()));
 				routes.insert(routes.end(), planned_routes.begin(), planned_routes.end());
 				sequence_points = planner->get_sequence_for(train);
-				pending_sequence_checks.clear();
 				current_sequence = 0;
+				sequence_check_pending = false;
 
 				route_changed();
 			}
@@ -204,14 +206,12 @@ void TrainRouter::tick(const Time::TimeDelta &dt)
 		}
 	}
 
-	for(list<SequencePoint *>::iterator i=pending_sequence_checks.begin(); i!=pending_sequence_checks.end(); ++i)
-		if((*i)->preceding_train->get_ai_of_type<TrainRouter>()->get_current_sequence()>=(*i)->sequence_in)
-		{
-			(*i)->preceding_train = 0;
-			if(*i==&sequence_points.front())
-				train.stop_at(0);
-		}
-	pending_sequence_checks.clear();
+	if(sequence_check_pending)
+	{
+		if(sequence_points.front().is_cleared())
+			train.stop_at(0);
+		sequence_check_pending = false;
+	}
 
 	if(arriving==1 && !train.get_speed())
 	{
@@ -243,21 +243,14 @@ void TrainRouter::block_reserved(Block &block, Train *t)
 		if(!t)
 			return;
 
-		TrainRouter *other_router = 0;
-		for(list<SequencePoint>::iterator i=sequence_points.begin(); i!=sequence_points.end(); ++i)
-			if(i->block==&block && i->preceding_train==t)
-			{
-				if(!other_router)
-					other_router = t->get_ai_of_type<TrainRouter>();
-				if(other_router->get_current_sequence()>=i->sequence_in)
-				{
-					i->preceding_train = 0;
-					if(i==sequence_points.begin())
-						train.stop_at(0);
-				}
-				else
-					pending_sequence_checks.push_back(&*i);
-			}
+		SequencePoint &sp = sequence_points.front();
+		if(sp.preceding_train==t && sp.block==&block)
+		{
+			if(sp.is_cleared())
+				train.stop_at(0);
+			else
+				sequence_check_pending = true;
+		}
 
 		return;
 	}
@@ -298,7 +291,7 @@ void TrainRouter::block_reserved(Block &block, Train *t)
 		if(!sequence_points.empty())
 		{
 			SequencePoint &sp = sequence_points.front();
-			if(sp.preceding_train && sp.block==b_iter_next.block())
+			if(sp.block==b_iter_next.block() && !sp.is_cleared())
 				train.stop_at(&block);
 		}
 	}
@@ -462,6 +455,15 @@ TrainRouter::SequencePoint::SequencePoint(Block &b, unsigned o):
 	sequence_out(o)
 { }
 
+bool TrainRouter::SequencePoint::is_cleared() const
+{
+	if(!preceding_train)
+		return true;
+
+	TrainRouter *router = preceding_train->get_ai_of_type<TrainRouter>();
+	return router->get_current_sequence()>=sequence_in;
+}
+
 
 TrainRouter::Loader::Loader(TrainRouter &r):
 	DataFile::ObjectLoader<TrainRouter>(r)