2 #include <msp/core/raii.h>
3 #include <msp/strings/format.h>
4 #include <msp/time/units.h>
8 #include "trackcircuit.h"
10 #include "tracktype.h"
17 Block::Block(Layout &l, Track &start):
20 sensor_addr(start.get_sensor_address()),
21 turnout_addr(start.get_turnout_address()),
26 emitting_reserve(false)
30 if(start.get_type().is_turnout())
32 unsigned nls = start.get_n_link_slots();
33 for(unsigned i=0; i<nls; ++i)
34 endpoints.push_back(Endpoint(&start, i));
38 unsigned nls = start.get_n_link_slots();
39 for(unsigned i=0; i<nls; ++i)
41 TrackIter iter = TrackIter(&start, i).flip();
42 for(; (iter && check_validity(*iter)==VALID); iter=iter.next())
44 if((iter = iter.flip()))
45 endpoints.push_back(Endpoint(iter.track(), iter.entry()));
51 const set<Block *> &blocks = layout.get_all<Block>();
52 for(set<Block *>::const_iterator i=blocks.begin(); (!conflict && i!=blocks.end()); ++i)
53 conflict = (id==(*i)->get_id());
55 if(!conflict && sensor_addr)
56 sensor = new TrackCircuit(layout, *this);
63 set<Track *> trks = tracks;
65 for(set<Track *>::iterator i=trks.begin(); i!=trks.end(); ++i)
68 for(vector<Endpoint>::iterator i=endpoints.begin(); i!=endpoints.end(); ++i)
69 if(Block *blk = i->link)
72 blk->break_link(*this);
80 void Block::set_name(const string &)
82 throw logic_error("Block names can't be set");
85 void Block::on_track_added(Track &track)
87 track.set_block(this);
90 TrackChain::Validity Block::check_validity(Track &track) const
92 if(track.get_sensor_address()!=sensor_addr || track.get_turnout_address()!=turnout_addr)
95 return TrackChain::check_validity(track);
98 const Block::Endpoint &Block::get_endpoint(unsigned i) const
100 if(i>=endpoints.size())
101 throw out_of_range("Block::get_endpoint");
106 int Block::get_endpoint_by_link(Block &other) const
108 for(unsigned i=0; i<endpoints.size(); ++i)
109 if(endpoints[i].link==&other)
115 float Block::get_path_length(unsigned entry, const Route *route) const
117 if(entry>=endpoints.size())
118 throw out_of_range("Block::get_path_length");
120 TrackIter t_iter = endpoints[entry].track_iter();
123 while(t_iter && has_track(*t_iter))
125 unsigned path = (route ? route->get_path(*t_iter) : t_iter->get_active_path());
126 result += t_iter->get_type().get_path_length(path);
128 t_iter = t_iter.next(path);
134 void Block::check_link(Block &other)
136 for(vector<Endpoint>::iterator i=endpoints.begin(); i!=endpoints.end(); ++i)
141 for(vector<Endpoint>::iterator j=other.endpoints.begin(); j!=other.endpoints.end(); ++j)
142 if(j->track==i->track->get_link(i->track_ep) && j->track->get_link(j->track_ep)==i->track && !j->link)
148 other.determine_id();
153 void Block::break_link(Block &other)
155 for(vector<Endpoint>::iterator i=endpoints.begin(); i!=endpoints.end(); ++i)
159 other.break_link(*this);
164 Block *Block::get_link(unsigned epi) const
166 if(epi>=endpoints.size())
167 throw out_of_range("Block::get_link");
168 return endpoints[epi].link;
171 bool Block::reserve(Train *t)
173 if(!t || !(emitting_reserve ? pending_train : train))
176 if(!emitting_reserve)
178 while(pending_train!=train)
180 train = pending_train;
181 SetFlag setf(emitting_reserve);
182 signal_reserved.emit(train);
192 void Block::determine_id()
197 id = 0x1000|sensor_addr;
198 n = format("Sensor %d", sensor_addr);
200 else if(turnout_addr)
202 id = 0x2000|turnout_addr;
203 n = format("Turnout %d", turnout_addr);
205 else if(endpoints.size()==2)
207 unsigned id1 = endpoints[0].link ? endpoints[0].link->get_id() : 1;
208 unsigned id2 = endpoints[1].link ? endpoints[1].link->get_id() : 1;
213 else if(endpoints.size()==1)
215 unsigned id1 = endpoints[0].link ? endpoints[0].link->get_id() : 1;
220 n = format("Block %x", id);
223 signal_name_changed.emit(name);
226 DataFile::Statement Block::save_reference() const
228 return (DataFile::Statement("block"), id);
232 Block::Endpoint::Endpoint(Track *t, unsigned e):
238 TrackIter Block::Endpoint::track_iter() const
240 return TrackIter(track, track_ep);