54 #ifdef CHECK_MEMORY_LEAKS 56 #endif // CHECK_MEMORY_LEAKS 63 : myDistricts(dc), myNoLoaded(0), myNoWritten(0), myNoDiscarded(0) {}
76 SUMOTime end,
const std::string& origin,
const std::string& destination,
77 const std::string& vehicleType) {
80 WRITE_WARNING(
"Missing origin '" + origin +
"' and destination '" + destination +
"' (" +
toString(vehicleNumber) +
" vehicles).");
84 }
else if (
myDistricts.
get(destination) == 0 && vehicleNumber > 0) {
85 WRITE_ERROR(
"Missing destination '" + destination +
"' (" +
toString(vehicleNumber) +
" vehicles).");
89 WRITE_ERROR(
"District '" + origin +
"' has no source.");
92 WRITE_ERROR(
"District '" + destination +
"' has no sink.");
110 const std::string& origin,
const std::string& destination,
111 const std::string& vehicleType) {
113 std::vector<ODCell*>::reverse_iterator cell =
myContainer.rbegin();
115 if ((*cell)->begin <= depart && (*cell)->end > depart &&
116 (*cell)->origin == origin && (*cell)-> destination == destination &&
117 (*cell)->vehicleType == vehicleType) {
123 const int intervalIdx = (int)(depart / interval);
124 add(1., intervalIdx * interval, (intervalIdx + 1) * interval, origin, destination, vehicleType);
127 (*cell)->vehicleNumber += 1.;
129 (*cell)->departures[depart].push_back(
id);
135 size_t& vehName, std::vector<ODVehicle>& into,
136 const bool uniform,
const bool differSourceSink,
137 const std::string& prefix) {
143 if (vehicles2insert == 0) {
148 for (
int i = 0; i < vehicles2insert; ++i) {
161 }
while (canDiffer && differSourceSink && (veh.
to == veh.
from));
162 if (!canDiffer && differSourceSink && (veh.
to == veh.
from)) {
174 const ODCell*
const cell) {
180 if (oc.
isSet(
"departlane") && oc.
getString(
"departlane") !=
"default") {
183 if (oc.
isSet(
"departpos")) {
186 if (oc.
isSet(
"departspeed") && oc.
getString(
"departspeed") !=
"default") {
189 if (oc.
isSet(
"arrivallane")) {
192 if (oc.
isSet(
"arrivalpos")) {
195 if (oc.
isSet(
"arrivalspeed")) {
204 const bool differSourceSink,
const bool noVtype,
205 const std::string& prefix,
const bool stepLog) {
209 std::map<std::pair<std::string, std::string>,
SUMOReal> fractionLeft;
214 std::vector<ODCell*>::iterator next =
myContainer.begin();
215 std::vector<ODVehicle> vehicles;
218 for (
SUMOTime t = begin; t < end;) {
219 if (stepLog && t - lastOut >=
DELTA_T) {
220 std::cout <<
"Parsing time " +
time2string(t) <<
'\r';
224 bool changed =
false;
225 while (next !=
myContainer.end() && (*next)->begin <= t && (*next)->end > t) {
226 std::pair<std::string, std::string> odID = std::make_pair((*next)->origin, (*next)->destination);
228 if (fractionLeft.find(odID) != fractionLeft.end()) {
229 (*next)->vehicleNumber += fractionLeft[odID];
230 fractionLeft[odID] = 0;
233 const size_t oldSize = vehicles.size();
235 if (oldSize != vehicles.size()) {
239 fractionLeft[odID] = fraction;
246 for (std::vector<ODVehicle>::reverse_iterator i = vehicles.rbegin(); i != vehicles.rend() && (*i).depart == t; ++i) {
255 while (vehicles.size() != 0 && vehicles.back().depart == t) {
258 if (!vehicles.empty()) {
259 t = vehicles.back().depart;
261 if (next !=
myContainer.end() && (t > (*next)->begin || vehicles.empty())) {
264 if (next ==
myContainer.end() && vehicles.empty()) {
274 const std::string& prefix) {
282 const ODCell*
const c = *i;
283 if (c->
end > begin && c->
begin < end) {
299 if (line[0] !=
'*') {
309 if (time.find(
'.') == std::string::npos) {
312 std::string hours = time.substr(0, time.find(
'.'));
313 std::string minutes = time.substr(time.find(
'.') + 1);
318 std::pair<SUMOTime, SUMOTime>
326 throw ProcessError(
"Begin time is larger than end time.");
328 return std::make_pair(begin, end);
330 throw ProcessError(
"Broken period definition '" + line +
"'.");
332 throw ProcessError(
"Broken period definition '" + line +
"'.");
350 std::string vehType,
bool matrixHasVehType) {
354 if (matrixHasVehType) {
362 std::pair<SUMOTime, SUMOTime> times =
readTime(lr);
373 std::vector<std::string> names;
378 names.push_back(st2.
next());
380 }
while ((
int) names.size() != districtNo);
383 for (std::vector<std::string>::iterator si = names.begin(); si != names.end(); ++si) {
384 std::vector<std::string>::iterator di = names.begin();
388 if (line.length() == 0) {
394 assert(di != names.end());
396 if (vehNumber != 0) {
397 add(vehNumber, begin, end, *si, *di, vehType);
399 if (di == names.end()) {
400 throw ProcessError(
"More entries than districts found.");
405 throw ProcessError(
"Not numeric vehicle number in line '" + line +
"'.");
410 }
while (di != names.end());
418 std::string vehType,
bool matrixHasVehType) {
422 if (matrixHasVehType) {
431 std::pair<SUMOTime, SUMOTime> times =
readTime(lr);
441 if (line.length() == 0) {
445 if (st2.
size() == 0) {
449 std::string sourceD = st2.
next();
450 std::string destD = st2.
next();
452 if (vehNumber != 0) {
453 add(vehNumber, begin, end, sourceD, destD, vehType);
456 throw ProcessError(
"Missing at least one information in line '" + line +
"'.");
458 throw ProcessError(
"Not numeric vehicle number in line '" + line +
"'.");
486 for (
size_t i = 0; i < ps.
getAreaNo(); ++i) {
494 newCells.push_back(ncell);
503 for (std::vector<ODCell*>::iterator i = oldCells.begin(); i != oldCells.end(); ++i) {
504 std::vector<ODCell*> newCells;
506 copy(newCells.begin(), newCells.end(), back_inserter(
myContainer));
514 std::vector<std::string> files = oc.
getStringVector(
"od-matrix-files");
515 for (std::vector<std::string>::iterator i = files.begin(); i != files.end(); ++i) {
522 if (type.find(
';') != std::string::npos) {
523 type = type.substr(0, type.find(
';'));
526 if (type.length() > 1 && type[1] ==
'V') {
528 if (type.find(
'N') != std::string::npos) {
529 throw ProcessError(
"'" + *i +
"' does not contain the needed information about the time described.");
532 }
else if (type.length() > 1 && type[1] ==
'O') {
534 if (type.find(
'N') != std::string::npos) {
535 throw ProcessError(
"'" + *i +
"' does not contain the needed information about the time described.");
539 throw ProcessError(
"'" + *i +
"' uses an unknown matrix type '" + type +
"'.");
542 std::vector<std::string> amitranFiles = oc.
getStringVector(
"od-amitran-files");
543 for (std::vector<std::string>::iterator i = amitranFiles.begin(); i != amitranFiles.end(); ++i) {
545 throw ProcessError(
"Could not access matrix file '" + *i +
"' to load.");
560 std::vector<std::string> routeFiles = oc.
getStringVector(
"route-files");
561 for (std::vector<std::string>::iterator i = routeFiles.begin(); i != routeFiles.end(); ++i) {
563 throw ProcessError(
"Could not access route file '" + *i +
"' to load.");
577 bool interpolating = !timelineDayInHours;
580 if (timelineDayInHours) {
581 if (def.size() != 24) {
582 throw ProcessError(
"Assuming 24 entries for a day timeline, but got " +
toString(def.size()) +
".");
584 for (
int chour = 0; chour < 24; ++chour) {
591 while (i < def.size()) {
593 if (st2.
size() != 2) {
594 throw ProcessError(
"Broken time line definition: missing a value in '" + def[i - 1] +
"'.");
SUMOReal getNoLoaded() const
Returns the number of loaded vehicles.
SUMOReal myNoLoaded
Number of loaded vehicles.
void writeDefaultAttrs(OutputDevice &dev, const bool noVtype, const ODCell *const cell)
Helper function for flow and trip output writing the depart and arrival attributes.
OutputDevice & writeAttr(const SumoXMLAttr attr, const T &val)
writes a named attribute
std::vector< std::string > getStringVector(const std::string &name) const
Returns the list of string-vector-value of the named option (only for Option_String) ...
Used for sorting the cells by the begin time they describe.
SUMOReal computeDeparts(ODCell *cell, size_t &vehName, std::vector< ODVehicle > &into, const bool uniform, const bool differSourceSink, const std::string &prefix)
Computes the vehicle departs stored in the given cell and saves them in "into".
static bool isReadable(std::string path)
Checks whether the given file is readable.
bool readLine(LineHandler &lh)
Reads a single (the next) line from the file and reports it to the given LineHandler.
static SUMOReal _2SUMOReal(const E *const data)
static const int WHITECHARS
Retrieves a file linewise and reports the lines to a handler.
SUMOReal getAreaPerc(size_t index) const
SUMOReal myNoWritten
Number of written vehicles.
const ODDistrictCont & myDistricts
The districts to retrieve sources/sinks from.
SUMOReal getAreaEnd(size_t index) const
An internal representation of a single vehicle.
static SUMOReal rand()
Returns a random real number in [0, 1)
std::string time2string(SUMOTime t)
void add(SUMOReal vehicleNumber, SUMOTime begin, SUMOTime end, const std::string &origin, const std::string &destination, const std::string &vehicleType)
Builds a single cell from the given values, verifying them.
SUMOReal getFloat(const std::string &name) const
Returns the SUMOReal-value of the named option (only for Option_Float)
SAX-handler base for SUMO-files.
std::string from
The edge the vehicles shall start at.
static bool runParser(GenericSAXHandler &handler, const std::string &file, const bool isNet=false)
Runs the given handler on the given file; returns if everything's ok.
SUMOTime parseSingleTime(const std::string &time)
Sorts cells by their start time.
#define WRITE_WARNING(msg)
static OptionsCont & getOptions()
Retrieves the options.
void loadMatrix(OptionsCont &oc)
read a matrix in one of several formats
T get(const std::string &id) const
Retrieves an item.
std::string getString(const std::string &name) const
Returns the string-value of the named option (only for Option_String)
#define PROGRESS_FAILED_MESSAGE()
unsigned int sinkNumber() const
Returns the number of sinks.
SUMOReal getNoDiscarded() const
Returns the number of discarded vehicles.
A single O/D-matrix cell.
void readV(LineReader &lr, SUMOReal scale, std::string vehType, bool matrixHasVehType)
read a VISUM-matrix with the V Format
std::string origin
Name of the origin district.
std::string getRandomSourceFromDistrict(const std::string &name) const
Returns the id of a random source from the named district.
void add(const std::string &id, const SUMOTime depart, const std::string &origin, const std::string &destination, const std::string &vehicleType)
Adds a single vehicle with departure time.
A point in 2D or 3D with translation and scaling methods.
void readO(LineReader &lr, SUMOReal scale, std::string vehType, bool matrixHasVehType)
read a VISUM-matrix with the O Format
ODCell * cell
The cell of the ODMatrix which generated the vehicle.
void loadRoutes(OptionsCont &oc, SUMOSAXHandler &handler)
read SUMO routes
SUMOTime string2time(const std::string &r)
A container for districts.
SUMOReal getAreaBegin(size_t index) const
#define PROGRESS_BEGIN_MESSAGE(msg)
unsigned int sourceNumber() const
Returns the number of sources.
SUMOReal getNoWritten() const
Returns the number of written vehicles.
SUMOReal vehicleNumber
The number of vehicles.
Used for sorting vehicles by their departure (latest first)
SUMOReal myNoDiscarded
Number of discarded vehicles.
std::vector< ODCell * > myContainer
The loaded cells.
std::string toString(const T &t, std::streamsize accuracy=OUTPUT_ACCURACY)
SUMOTime begin
The begin time this cell describes.
bool good() const
Returns the information whether the stream is readable.
void writeFlows(const SUMOTime begin, const SUMOTime end, OutputDevice &dev, const bool noVtype, const std::string &prefix)
Writes the flows stored in the matrix.
SUMOReal readFactor(LineReader &lr, SUMOReal scale)
std::string getFileName() const
Returns the name of the used file.
std::pair< SUMOTime, SUMOTime > readTime(LineReader &lr)
static int _2int(const E *const data)
std::string getNextNonCommentLine(LineReader &lr)
SUMOTime depart
The departure time of the vehicle.
static std::string prune(const std::string &str)
Removes trailing and leading whitechars.
A storage for options typed value containers)
An XML-Handler for districts.
void applyCurve(const Distribution_Points &ps)
Splits the stored cells dividing them on the given time line.
std::string vehicleType
Name of the vehicle type.
Static storage of an output device and its base (abstract) implementation.
std::string destination
Name of the destination district.
bool closeTag()
Closes the most recently opened tag.
bool hasMore() const
Returns whether another line may be read (the file was not read completely)
void write(SUMOTime begin, const SUMOTime end, OutputDevice &dev, const bool uniform, const bool differSourceSink, const bool noVtype, const std::string &prefix, const bool stepLog)
Writes the vehicles stored in the matrix assigning the sources and sinks.
std::string getRandomSinkFromDistrict(const std::string &name) const
Returns the id of a random sink from the named district.
SUMOTime end
The end time this cell describes.
#define PROGRESS_DONE_MESSAGE()
std::string to
The edge the vehicles shall end at.
ODMatrix(const ODDistrictCont &dc)
Constructor.
std::string id
The id of the vehicle.
OutputDevice & openTag(const std::string &xmlElement)
Opens an XML tag.
Distribution_Points parseTimeLine(const std::vector< std::string > &def, bool timelineDayInHours)
split the given timeline
bool isSet(const std::string &name, bool failOnNonExistant=true) const
Returns the information whether the named option is set.