SUMO - Simulation of Urban MObility
 All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
duarouter_main.cpp
Go to the documentation of this file.
1 /****************************************************************************/
9 // Main for DUAROUTER
10 /****************************************************************************/
11 // SUMO, Simulation of Urban MObility; see http://sumo.sourceforge.net/
12 // Copyright (C) 2001-2013 DLR (http://www.dlr.de/) and contributors
13 /****************************************************************************/
14 //
15 // This file is part of SUMO.
16 // SUMO is free software: you can redistribute it and/or modify
17 // it under the terms of the GNU General Public License as published by
18 // the Free Software Foundation, either version 3 of the License, or
19 // (at your option) any later version.
20 //
21 /****************************************************************************/
22 
23 
24 // ===========================================================================
25 // included modules
26 // ===========================================================================
27 #ifdef _MSC_VER
28 #include <windows_config.h>
29 #else
30 #include <config.h>
31 #endif
32 
33 #ifdef HAVE_VERSION_H
34 #include <version.h>
35 #endif
36 
37 #include <xercesc/sax/SAXException.hpp>
38 #include <xercesc/sax/SAXParseException.hpp>
39 #include <utils/common/TplConvert.h>
40 #include <iostream>
41 #include <string>
42 #include <limits.h>
43 #include <ctime>
44 #include <router/ROLoader.h>
45 #include <router/RONet.h>
46 #include <router/ROEdge.h>
47 #include <router/ROCostCalculator.h>
48 #include <utils/common/DijkstraRouterTT.h>
49 #include <utils/common/DijkstraRouterEffort.h>
50 #include <utils/common/AStarRouter.h>
51 #include "RODUAEdgeBuilder.h"
52 #include <router/ROFrame.h>
53 #include <utils/common/MsgHandler.h>
54 #include <utils/options/Option.h>
55 #include <utils/options/OptionsCont.h>
56 #include <utils/options/OptionsIO.h>
57 #include <utils/common/UtilExceptions.h>
58 #include <utils/common/SystemFrame.h>
59 #include <utils/common/RandHelper.h>
60 #include <utils/common/ToString.h>
61 #include <utils/xml/XMLSubSys.h>
62 #include "RODUAFrame.h"
63 #include <utils/iodevices/OutputDevice.h>
64 
65 #ifdef HAVE_INTERNAL // catchall for internal stuff
66 #include <internal/BulkStarRouter.h>
67 #include <internal/CHRouter.h>
68 #include <internal/CHRouterWrapper.h>
69 #endif // have HAVE_INTERNAL
70 
71 #ifdef CHECK_MEMORY_LEAKS
72 #include <foreign/nvwa/debug_new.h>
73 #endif // CHECK_MEMORY_LEAKS
74 
75 
76 // ===========================================================================
77 // functions
78 // ===========================================================================
79 /* -------------------------------------------------------------------------
80  * data processing methods
81  * ----------------------------------------------------------------------- */
87 void
88 initNet(RONet& net, ROLoader& loader, OptionsCont& oc) {
89  // load the net
90  RODUAEdgeBuilder builder(oc.getBool("weights.expand"), oc.getBool("weights.interpolate"));
91  loader.loadNet(net, builder);
92  // load the weights when wished/available
93  if (oc.isSet("weight-files")) {
94  loader.loadWeights(net, "weight-files", oc.getString("weight-attribute"), false);
95  }
96  if (oc.isSet("lane-weight-files")) {
97  loader.loadWeights(net, "lane-weight-files", oc.getString("weight-attribute"), true);
98  }
99 }
100 
101 
102 
106 void
107 computeRoutes(RONet& net, ROLoader& loader, OptionsCont& oc) {
108  // initialise the loader
109  loader.openRoutes(net);
110  // prepare the output
111  const std::string& filename = oc.getString("output-file");
112  std::string altFilename = filename + ".alt";
113  const size_t len = filename.length();
114  if (len > 4 && filename.substr(len - 4) == ".xml") {
115  altFilename = filename.substr(0, len - 4) + ".alt.xml";
116  } else if (len > 4 && filename.substr(len - 4) == ".sbx") {
117  altFilename = filename.substr(0, len - 4) + ".alt.sbx";
118  }
119  net.openOutput(filename, altFilename, oc.getString("vtype-output"));
120  // build the router
121  SUMOAbstractRouter<ROEdge, ROVehicle>* router;
122  const std::string measure = oc.getString("weight-attribute");
123  const std::string routingAlgorithm = oc.getString("routing-algorithm");
124  if (measure == "traveltime") {
125  if (routingAlgorithm == "dijkstra") {
126  if (net.hasRestrictions()) {
127  router = new DijkstraRouterTT_Direct<ROEdge, ROVehicle, prohibited_withRestrictions<ROEdge, ROVehicle> >(
128  net.getEdgeNo(), oc.getBool("ignore-errors"), &ROEdge::getTravelTime);
129  } else {
130  router = new DijkstraRouterTT_Direct<ROEdge, ROVehicle, prohibited_noRestrictions<ROEdge, ROVehicle> >(
131  net.getEdgeNo(), oc.getBool("ignore-errors"), &ROEdge::getTravelTime);
132  }
133  } else if (routingAlgorithm == "astar") {
134  if (net.hasRestrictions()) {
135  router = new AStarRouterTT_Direct<ROEdge, ROVehicle, prohibited_withRestrictions<ROEdge, ROVehicle> >(
136  net.getEdgeNo(), oc.getBool("ignore-errors"), &ROEdge::getTravelTime);
137  } else {
138  router = new AStarRouterTT_Direct<ROEdge, ROVehicle, prohibited_noRestrictions<ROEdge, ROVehicle> >(
139  net.getEdgeNo(), oc.getBool("ignore-errors"), &ROEdge::getTravelTime);
140  }
141 #ifdef HAVE_INTERNAL // catchall for internal stuff
142  } else if (routingAlgorithm == "bulkstar") {
143  if (net.hasRestrictions()) {
144  router = new BulkStarRouterTT<ROEdge, ROVehicle, prohibited_withRestrictions<ROEdge, ROVehicle> >(
145  net.getEdgeNo(), oc.getBool("ignore-errors"), &ROEdge::getTravelTime, &ROEdge::getMinimumTravelTime);
146  } else {
147  router = new BulkStarRouterTT<ROEdge, ROVehicle, prohibited_noRestrictions<ROEdge, ROVehicle> >(
148  net.getEdgeNo(), oc.getBool("ignore-errors"), &ROEdge::getTravelTime, &ROEdge::getMinimumTravelTime);
149  }
150 
151  } else if (routingAlgorithm == "CH") {
152  // defaultVehicle is only in constructor and may be safely deleted
153  // it is mainly needed for its maximum speed. @todo XXX make this configurable
154  ROVehicle defaultVehicle(SUMOVehicleParameter(), 0, net.getVehicleTypeSecure(DEFAULT_VTYPE_ID));
155  const SUMOTime begin = string2time(oc.getString("begin"));
156  const SUMOTime weightPeriod = (oc.isSet("weight-files") ?
157  string2time(oc.getString("weight-period")) :
158  std::numeric_limits<int>::max());
159  if (net.hasRestrictions()) {
160  router = new CHRouter<ROEdge, ROVehicle, prohibited_withRestrictions<ROEdge, ROVehicle> >(
161  net.getEdgeNo(), oc.getBool("ignore-errors"), &ROEdge::getTravelTime, &defaultVehicle, begin, weightPeriod, true);
162  } else {
163  router = new CHRouter<ROEdge, ROVehicle, prohibited_noRestrictions<ROEdge, ROVehicle> >(
164  net.getEdgeNo(), oc.getBool("ignore-errors"), &ROEdge::getTravelTime, &defaultVehicle, begin, weightPeriod, false);
165  }
166 
167  } else if (routingAlgorithm == "CHWrapper") {
168  const SUMOTime begin = string2time(oc.getString("begin"));
169  const SUMOTime weightPeriod = (oc.isSet("weight-files") ?
170  string2time(oc.getString("weight-period")) :
171  std::numeric_limits<int>::max());
172 
173  router = new CHRouterWrapper<ROEdge, ROVehicle, prohibited_withRestrictions<ROEdge, ROVehicle> >(
174  net.getEdgeNo(), oc.getBool("ignore-errors"), &ROEdge::getTravelTime, begin, weightPeriod);
175 
176 #endif // have HAVE_INTERNAL
177  } else {
178  throw ProcessError("Unknown routing Algorithm '" + routingAlgorithm + "'!");
179  }
180 
181  } else {
182  DijkstraRouterEffort_Direct<ROEdge, ROVehicle, prohibited_withRestrictions<ROEdge, ROVehicle> >::Operation op;
183  if (measure == "CO") {
184  op = &ROEdge::getCOEffort;
185  } else if (measure == "CO2") {
186  op = &ROEdge::getCO2Effort;
187  } else if (measure == "PMx") {
188  op = &ROEdge::getPMxEffort;
189  } else if (measure == "HC") {
190  op = &ROEdge::getHCEffort;
191  } else if (measure == "NOx") {
192  op = &ROEdge::getNOxEffort;
193  } else if (measure == "fuel") {
194  op = &ROEdge::getFuelEffort;
195  } else if (measure == "noise") {
196  op = &ROEdge::getNoiseEffort;
197  } else {
198  net.closeOutput();
199  throw ProcessError("Unknown measure (weight attribute '" + measure + "')!");
200  }
201  if (net.hasRestrictions()) {
202  router = new DijkstraRouterEffort_Direct<ROEdge, ROVehicle, prohibited_withRestrictions<ROEdge, ROVehicle> >(
203  net.getEdgeNo(), oc.getBool("ignore-errors"), op, &ROEdge::getTravelTime);
204  } else {
205  router = new DijkstraRouterEffort_Direct<ROEdge, ROVehicle, prohibited_noRestrictions<ROEdge, ROVehicle> >(
206  net.getEdgeNo(), oc.getBool("ignore-errors"), op, &ROEdge::getTravelTime);
207  }
208  }
209  // process route definitions
210  try {
211  if (routingAlgorithm == "bulkstar") {
212 #ifdef HAVE_INTERNAL // catchall for internal stuff
213  // need to load all routes for spatial aggregation
214  loader.processAllRoutesWithBulkRouter(string2time(oc.getString("begin")), string2time(oc.getString("end")), net, *router);
215 #endif
216  } else {
217  loader.processRoutes(string2time(oc.getString("begin")), string2time(oc.getString("end")), net, *router);
218  }
219  // end the processing
220  net.closeOutput();
221  delete router;
222  ROCostCalculator::cleanup();
223  } catch (ProcessError&) {
224  net.closeOutput();
225  delete router;
226  ROCostCalculator::cleanup();
227  throw;
228  }
229 }
230 
231 
232 /* -------------------------------------------------------------------------
233  * main
234  * ----------------------------------------------------------------------- */
235 int
236 main(int argc, char** argv) {
237  OptionsCont& oc = OptionsCont::getOptions();
238  // give some application descriptions
239  oc.setApplicationDescription("Shortest path router and DUE computer for the microscopic road traffic simulation SUMO.");
240  oc.setApplicationName("duarouter", "SUMO duarouter Version " + (std::string)VERSION_STRING);
241  int ret = 0;
242  RONet* net = 0;
243  try {
244  XMLSubSys::init();
245  RODUAFrame::fillOptions();
246  OptionsIO::getOptions(true, argc, argv);
247  if (oc.processMetaOptions(argc < 2)) {
248  SystemFrame::close();
249  return 0;
250  }
251  XMLSubSys::setValidation(oc.getBool("xml-validation"));
252  MsgHandler::initOutputOptions();
253  if (!RODUAFrame::checkOptions()) {
254  throw ProcessError();
255  }
256  RandHelper::initRandGlobal();
257  // load data
258  ROLoader loader(oc, false, !oc.getBool("no-step-log"));
259  net = new RONet();
260  initNet(*net, loader, oc);
261  // build routes
262  try {
263  computeRoutes(*net, loader, oc);
264  } catch (XERCES_CPP_NAMESPACE::SAXParseException& e) {
265  WRITE_ERROR(toString(e.getLineNumber()));
266  ret = 1;
267  } catch (XERCES_CPP_NAMESPACE::SAXException& e) {
268  WRITE_ERROR(TplConvert::_2str(e.getMessage()));
269  ret = 1;
270  }
271  if (MsgHandler::getErrorInstance()->wasInformed() || ret != 0) {
272  throw ProcessError();
273  }
274  } catch (const ProcessError& e) {
275  if (std::string(e.what()) != std::string("Process Error") && std::string(e.what()) != std::string("")) {
276  WRITE_ERROR(e.what());
277  }
278  MsgHandler::getErrorInstance()->inform("Quitting (on error).", false);
279  ret = 1;
280 #ifndef _DEBUG
281  } catch (const std::exception& e) {
282  if (std::string(e.what()) != std::string("")) {
283  WRITE_ERROR(e.what());
284  }
285  MsgHandler::getErrorInstance()->inform("Quitting (on error).", false);
286  ret = 1;
287  } catch (...) {
288  MsgHandler::getErrorInstance()->inform("Quitting (on unknown error).", false);
289  ret = 1;
290 #endif
291  }
292  delete net;
293  SystemFrame::close();
294  if (ret == 0) {
295  std::cout << "Success." << std::endl;
296  }
297  return ret;
298 }
299 
300 
301 
302 /****************************************************************************/
303