+ }
+ }
+
+ rsv_blocks.push_back(BlockRef(link, entry));
+ last = &rsv_blocks.back();
+ if(last->block->get_sensor_id())
+ {
+ ++nsens;
+ got_more = true;
+ }
+ }
+
+ // Unreserve blocks that were not good
+ while(!rsv_blocks.empty() && last!=good)
+ {
+ last->block->reserve(0);
+ rsv_blocks.erase(--rsv_blocks.end());
+ if(!rsv_blocks.empty())
+ last = &rsv_blocks.back();
+ }
+
+ if(got_more)
+ update_speed();
+
+ return nsens;
+}
+
+void Train::update_speed()
+{
+ if(!target_speed)
+ {
+ loco.set_speed(0);
+ try_reserve = Time::TimeStamp();
+ set_status("Stopped");
+ }
+ else
+ {
+ unsigned nsens = 0;
+ for(list<BlockRef>::const_iterator i=rsv_blocks.begin(); i!=rsv_blocks.end(); ++i)
+ if(i->block->get_sensor_id())
+ ++nsens;
+
+ unsigned slow_speed = find_speed(0.1); // 31.3 km/h
+ if(nsens==0)
+ {
+ loco.set_speed(0);
+ pure_speed = false;
+ try_reserve = Time::now()+2*Time::sec;
+ set_status("Blocked");
+ }
+ else if(nsens==1 && target_speed>slow_speed)
+ {
+ loco.set_speed(slow_speed);
+ pure_speed = false;
+ try_reserve = Time::now()+2*Time::sec;
+ set_status("Slow");