X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Flibr2c2%2Ftrainrouter.h;h=c7c1be18b9a6f5cd55f00c632f049f253bf4e436;hb=03a22611772265b539f826f1f8bc482e71ca4a99;hp=c1b6977f3734d45b19f615146c899d0ef22dedc0;hpb=b68d1d4f2be93a405170e7caca05760ca473dcc6;p=r2c2.git diff --git a/source/libr2c2/trainrouter.h b/source/libr2c2/trainrouter.h index c1b6977..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,8 +11,8 @@ namespace R2C2 { class Block; class Layout; class Track; -class TrackChain; class TrainRouteMetric; +class TrainRoutePlanner; class TrainRouter: public TrainAI { @@ -24,31 +25,59 @@ public: void route(const std::string &); }; - sigc::signal signal_route_changed; - sigc::signal signal_arrived; - sigc::signal signal_waypoint_reached; + 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; + RouteList::iterator reserving_route; + TravelState state; + std::vector waypoints; + bool waypoints_changed; std::vector metrics; - std::list waits; + 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 &); @@ -58,19 +87,23 @@ public: int get_priority() const { return priority; } bool set_route(const Route *); - bool add_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 &); @@ -80,14 +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 &); void create_metrics(); - Route *create_lead_route(Route *, const Route *); - bool advance_route(RouteList::iterator &, const Block &); - bool is_on_route(const Block &); + 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