Line data Source code
1 : /****************************************************************************/
2 : // Eclipse SUMO, Simulation of Urban MObility; see https://eclipse.dev/sumo
3 : // Copyright (C) 2001-2024 German Aerospace Center (DLR) and others.
4 : // This program and the accompanying materials are made available under the
5 : // terms of the Eclipse Public License 2.0 which is available at
6 : // https://www.eclipse.org/legal/epl-2.0/
7 : // This Source Code may also be made available under the following Secondary
8 : // Licenses when the conditions for such availability set forth in the Eclipse
9 : // Public License 2.0 are satisfied: GNU General Public License, version 2
10 : // or later which is available at
11 : // https://www.gnu.org/licenses/old-licenses/gpl-2.0-standalone.html
12 : // SPDX-License-Identifier: EPL-2.0 OR GPL-2.0-or-later
13 : /****************************************************************************/
14 : /// @file MSDetectorControl.cpp
15 : /// @author Daniel Krajzewicz
16 : /// @author Jakob Erdmann
17 : /// @author Clemens Honomichl
18 : /// @author Sascha Krieg
19 : /// @author Michael Behrisch
20 : /// @author Laura Bieker
21 : /// @date 2005-09-15
22 : ///
23 : // Detectors container; responsible for string and output generation
24 : /****************************************************************************/
25 : #include <config.h>
26 :
27 : #include <iostream>
28 : #include <utils/options/OptionsCont.h>
29 : #include <utils/options/Option.h>
30 : #include <utils/common/MsgHandler.h>
31 : #include "MSMeanData_Emissions.h"
32 : #include "MSMeanData_Net.h"
33 : #include "MSDetectorControl.h"
34 :
35 :
36 : // ===========================================================================
37 : // member method definitions
38 : // ===========================================================================
39 43013 : MSDetectorControl::MSDetectorControl() {
40 43013 : }
41 :
42 :
43 40036 : MSDetectorControl::~MSDetectorControl() {
44 50023 : for (auto i = myDetectors.begin(); i != myDetectors.end(); ++i) {
45 9987 : (*i).second.clear();
46 : }
47 43881 : for (auto item : myMeanData) {
48 8123 : for (MSMeanData* md : item.second) {
49 4278 : delete md;
50 : }
51 : }
52 : myMeanData.clear();
53 40036 : }
54 :
55 :
56 : void
57 38584 : MSDetectorControl::close(SUMOTime step) {
58 : // flush the last values
59 38584 : writeOutput(step, true);
60 : // [...] files are closed on another place [...]
61 : myIntervals.clear();
62 38584 : }
63 :
64 :
65 : void
66 29205 : MSDetectorControl::add(SumoXMLTag type, MSDetectorFileOutput* d, const std::string& device, SUMOTime interval, SUMOTime begin) {
67 29205 : if (!myDetectors[type].add(d->getID(), d)) {
68 : const std::string id = d->getID();
69 4 : delete d;
70 8 : throw ProcessError(toString(type) + " detector '" + id + "' could not be built (declared twice?).");
71 : }
72 29201 : addDetectorAndInterval(d, &OutputDevice::getDevice(device), interval, begin);
73 29187 : }
74 :
75 :
76 : void
77 2938 : MSDetectorControl::add(SumoXMLTag type, MSDetectorFileOutput* d) {
78 2938 : if (!myDetectors[type].add(d->getID(), d)) {
79 : const std::string id = d->getID();
80 0 : delete d;
81 0 : throw ProcessError(toString(type) + " detector '" + id + "' could not be built (declared twice?).");
82 : }
83 2938 : }
84 :
85 :
86 : void
87 4279 : MSDetectorControl::add(MSMeanData* md, const std::string& device,
88 : SUMOTime frequency, SUMOTime begin) {
89 4279 : myMeanData[md->getID()].push_back(md);
90 4279 : addDetectorAndInterval(md, &OutputDevice::getDevice(device), frequency, begin);
91 8558 : if (begin <= string2time(OptionsCont::getOptions().getString("begin"))) {
92 3640 : md->init();
93 : }
94 4279 : MSGlobals::gHaveEmissions |= typeid(*md) == typeid(MSMeanData_Emissions);
95 4279 : }
96 :
97 :
98 : const std::vector<SumoXMLTag>
99 7274 : MSDetectorControl::getAvailableTypes() const {
100 : std::vector<SumoXMLTag> result;
101 7762 : for (std::map<SumoXMLTag, NamedObjectCont<MSDetectorFileOutput*> >::const_iterator i = myDetectors.begin(); i != myDetectors.end(); ++i) {
102 488 : result.push_back(i->first);
103 : }
104 7274 : return result;
105 0 : }
106 :
107 :
108 : const NamedObjectCont<MSDetectorFileOutput*>&
109 27546942 : MSDetectorControl::getTypedDetectors(SumoXMLTag type) const {
110 27546942 : if (myDetectors.find(type) == myDetectors.end()) {
111 82 : return myEmptyContainer;
112 : }
113 27546860 : return myDetectors.find(type)->second;
114 : }
115 :
116 :
117 : void
118 92748581 : MSDetectorControl::updateDetectors(const SUMOTime step) {
119 120177501 : for (const auto& i : myDetectors) {
120 107795564 : for (const auto& j : getTypedDetectors(i.first)) {
121 80366644 : j.second->detectorUpdate(step);
122 : }
123 : }
124 98677397 : for (auto item : myMeanData) {
125 12742357 : for (MSMeanData* md : item.second) {
126 6813532 : md->detectorUpdate(step);
127 : }
128 : }
129 92748572 : }
130 :
131 :
132 : void
133 92787150 : MSDetectorControl::writeOutput(SUMOTime step, bool closing) {
134 123668123 : for (Intervals::iterator i = myIntervals.begin(); i != myIntervals.end(); ++i) {
135 30880974 : IntervalsKey interval = (*i).first;
136 30880974 : if (myLastCalls[interval] + interval.first <= step || (closing && myLastCalls[interval] < step)) {
137 473559 : DetectorFileVec dfVec = (*i).second;
138 473559 : SUMOTime startTime = myLastCalls[interval];
139 : // check whether at the end the output was already generated
140 1784941 : for (DetectorFileVec::iterator it = dfVec.begin(); it != dfVec.end(); ++it) {
141 1311383 : MSDetectorFileOutput* det = it->first;
142 1311383 : det->writeXMLOutput(*(it->second), startTime, step);
143 : }
144 473558 : myLastCalls[interval] = step;
145 473559 : }
146 : }
147 92787149 : }
148 :
149 :
150 : void
151 33466 : MSDetectorControl::addDetectorAndInterval(MSDetectorFileOutput* det,
152 : OutputDevice* device,
153 : SUMOTime interval,
154 : SUMOTime begin) {
155 33466 : const SUMOTime simBegin = string2time(OptionsCont::getOptions().getString("begin"));
156 33466 : if (begin == -1) {
157 : begin = simBegin;
158 : }
159 33466 : IntervalsKey key = std::make_pair(interval, begin);
160 : Intervals::iterator it = myIntervals.find(key);
161 : // Add command for given key only once to MSEventControl...
162 33466 : if (it == myIntervals.end()) {
163 : DetectorFileVec detAndFileVec;
164 12263 : detAndFileVec.push_back(std::make_pair(det, device));
165 12263 : myIntervals.insert(std::make_pair(key, detAndFileVec));
166 : SUMOTime lastCall = begin;
167 12263 : if (begin < simBegin) {
168 18 : SUMOTime divRest = (simBegin - begin) % interval;
169 18 : lastCall = simBegin - divRest;
170 : }
171 12263 : myLastCalls[key] = lastCall;
172 12263 : } else {
173 21203 : DetectorFileVec& detAndFileVec = it->second;
174 21203 : if (find_if(detAndFileVec.begin(), detAndFileVec.end(), [&](const DetectorFilePair & pair) {
175 80789 : return pair.first == det;
176 : }) == detAndFileVec.end()) {
177 21203 : detAndFileVec.push_back(std::make_pair(det, device));
178 : } else {
179 : // detector already in container. Don't add several times
180 0 : WRITE_WARNING("MSDetectorControl::addDetectorAndInterval: detector already in container. Ignoring.");
181 0 : return;
182 : }
183 : }
184 33466 : det->writeXMLDetectorProlog(*device);
185 : }
186 :
187 : void
188 187 : MSDetectorControl::clearState(SUMOTime step) {
189 247 : for (const auto& i : myDetectors) {
190 120 : for (const auto& j : getTypedDetectors(i.first)) {
191 60 : j.second->clearState(step);
192 : }
193 : }
194 187 : }
195 :
196 : /****************************************************************************/
|
