]> git.tdb.fi Git - r2c2.git/blobdiff - source/libmarklin/route.cpp
Support more complex article numbers
[r2c2.git] / source / libmarklin / route.cpp
index 13f4e3efff012e57622d2e387ac25e8613ffc6bc..daa044f9b9b4054b774421df3e6ada5168f76c43 100644 (file)
@@ -10,6 +10,7 @@ Distributed under the GPL
 #include "layout.h"
 #include "route.h"
 #include "track.h"
+#include "trackiter.h"
 #include "tracktype.h"
 
 using namespace std;
@@ -19,9 +20,11 @@ namespace {
 
 using namespace Marklin;
 
+typedef std::pair<Track *, unsigned> Key;
+
 struct Node
 {
-       const Track *track;
+       Track *track;
        unsigned ep;
        Node *prev;
        float dist;
@@ -30,11 +33,11 @@ struct Node
                track(0), ep(0), prev(0), dist(0)
        { }
 
-       Node(const Track &t, unsigned e):
+       Node(Track &t, unsigned e):
                track(&t), ep(e), prev(0), dist(0)
        { }
 
-       Node(const Track &t, unsigned e, Node &r, float d):
+       Node(Track &t, unsigned e, Node &r, float d):
                track(&t), ep(e), prev(&r), dist(prev->dist+d)
        { }
 
@@ -44,18 +47,26 @@ struct Node
 
 struct TrackMatch
 {
-       const Track &track;
+       Track &track;
+
+       TrackMatch(Track &t): track(t) { }
+
+       bool operator()(Track &t) const { return &t==&track; }
+};
+
+struct TrackInSet
+{
+       const set<Track *> &tracks;
 
-       TrackMatch(const Track &t): track(t) { }
+       TrackInSet(const set<Track *> &t): tracks(t) { }
 
-       bool operator()(const Track &t) { return &t==&track; }
+       bool operator()(Track &t) const { return tracks.count(&t); }
 };
 
 template<typename Pred>
-list<const Track *> dijkstra(const Track &from, unsigned ep, Pred goal)
+list<Track *> dijkstra(Track &from, unsigned ep, const Pred &goal)
 {
-       // XXX Fails to find some routes - should use track+ep as key
-       map<const Track *, Node> track_nodes;
+       map<Key, Node> track_nodes;
        priority_queue<Node> nodes;
        Node *final = 0;
 
@@ -66,10 +77,11 @@ list<const Track *> dijkstra(const Track &from, unsigned ep, Pred goal)
                Node lowest = nodes.top();
                nodes.pop();
 
-               if(track_nodes.count(lowest.track))
+               Key key(lowest.track, lowest.ep);
+               if(track_nodes.count(key))
                        continue;
 
-               Node &ref = track_nodes[lowest.track] = lowest;
+               Node &ref = track_nodes[key] = lowest;
                if(goal(*lowest.track))
                {
                        final = &ref;
@@ -77,11 +89,15 @@ list<const Track *> dijkstra(const Track &from, unsigned ep, Pred goal)
                }
 
                const TrackType &type = lowest.track->get_type();
-               const vector<Endpoint> &eps = type.get_endpoints();
+               const vector<TrackType::Endpoint> &eps = type.get_endpoints();
                const vector<Track *> &links = lowest.track->get_links();
                for(unsigned i=0; i<eps.size(); ++i)
                {
-                       if(i==lowest.ep || !links[i] || track_nodes.count(links[i]))
+                       if(i==lowest.ep || !links[i])
+                               continue;
+
+                       unsigned link_ep = links[i]->get_endpoint_by_link(*lowest.track);
+                       if(track_nodes.count(Key(links[i], link_ep)))
                                continue;
 
                        unsigned mask = eps[i].paths&eps[lowest.ep].paths;
@@ -94,24 +110,39 @@ list<const Track *> dijkstra(const Track &from, unsigned ep, Pred goal)
                }
        }
 
-       if(!final)
-               throw InvalidParameterValue("Could not find a route");
-
-       list<const Track *> result;
+       list<Track *> result;
        for(Node *node=final; node; node=node->prev)
                result.push_front(node->track);
 
        return result;
 }
 
+template<typename Pred>
+Route *create_route(Track &from, unsigned ep, const Pred &goal)
+{
+       list<Track *> tracks = dijkstra(from, ep, goal);
+
+       if(tracks.empty())
+               return 0;
+
+       Route *route = new Route(from.get_layout());
+       for(list<Track *>::iterator i=tracks.begin(); i!=tracks.end(); ++i)
+               route->add_track(**i);
+
+       route->set_name("Pathfinder");
+       route->set_temporary(true);
+
+       return route;
+}
+
 }
 
 
 namespace Marklin {
 
-Route::Route(Layout &l, const string &n):
+Route::Route(Layout &l):
        layout(l),
-       name(n)
+       temporary(false)
 {
        layout.add_route(*this);
        layout.signal_track_removed.connect(sigc::mem_fun(this, &Route::track_removed));
@@ -122,6 +153,83 @@ Route::~Route()
        layout.remove_route(*this);
 }
 
+void Route::set_name(const string &n)
+{
+       name = n;
+       signal_name_changed.emit(name);
+}
+
+void Route::set_temporary(bool t)
+{
+       temporary = t;
+}
+
+void Route::set_turnout(unsigned addr, unsigned path)
+{
+       if(!addr)
+               throw InvalidParameterValue("Invalid turnout address");
+       map<unsigned, int>::iterator i = turnouts.find(addr);
+       if(i==turnouts.end())
+               throw KeyError("Turnout is not in this route");
+       if(i->second>=0 && path!=static_cast<unsigned>(i->second))
+               throw InvalidState("Setting conflicts with route");
+       i->second = path;
+}
+
+void Route::update_turnouts()
+{
+       set<unsigned> found;
+       for(set<Track *>::const_iterator i=tracks.begin(); i!=tracks.end(); ++i)
+               if(unsigned tid = (*i)->get_turnout_id())
+               {
+                       found.insert(tid);
+
+                       const vector<TrackType::Endpoint> &endpoints = (*i)->get_type().get_endpoints();
+                       const vector<Track *> &links = (*i)->get_links();
+
+                       // Build a combined path mask from linked endpoints
+                       unsigned mask = 15;
+                       for(unsigned j=0; j<endpoints.size(); ++j)
+                       {
+                               if(!tracks.count(links[j]))
+                                       continue;
+
+                               if(unsigned tid2 = links[j]->get_turnout_id())
+                               {
+                                       const TrackType::Endpoint &ep = links[j]->get_type().get_endpoints()[links[j]->get_endpoint_by_link(**i)];
+                                       int p = get_turnout(tid2);
+                                       if(p>=0 && !(ep.paths&(1<<p)))
+                                       {
+                                               // The linked track is a turnout and has a path which is incompatible with this endpoint
+                                               mask &= ~endpoints[j].paths;
+                                               continue;
+                                       }
+                               }
+                               mask &= endpoints[j].paths;
+                       }
+
+                       if(mask && !(mask&(mask-1)))
+                       {
+                               // Exactly one possible choice, set the path accordingly
+                               unsigned path = 0;
+                               for(; (mask && !(mask&1)); mask>>=1, ++path) ;
+                               turnouts[tid] = path;
+                       }
+                       else if(!turnouts.count(tid))
+                               // More than one possible choice, and no existing entry - set as undecided
+                               turnouts[tid] = -1;
+               }
+
+       // Remove any turnouts that do not exist in the route
+       for(map<unsigned, int>::iterator i=turnouts.begin(); i!=turnouts.end();)
+       {
+               if(!found.count(i->first))
+                       turnouts.erase(i++);
+               else
+                       ++i;
+       }
+}
+
 int Route::get_turnout(unsigned id) const
 {
        map<unsigned, int>::const_iterator i = turnouts.find(id);
@@ -130,7 +238,7 @@ int Route::get_turnout(unsigned id) const
        return -1;
 }
 
-void Route::add_track(const Track &trk)
+void Route::add_track(Track &trk)
 {
        if(tracks.count(&trk))
                return;
@@ -150,17 +258,17 @@ void Route::add_track(const Track &trk)
        update_turnouts();
 }
 
-void Route::add_tracks(const set<const Track *> &trks)
+void Route::add_tracks(const set<Track *> &trks)
 {
-       set<const Track *> pending;
-       for(set<const Track *>::const_iterator i=trks.begin(); i!=trks.end(); ++i)
+       set<Track *> pending;
+       for(set<Track *>::const_iterator i=trks.begin(); i!=trks.end(); ++i)
                if(!tracks.count(*i))
                        pending.insert(*i);
 
        while(!pending.empty())
        {
                bool found = false;
-               for(set<const Track *>::const_iterator i=pending.begin(); i!=pending.end(); ++i)
+               for(set<Track *>::const_iterator i=pending.begin(); i!=pending.end(); ++i)
                        if(tracks.empty() || check_validity(**i)==7)
                        {
                                tracks.insert(*i);
@@ -176,77 +284,56 @@ void Route::add_tracks(const set<const Track *> &trks)
        update_turnouts();
 }
 
-void Route::save(list<DataFile::Statement> &st) const
+void Route::add_track_chain(Track &start, unsigned ep, const TurnoutMap &trnts)
 {
-       for(map<unsigned, int>::const_iterator i=turnouts.begin(); i!=turnouts.end(); ++i)
-               st.push_back((DataFile::Statement("turnout"), i->first, i->second));
-}
+       TrackIter iter(&start, ep);
+       while(iter)
+       {
+               if(iter->get_type().is_dead_end())
+                       break;
 
-void Route::update_turnouts()
-{
-       set<unsigned> found;
-       for(set<const Track *>::const_iterator i=tracks.begin(); i!=tracks.end(); ++i)
-               if(unsigned tid=(*i)->get_turnout_id())
+               if(has_track(*iter))
+                       break;
+
+               int path = 0;
+               if(iter->get_turnout_id())
                {
-                       found.insert(tid);
+                       TurnoutMap::const_iterator i = trnts.find(iter->get_turnout_id());
+                       if(i==trnts.end())
+                               break;
 
-                       const vector<Endpoint> &endpoints = (*i)->get_type().get_endpoints();
-                       const vector<Track *> &links = (*i)->get_links();
+                       path = i->second;
+               }
 
-                       // Build a combined path mask from linked endpoints
-                       unsigned mask = 15;
-                       for(unsigned j=0; j<endpoints.size(); ++j)
-                       {
-                               if(!tracks.count(links[j]))
-                                       continue;
+               add_track(*iter);
 
-                               if(unsigned tid2=links[j]->get_turnout_id())
-                               {
-                                       const Endpoint &ep = links[j]->get_type().get_endpoints()[links[j]->get_endpoint_by_link(**i)];
-                                       int p = get_turnout(tid2);
-                                       if(p>=0 && !(ep.paths&(1<<p)))
-                                       {
-                                               // The linked track is a turnout and has a path which is incompatible with this endpoint
-                                               mask &= ~endpoints[j].paths;
-                                               continue;
-                                       }
-                               }
-                               mask &= endpoints[j].paths;
-                       }
+               iter = iter.next(path);
+       }
+}
 
-                       if(mask && !(mask&(mask-1)))
-                       {
-                               // Exactly one possible choice, set the path accordingly
-                               unsigned path = 0;
-                               for(; (mask && !(mask&1)); mask>>=1, ++path) ;
-                               turnouts[tid] = path;
-                       }
-                       else if(!turnouts.count(tid))
-                               // More than one possible choice, and no existing entry - set as undecided
-                               turnouts[tid] = -1;
-               }
+bool Route::has_track(Track &t) const
+{
+       return tracks.count(&t);
+}
 
-       // Remove any turnouts that do not exist in the route
-       for(map<unsigned, int>::iterator i=turnouts.begin(); i!=turnouts.end();)
-       {
-               if(!found.count(i->first))
-                       turnouts.erase(i++);
-               else
-                       ++i;
-       }
+void Route::save(list<DataFile::Statement> &st) const
+{
+       st.push_back((DataFile::Statement("name"), name));
+       for(map<unsigned, int>::const_iterator i=turnouts.begin(); i!=turnouts.end(); ++i)
+               st.push_back((DataFile::Statement("turnout"), i->first, i->second));
 }
 
-unsigned Route::check_validity(const Track &trk) const
+unsigned Route::check_validity(Track &trk) const
 {
        unsigned result = 4;
-       for(set<const Track *>::const_iterator i=tracks.begin(); i!=tracks.end(); ++i)
+       for(set<Track *>::const_iterator i=tracks.begin(); i!=tracks.end(); ++i)
        {
                int epi=(*i)->get_endpoint_by_link(trk);
                if(epi>=0)
                {
                        // Linked to an existing track - good
                        result |= 1;
-                       const vector<Endpoint> &endpoints = (*i)->get_type().get_endpoints();
+                       const vector<TrackType::Endpoint> &endpoints = (*i)->get_type().get_endpoints();
                        if(unsigned tid=(*i)->get_turnout_id())
                        {
                                int r = get_turnout(tid);
@@ -293,29 +380,62 @@ void Route::track_removed(Track &t)
        tracks.erase(&t);
 }
 
-Route *Route::find(const Track &from, unsigned ep, const Track &to)
+Route *Route::find(Track &from, unsigned ep, Track &to)
 {
-       TrackMatch goal(to);
-       list<const Track *> tracks = dijkstra(from, ep, goal);
+       return create_route(from, ep, TrackMatch(to));
+}
 
-       static unsigned n = 0;
-       Route *route = new Route(from.get_layout(), format("Route::find %d", ++n));
-       for(list<const Track *>::iterator i=tracks.begin(); i!=tracks.end(); ++i)
-               route->add_track(**i);
+Route *Route::find(Track &from, unsigned ep, const Route &to)
+{
+       return create_route(from, ep, TrackInSet(to.get_tracks()));
+}
 
-       return route;
+Route *Route::find(Track &from, unsigned ep, const set<Track *> &to)
+{
+       return create_route(from, ep, TrackInSet(to));
 }
 
 
 Route::Loader::Loader(Route &r):
        DataFile::BasicLoader<Route>(r)
 {
+       add("name",    &Route::name);
        add("turnout", &Loader::turnout);
 }
 
+void Route::Loader::finish()
+{
+       const set<Track *> &ltracks = obj.layout.get_tracks();
+       for(set<Track *>::const_iterator i=ltracks.begin(); i!=ltracks.end(); ++i)
+       {
+               unsigned tid = (*i)->get_turnout_id();
+               if(!tid)
+                       continue;
+
+               TurnoutMap::iterator j = turnouts.find(tid);
+               if(j==turnouts.end())
+                       continue;
+
+               unsigned path_mask = 1<<j->second;
+               const vector<TrackType::Endpoint> &eps = (*i)->get_type().get_endpoints();
+               for(unsigned k=0; k<eps.size(); ++k)
+                       if(eps[k].paths&path_mask)
+                       {
+                               Track *link = (*i)->get_link(k);
+                               if(!obj.tracks.count(link))
+                                       obj.add_track_chain(*link, link->get_endpoint_by_link(**i), turnouts);
+                               if(!obj.tracks.count(*i))
+                                       obj.add_track_chain(**i, k, turnouts);
+                               break;
+                       }
+
+               break;
+       }
+}
+
 void Route::Loader::turnout(unsigned id, unsigned path)
 {
-       obj.turnouts[id] = path;
+       turnouts[id] = path;
 }
 
 } // namespace Marklin