X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Flibmarklin%2Froute.cpp;h=cdbcf1dc4c8cc778f4183277dae9c6b65616f572;hb=f409cd39a687900724d987c9db629cbff0dd49be;hp=7db3f324b61e9ce5d753786aac251982cff6ec90;hpb=651698847d5293cfb15b6fb23a394701388c0151;p=r2c2.git diff --git a/source/libmarklin/route.cpp b/source/libmarklin/route.cpp index 7db3f32..cdbcf1d 100644 --- a/source/libmarklin/route.cpp +++ b/source/libmarklin/route.cpp @@ -5,6 +5,8 @@ Copyright © 2007-2010 Mikkosoft Productions, Mikko Rasa Distributed under the GPL */ +#include +#include #include "layout.h" #include "route.h" #include "track.h" @@ -13,11 +15,135 @@ Distributed under the GPL using namespace std; using namespace Msp; +namespace { + +using namespace Marklin; + +typedef std::pair Key; + +struct Node +{ + const Track *track; + unsigned ep; + Node *prev; + float dist; + + Node(): + track(0), ep(0), prev(0), dist(0) + { } + + Node(const Track &t, unsigned e): + track(&t), ep(e), prev(0), dist(0) + { } + + Node(const Track &t, unsigned e, Node &r, float d): + track(&t), ep(e), prev(&r), dist(prev->dist+d) + { } + + bool operator<(const Node &other) const + { return dist>other.dist; } +}; + +struct TrackMatch +{ + const Track &track; + + TrackMatch(const Track &t): track(t) { } + + bool operator()(const Track &t) const { return &t==&track; } +}; + +struct TrackInRoute +{ + const Route &route; + + TrackInRoute(const Route &r): route(r) { } + + bool operator()(const Track &t) const { return route.get_tracks().count(&t); } +}; + +template +list dijkstra(const Track &from, unsigned ep, const Pred &goal) +{ + map track_nodes; + priority_queue nodes; + Node *final = 0; + + nodes.push(Node(from, ep)); + + while(!nodes.empty()) + { + Node lowest = nodes.top(); + nodes.pop(); + + Key key(lowest.track, lowest.ep); + if(track_nodes.count(key)) + continue; + + Node &ref = track_nodes[key] = lowest; + if(goal(*lowest.track)) + { + final = &ref; + break; + } + + const TrackType &type = lowest.track->get_type(); + const vector &eps = type.get_endpoints(); + const vector &links = lowest.track->get_links(); + for(unsigned i=0; iget_endpoint_by_link(*lowest.track); + if(track_nodes.count(Key(links[i], link_ep))) + continue; + + unsigned mask = eps[i].paths&eps[lowest.ep].paths; + if(!mask) + continue; + + unsigned path=0; + for(; !(mask&1); ++path, mask>>=1) ; + nodes.push(Node(*links[i], links[i]->get_endpoint_by_link(*lowest.track), ref, type.get_path_length(path))); + } + } + + if(!final) + throw InvalidParameterValue("Could not find a route"); + + list result; + for(Node *node=final; node; node=node->prev) + result.push_front(node->track); + + return result; +} + +unsigned count = 0; + +template +Route *create_route(const Track &from, unsigned ep, const Pred &goal) +{ + list tracks = dijkstra(from, ep, goal); + + Route *route = new Route(from.get_layout(), format("-%d-", ++count)); + for(list::iterator i=tracks.begin(); i!=tracks.end(); ++i) + route->add_track(**i); + + route->set_temporary(true); + + return route; +} + +} + + namespace Marklin { Route::Route(Layout &l, const string &n): layout(l), - name(n) + name(n), + temporary(false) { layout.add_route(*this); layout.signal_track_removed.connect(sigc::mem_fun(this, &Route::track_removed)); @@ -28,6 +154,11 @@ Route::~Route() layout.remove_route(*this); } +void Route::set_temporary(bool t) +{ + temporary = t; +} + int Route::get_turnout(unsigned id) const { map::const_iterator i = turnouts.find(id); @@ -82,17 +213,44 @@ void Route::add_tracks(const set &trks) update_turnouts(); } -void Route::save(list &st) const +void Route::add_track_chain(const Track &start, unsigned ep, const TurnoutMap &trnts) { - for(map::const_iterator i=turnouts.begin(); i!=turnouts.end(); ++i) - st.push_back((DataFile::Statement("turnout"), i->first, i->second)); + const Track *track = &start; + while(1) + { + if(track->get_type().is_dead_end()) + break; + + if(tracks.count(track)) + break; + + int path = 0; + if(track->get_turnout_id()) + { + TurnoutMap::const_iterator i = trnts.find(track->get_turnout_id()); + if(i==trnts.end()) + break; + + path = i->second; + } + + add_track(*track); + + unsigned out_ep = track->traverse(ep, path); + Track *next = track->get_links()[out_ep]; + if(!next) + break; + + ep = next->get_endpoint_by_link(*track); + track = next; + } } void Route::update_turnouts() { set found; for(set::const_iterator i=tracks.begin(); i!=tracks.end(); ++i) - if(unsigned tid=(*i)->get_turnout_id()) + if(unsigned tid = (*i)->get_turnout_id()) { found.insert(tid); @@ -106,7 +264,7 @@ void Route::update_turnouts() if(!tracks.count(links[j])) continue; - if(unsigned tid2=links[j]->get_turnout_id()) + 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); @@ -142,6 +300,12 @@ void Route::update_turnouts() } } +void Route::save(list &st) const +{ + for(map::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 result = 4; @@ -199,6 +363,16 @@ void Route::track_removed(Track &t) tracks.erase(&t); } +Route *Route::find(const Track &from, unsigned ep, const Track &to) +{ + return create_route(from, ep, TrackMatch(to)); +} + +Route *Route::find(const Track &from, unsigned ep, const Route &to) +{ + return create_route(from, ep, TrackInRoute(to)); +} + Route::Loader::Loader(Route &r): DataFile::BasicLoader(r) @@ -206,9 +380,37 @@ Route::Loader::Loader(Route &r): add("turnout", &Loader::turnout); } +void Route::Loader::finish() +{ + const set <racks = obj.layout.get_tracks(); + for(set::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<second; + const vector &eps = (*i)->get_type().get_endpoints(); + for(unsigned k=0; kget_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; + } + } +} + void Route::Loader::turnout(unsigned id, unsigned path) { - obj.turnouts[id] = path; + turnouts[id] = path; } } // namespace Marklin