-/* $Id$
-
-This file is part of R²C²
-Copyright © 2006-2010 Mikkosoft Productions, Mikko Rasa
-Distributed under the GPL
-*/
-
#include <algorithm>
+#include <msp/time/units.h>
#include "block.h"
+#include "driver.h"
#include "layout.h"
#include "route.h"
#include "trackiter.h"
id(0),
sensor_id(start.get_sensor_id()),
turnout_id(start.get_turnout_id()),
+ state(INACTIVE),
train(0)
{
tracks.insert(&start);
find_paths(TrackIter(endpoints[i].track, endpoints[i].track_ep), path);
}
+ if(sensor_id && layout.has_driver())
+ layout.get_driver().signal_sensor.connect(sigc::mem_fun(this, &Block::sensor_event));
+
layout.add_block(*this);
}
const Block::Endpoint &Block::get_endpoint(unsigned i) const
{
if(i>=endpoints.size())
- throw InvalidParameterValue("Endpoint index out of range");
+ throw out_of_range("Block::get_endpoint");
return endpoints[i];
}
float Block::get_path_length(unsigned entry, const Route *route) const
{
if(entry>=endpoints.size())
- throw InvalidParameterValue("Endpoint index out of range");
+ throw out_of_range("Block::get_path_length");
TrackIter t_iter(endpoints[entry].track, endpoints[entry].track_ep);
Block *Block::get_link(unsigned epi) const
{
if(epi>=endpoints.size())
- throw InvalidParameterValue("Endpoint index out of range");
+ throw out_of_range("Block::get_link");
return endpoints[epi].link;
}
if(!t || !train)
{
train = t;
- layout.signal_block_reserved.emit(*this, train);
+ signal_reserved.emit(train);
return true;
}
else
return false;
}
+void Block::tick(const Time::TimeDelta &dt)
+{
+ if(state_confirm_timeout)
+ {
+ state_confirm_timeout -= dt;
+ if(state_confirm_timeout<=Time::zero)
+ {
+ if(state==MAYBE_INACTIVE)
+ state = INACTIVE;
+ else if(state==MAYBE_ACTIVE)
+ state = ACTIVE;
+ state_confirm_timeout = Time::zero;
+ signal_state_changed.emit(state);
+ }
+ }
+}
+
void Block::find_paths(TrackIter track, unsigned path)
{
unsigned mask = track.endpoint().paths;
}
}
+void Block::sensor_event(unsigned addr, bool s)
+{
+ if(addr==sensor_id)
+ {
+ if(s && state<MAYBE_ACTIVE)
+ {
+ state = MAYBE_ACTIVE;
+ state_confirm_timeout = 300*Time::msec;
+ signal_state_changed.emit(state);
+ }
+ else if(!s && state>MAYBE_INACTIVE)
+ {
+ state = MAYBE_INACTIVE;
+ state_confirm_timeout = 700*Time::msec;
+ signal_state_changed.emit(state);
+ }
+ }
+}
+
Block::Endpoint::Endpoint(Track *t, unsigned e):
track(t),