1 #include <msp/strings/format.h>
7 #include "trainrouter.h"
15 Timetable::Timetable(Train &t):
17 current_row(rows.end()),
20 if(!train.get_ai_of_type<AIControl>())
22 if(!train.get_ai_of_type<TrainRouter>())
23 new TrainRouter(train);
25 train.signal_ai_event.connect(sigc::mem_fun(this, &Timetable::event));
28 void Timetable::append_row(const Row &r)
30 insert_row(rows.size(), r);
33 void Timetable::insert_row(unsigned i, const Row &r)
36 throw out_of_range("Timetable::insert_row");
38 list<Row>::iterator j = rows.begin();
40 j = rows.insert(j, r);
41 signal_row_added.emit(i, *j);
46 void Timetable::modify_row(unsigned i, const Row &r)
49 throw out_of_range("Timetable::remove_row");
51 list<Row>::iterator j = rows.begin();
54 signal_row_modified.emit(i, r);
59 void Timetable::remove_row(unsigned i)
62 throw out_of_range("Timetable::remove_row");
64 list<Row>::iterator j = rows.begin();
72 signal_row_removed.emit(i);
75 const Timetable::Row &Timetable::get_row(unsigned i) const
78 throw out_of_range("Timetable::get_row");
80 list<Row>::const_iterator j = rows.begin();
85 void Timetable::tick(const Time::TimeDelta &dt)
87 if(update_pending && !train.get_block_allocator().is_active())
90 if(current_row->type==DEPART)
92 const Clock &clock = train.get_layout().get_clock();
94 Time::TimeDelta t = clock.get_current_time();
95 if(t<current_row->time)
98 Time::TimeDelta b = t-dt*clock.get_rate();
99 if(b<current_row->time)
101 train.ai_message(Message("set-target-speed", train.get_maximum_speed()));
107 void Timetable::save(list<DataFile::Statement> &st) const
109 for(list<Row>::const_iterator i=rows.begin(); i!=rows.end(); ++i)
111 DataFile::Statement ss("row");
117 void Timetable::check_update(list<Row>::const_iterator i)
119 for(list<Row>::const_iterator j=current_row; (j!=rows.end() && j!=i); ++j)
122 update_pending = true;
125 void Timetable::update_route()
127 update_pending = false;
131 list<Row>::iterator depart = rows.end();
132 for(list<Row>::iterator i=current_row;; )
142 else if(depart!=rows.end() && i->type==ARRIVE)
148 current_row = rows.end();
153 train.ai_message(Message("clear-route"));
155 current_row = depart;
156 for(list<Row>::const_iterator i=depart; i!=rows.end(); ++i)
160 train.ai_message(Message("set-destination", i->target));
163 else if(i->type==DEPART)
165 const Clock &clock = train.get_layout().get_clock();
166 Time::TimeDelta dt = i->time-clock.get_current_time();
169 dt /= clock.get_rate();
170 train.ai_message(Message("set-departure-delay", dt));
172 else if(i->type==THROUGH)
173 train.ai_message(Message("add-waypoint", i->target));
177 void Timetable::event(TrainAI &, const Message &msg)
179 if(msg.type=="arrived")
181 if(current_row->type==ARRIVE)
183 update_pending = true;
185 else if(msg.type=="waypoint-reached")
187 const TrackChain *wp = msg.value.value<const TrackChain *>();
188 if(current_row->type==THROUGH && current_row->target==wp)
196 void Timetable::record_time()
198 current_row->time = train.get_layout().get_clock().get_current_time();
199 unsigned i = distance(rows.begin(), current_row);
200 signal_row_modified.emit(i, *current_row);
204 Timetable::Row::Row():
209 void Timetable::Row::save(list<DataFile::Statement> &st) const
211 st.push_back((DataFile::Statement("type"), type));
212 st.push_back((DataFile::Statement("time"), time.raw()));
213 st.push_back(target->save_reference());
217 Timetable::Loader::Loader(Timetable &t, Layout &l):
218 DataFile::ObjectLoader<Timetable>(t),
221 add("row", &Loader::row);
224 void Timetable::Loader::row()
228 obj.rows.push_back(r);
229 obj.update_pending = true;
233 Timetable::Row::Loader::Loader(Row &r, Layout &l):
234 DataFile::ObjectLoader<Timetable::Row>(r),
237 add("block", &Loader::block);
238 add("time", &Loader::time);
239 add("type", &Row::type);
240 add("zone", &Loader::zone);
243 void Timetable::Row::Loader::block(unsigned id)
245 obj.target = &layout.get_block(id);
248 void Timetable::Row::Loader::time(Time::RawTime t)
250 obj.time = Time::TimeDelta(t);
253 void Timetable::Row::Loader::zone(const string &name, unsigned number)
255 obj.target = &layout.get_zone(name, number);
259 void operator<<(LexicalConverter &conv, Timetable::RowType rt)
263 case Timetable::ARRIVE: conv.result("ARRIVE"); return;
264 case Timetable::DEPART: conv.result("DEPART"); return;
265 case Timetable::THROUGH: conv.result("THROUGH"); return;
266 default: throw lexical_error(format("conversion of RowType(%d) to string", rt));
270 void operator>>(const LexicalConverter &conv, Timetable::RowType &rt)
272 if(conv.get()=="ARRIVE")
273 rt = Timetable::ARRIVE;
274 else if(conv.get()=="DEPART")
275 rt = Timetable::DEPART;
276 else if(conv.get()=="THROUGH")
277 rt = Timetable::THROUGH;
279 throw lexical_error(format("conversion of '%s' to RowType", conv.get()));