]> git.tdb.fi Git - r2c2.git/blob - source/libr2c2/trainrouter.h
Replace waits with a more robust sequencing system
[r2c2.git] / source / libr2c2 / trainrouter.h
1 #ifndef LIBR2C2_TRAINROUTER_H_
2 #define LIBR2C2_TRAINROUTER_H_
3
4 #include <list>
5 #include <msp/datafile/objectloader.h>
6 #include "trainai.h"
7
8 namespace R2C2 {
9
10 class Block;
11 class Layout;
12 class Track;
13 class TrackChain;
14 class TrainRouteMetric;
15
16 class TrainRouter: public TrainAI
17 {
18 public:
19         class Loader: public Msp::DataFile::ObjectLoader<TrainRouter>
20         {
21         public:
22                 Loader(TrainRouter &);
23         private:
24                 void route(const std::string &);
25         };
26
27         sigc::signal<void, const Route *> signal_route_changed;
28         sigc::signal<void, const TrackChain *> signal_arrived;
29         sigc::signal<void, const TrackChain *> signal_waypoint_reached;
30
31 private:
32         struct SequencePoint
33         {
34                 Block *block;
35                 Train *preceding_train;
36                 unsigned sequence_in;
37                 unsigned sequence_out;
38
39                 SequencePoint(Block &, unsigned);
40         };
41
42         typedef std::list<const Route *> RouteList;
43
44         int priority;
45         RouteList routes;
46         unsigned arriving;
47         const TrackChain *destination;
48         std::vector<const TrackChain *> waypoints;
49         std::vector<TrainRouteMetric *> metrics;
50         std::list<SequencePoint> sequence_points;
51         std::list<SequencePoint *> pending_sequence_checks;
52         unsigned current_sequence;
53         Msp::Time::TimeDelta delay;
54
55         bool update_pending;
56
57 public:
58         TrainRouter(Train &);
59         ~TrainRouter();
60
61         void set_priority(int);
62         int get_priority() const { return priority; }
63
64         bool set_route(const Route *);
65         bool add_route(const Route &);
66         const Route *get_route() const;
67         void add_sequence_point(Block &, unsigned);
68         void add_sequence_point(Block &, Train &, unsigned, unsigned);
69         unsigned get_current_sequence() const { return current_sequence; }
70
71         void set_destination(const TrackChain &);
72         const TrackChain *get_destination() const { return destination; }
73         bool is_destination(Track &) const;
74         void add_waypoint(const TrackChain &);
75         unsigned get_n_waypoints() const { return waypoints.size(); }
76         bool is_waypoint(unsigned, Track &) const;
77         const TrainRouteMetric &get_metric(int = -1) const;
78         void set_departure_delay(const Msp::Time::TimeDelta &);
79         const Msp::Time::TimeDelta &get_departure_delay() const { return delay; }
80
81         virtual void message(const Message &);
82         virtual void tick(const Msp::Time::TimeDelta &);
83
84         void save(std::list<Msp::DataFile::Statement> &) const;
85
86 private:
87         void block_reserved(Block &, Train *);
88         void train_advanced(Block &);
89         const Route *get_route_for_block(const Block &) const;
90
91         void create_metrics();
92         Route *create_lead_route(Route *, const Route *);
93         bool advance_route(RouteList::iterator &, const Block &);
94         bool is_on_route(const Block &);
95
96         static void create_plans(Layout &);
97 };
98
99 } // namespace R2C2
100
101 #endif