X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Flibr2c2%2Ftrainrouter.h;h=c7c1be18b9a6f5cd55f00c632f049f253bf4e436;hb=03a22611772265b539f826f1f8bc482e71ca4a99;hp=9efc3a6001cf6bc811d101b8fb8a6b54b5f1e81e;hpb=0aa9976c7ee8752a47decd8e162161b0b824af57;p=r2c2.git diff --git a/source/libr2c2/trainrouter.h b/source/libr2c2/trainrouter.h index 9efc3a6..c7c1be1 100644 --- a/source/libr2c2/trainrouter.h +++ b/source/libr2c2/trainrouter.h @@ -3,6 +3,7 @@ #include #include +#include "trackchain.h" #include "trainai.h" namespace R2C2 { @@ -10,7 +11,8 @@ namespace R2C2 { class Block; class Layout; class Track; -class TrackChain; +class TrainRouteMetric; +class TrainRoutePlanner; class TrainRouter: public TrainAI { @@ -23,48 +25,85 @@ public: void route(const std::string &); }; - sigc::signal signal_route_changed; - sigc::signal signal_arrived; + struct Waypoint + { + const TrackChain *chain; + TrackChain::Direction direction; -private: - struct Wait + Waypoint(const TrackChain &, TrackChain::Direction = TrackChain::UNSPECIFIED); + }; + + struct SequencePoint { Block *block; - Train *train; + Train *preceding_train; + unsigned sequence_in; + unsigned sequence_out; + + SequencePoint(Block &, unsigned); - Wait(); + bool is_cleared() const; }; +private: typedef std::list RouteList; + enum TravelState + { + ON_THE_WAY, + WAITING_FOR_SEQUENCE, + SEQUENCE_CHECK_PENDING, + RESERVED_TO_END, + ADVANCED_TO_END, + ARRIVED + }; + +public: + sigc::signal signal_route_changed; + sigc::signal signal_departed; + sigc::signal signal_arrived; + sigc::signal signal_waypoint_reached; + +private: int priority; RouteList routes; - unsigned arriving; - const TrackChain *destination; - std::vector waypoints; - std::list waits; + RouteList::iterator reserving_route; + TravelState state; + std::vector waypoints; + bool waypoints_changed; + std::vector metrics; + bool metrics_stale; + std::list sequence_points; + unsigned current_sequence; Msp::Time::TimeDelta delay; - - bool update_pending; + Msp::Time::TimeDelta duration; + Msp::RefPtr planner; public: TrainRouter(Train &); + ~TrainRouter(); void set_priority(int); int get_priority() const { return priority; } bool set_route(const Route *); - void add_wait(Block &, Train *); const Route *get_route() const; + unsigned get_current_sequence() const { return current_sequence; } +private: + void use_planned_route(); + void route_changed(); +public: void set_destination(const TrackChain &); - const TrackChain *get_destination() const { return destination; } - bool is_destination(Track &) const; - void add_waypoint(const TrackChain &); + const TrackChain *get_destination() const { return waypoints.empty() ? 0 : waypoints.back().chain; } + void add_waypoint(const TrackChain &, TrackChain::Direction = TrackChain::UNSPECIFIED); unsigned get_n_waypoints() const { return waypoints.size(); } - bool is_waypoint(unsigned, Track &) const; + const Waypoint &get_waypoint(unsigned) const; + const TrainRouteMetric &get_metric(int = -1) const; void set_departure_delay(const Msp::Time::TimeDelta &); const Msp::Time::TimeDelta &get_departure_delay() const { return delay; } + void set_trip_duration(const Msp::Time::TimeDelta &); + const Msp::Time::TimeDelta &get_trip_duration() const { return duration; } virtual void message(const Message &); virtual void tick(const Msp::Time::TimeDelta &); @@ -74,13 +113,15 @@ public: private: void block_reserved(Block &, Train *); void train_advanced(Block &); - const Route *get_route_for_block(const Block &) const; + void train_rear_advanced(Block &); - Route *create_lead_route(Route *, const Route *); - bool advance_route(RouteList::iterator &, const Block &); - bool is_on_route(const Block &); + void create_metrics(); + bool create_lead_route(); + bool advance_to_track(RouteList::iterator &, const TrackIter &); - static void create_plans(Layout &); + static void get_routers(Layout &, std::vector &, TrainRoutePlanner * = 0); + static void start_planning(Layout &); + static void apply_plan(Layout &, TrainRoutePlanner &); }; } // namespace R2C2