53 #ifdef CHECK_MEMORY_LEAKS
55 #endif // CHECK_MEMORY_LEAKS
62 : myDistricts(dc), myNoLoaded(0), myNoWritten(0), myNoDiscarded(0) {}
75 SUMOTime end,
const std::string& origin,
const std::string& destination,
76 const std::string& vehicleType) {
79 WRITE_WARNING(
"Missing origin '" + origin +
"' and destination '" + destination +
"' (" +
toString(vehicleNumber) +
" vehicles).");
83 }
else if (
myDistricts.
get(destination) == 0 && vehicleNumber > 0) {
84 WRITE_ERROR(
"Missing destination '" + destination +
"' (" +
toString(vehicleNumber) +
" vehicles).");
88 WRITE_ERROR(
"District '" + origin +
"' has no source.");
91 WRITE_ERROR(
"District '" + destination +
"' has no sink.");
109 size_t& vehName, std::vector<ODVehicle>& into,
110 bool uniform,
const std::string& prefix) {
116 if (vehicles2insert == 0) {
121 for (
int i = 0; i < vehicles2insert; ++i) {
142 const ODCell*
const cell) {
148 if (oc.
isSet(
"departlane") && oc.
getString(
"departlane") !=
"default") {
151 if (oc.
isSet(
"departpos")) {
154 if (oc.
isSet(
"departspeed") && oc.
getString(
"departspeed") !=
"default") {
157 if (oc.
isSet(
"arrivallane")) {
160 if (oc.
isSet(
"arrivalpos")) {
163 if (oc.
isSet(
"arrivalspeed")) {
171 OutputDevice& dev,
const bool uniform,
const bool noVtype,
172 const std::string& prefix,
const bool stepLog) {
176 std::map<std::pair<std::string, std::string>,
SUMOReal> fractionLeft;
181 std::vector<ODCell*>::iterator next =
myContainer.begin();
182 std::vector<ODVehicle> vehicles;
185 for (
SUMOTime t = begin; t != end;) {
186 if (stepLog && t - lastOut >=
DELTA_T) {
187 std::cout <<
"Parsing time " +
time2string(t) <<
'\r';
191 bool changed =
false;
192 while (next !=
myContainer.end() && (*next)->begin <= t && (*next)->end > t) {
193 std::pair<std::string, std::string> odID = std::make_pair((*next)->origin, (*next)->destination);
195 if (fractionLeft.find(odID) != fractionLeft.end()) {
196 (*next)->vehicleNumber += fractionLeft[odID];
197 fractionLeft[odID] = 0;
200 const size_t oldSize = vehicles.size();
202 if (oldSize != vehicles.size()) {
206 fractionLeft[odID] = fraction;
213 for (std::vector<ODVehicle>::reverse_iterator i = vehicles.rbegin(); i != vehicles.rend() && (*i).depart == t; ++i) {
220 while (vehicles.size() != 0 && vehicles.back().depart == t) {
223 if (!vehicles.empty()) {
224 t = vehicles.back().depart;
226 if (next !=
myContainer.end() && (t > (*next)->begin || vehicles.empty())) {
229 if (next ==
myContainer.end() && vehicles.empty()) {
239 const std::string& prefix) {
247 const ODCell*
const c = *i;
248 if (c->
end > begin && c->
begin < end) {
264 if (line[0] !=
'*') {
274 if (time.find(
'.') == std::string::npos) {
277 std::string hours = time.substr(0, time.find(
'.'));
278 std::string minutes = time.substr(time.find(
'.') + 1);
283 std::pair<SUMOTime, SUMOTime>
291 throw ProcessError(
"Begin time is larger than end time.");
293 return std::make_pair(begin, end);
295 throw ProcessError(
"Broken period definition '" + line +
"'.");
297 throw ProcessError(
"Broken period definition '" + line +
"'.");
315 std::string vehType,
bool matrixHasVehType) {
319 if (matrixHasVehType) {
327 std::pair<SUMOTime, SUMOTime> times =
readTime(lr);
338 std::vector<std::string> names;
343 names.push_back(st2.
next());
345 }
while ((
int) names.size() != districtNo);
348 for (std::vector<std::string>::iterator si = names.begin(); si != names.end(); ++si) {
349 std::vector<std::string>::iterator di = names.begin();
353 if (line.length() == 0) {
359 assert(di != names.end());
361 if (vehNumber != 0) {
362 add(vehNumber, begin, end, *si, *di, vehType);
364 if (di == names.end()) {
365 throw ProcessError(
"More entries than districts found.");
370 throw ProcessError(
"Not numeric vehicle number in line '" + line +
"'.");
375 }
while (di != names.end());
383 std::string vehType,
bool matrixHasVehType) {
387 if (matrixHasVehType) {
396 std::pair<SUMOTime, SUMOTime> times =
readTime(lr);
406 if (line.length() == 0) {
410 if (st2.
size() == 0) {
414 std::string sourceD = st2.
next();
415 std::string destD = st2.
next();
417 if (vehNumber != 0) {
418 add(vehNumber, begin, end, sourceD, destD, vehType);
421 throw ProcessError(
"Missing at least one information in line '" + line +
"'.");
423 throw ProcessError(
"Not numeric vehicle number in line '" + line +
"'.");
451 for (
size_t i = 0; i < ps.
getAreaNo(); ++i) {
459 newCells.push_back(ncell);
468 for (std::vector<ODCell*>::iterator i = oldCells.begin(); i != oldCells.end(); ++i) {
469 std::vector<ODCell*> newCells;
471 copy(newCells.begin(), newCells.end(), back_inserter(
myContainer));
478 std::vector<std::string> files = oc.
getStringVector(
"od-matrix-files");
479 for (std::vector<std::string>::iterator i = files.begin(); i != files.end(); ++i) {
486 if (type.find(
';') != std::string::npos) {
487 type = type.substr(0, type.find(
';'));
490 if (type.length() > 1 && type[1] ==
'V') {
492 if (type.find(
'N') != std::string::npos) {
493 throw ProcessError(
"'" + *i +
"' does not contain the needed information about the time described.");
496 }
else if (type.length() > 1 && type[1] ==
'O') {
498 if (type.find(
'N') != std::string::npos) {
499 throw ProcessError(
"'" + *i +
"' does not contain the needed information about the time described.");
503 throw ProcessError(
"'" + *i +
"' uses an unknown matrix type '" + type +
"'.");
506 std::vector<std::string> amitranFiles = oc.
getStringVector(
"od-amitran-files");
507 for (std::vector<std::string>::iterator i = amitranFiles.begin(); i != amitranFiles.end(); ++i) {
509 throw ProcessError(
"Could not access matrix file '" + *i +
"' to load.");
524 bool interpolating = !timelineDayInHours;
527 if (timelineDayInHours) {
528 if (def.size() != 24) {
529 throw ProcessError(
"Assuming 24 entries for a day timeline, but got " +
toString(def.size()) +
".");
531 for (
int chour = 0; chour < 24; ++chour) {
538 while (i < def.size()) {
540 if (st2.
size() != 2) {
541 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.
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
void write(SUMOTime begin, const SUMOTime end, OutputDevice &dev, const bool uniform, const bool noVtype, const std::string &prefix, const bool stepLog)
Writes the vehicles stored in the matrix assigning the sources and sinks.
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)
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)
#define WRITE_WARNING(msg)
static OptionsCont & getOptions()
Retrieves the options.
void loadMatrix(OptionsCont &oc)
read a VISUM-matrix with the V Format
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.
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.
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)
void push_back(const PositionVector &p)
Appends all positions from the given vector.
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)
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.
SUMOReal computeDeparts(ODCell *cell, size_t &vehName, std::vector< ODVehicle > &into, bool uniform, const std::string &prefix)
Computes the vehicle departs stored in the given cell and saves them in "into".
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.