Command_SaveTLSState.cpp

Go to the documentation of this file.

/****************************************************************************/
// Eclipse SUMO, Simulation of Urban MObility; see https://eclipse.dev/sumo
// Copyright (C) 2001-2025 German Aerospace Center (DLR) and others.
// This program and the accompanying materials are made available under the
// terms of the Eclipse Public License 2.0 which is available at
// https://www.eclipse.org/legal/epl-2.0/
// This Source Code may also be made available under the following Secondary
// Licenses when the conditions for such availability set forth in the Eclipse
// Public License 2.0 are satisfied: GNU General Public License, version 2
// or later which is available at
// https://www.gnu.org/licenses/old-licenses/gpl-2.0-standalone.html
// SPDX-License-Identifier: EPL-2.0 OR GPL-2.0-or-later
/****************************************************************************/
// Writes the state of the tls to a file (in each second)
/****************************************************************************/
#include <config.h>
 
#include "Command_SaveTLSState.h"
#include <microsim/traffic_lights/MSTrafficLightLogic.h>
#include <microsim/MSEventControl.h>
#include <microsim/MSNet.h>
#include <utils/common/UtilExceptions.h>
#include <utils/common/MsgHandler.h>
#include <utils/iodevices/OutputDevice.h>
 
 
// ===========================================================================
// method definitions
// ===========================================================================
Command_SaveTLSState::Command_SaveTLSState(const MSTLLogicControl::TLSLogicVariants& logics,
        OutputDevice& od, bool saveDetectors, bool saveConditions) :
    myOutputDevice(od),
    myLogics(logics),
    mySaveDetectors(saveDetectors),
    mySaveConditions(saveConditions) {
    MSNet::getInstance()->getEndOfTimestepEvents()->addEvent(this);
}
 
 
Command_SaveTLSState::~Command_SaveTLSState() {
}
 
 
SUMOTime
Command_SaveTLSState::execute(SUMOTime currentTime) {
    if (!myOutputDevice.wroteHeader()) {
        // delay writing header to ensure tls is initialized
        std::map<SumoXMLAttr, std::string> attrs;
        if (mySaveDetectors) {
            std::vector<std::string> IDs;
            for (auto item : myLogics.getActive()->getDetectorStates()) {
                IDs.push_back(item.first);
            }
            attrs[SUMO_ATTR_DETECTORS] = joinToString(IDs, " ");
 
        }
        if (mySaveConditions) {
            std::vector<std::string> IDs;
            for (auto item : myLogics.getActive()->getConditions()) {
                IDs.push_back(item.first);
            }
            attrs[SUMO_ATTR_CONDITIONS] = joinToString(IDs, " ");
        }
        myOutputDevice.writeXMLHeader("tlsStates", "tlsstates_file.xsd", attrs);
    }
    myOutputDevice.openTag("tlsState");
    myOutputDevice.writeAttr(SUMO_ATTR_TIME, time2string(currentTime));
    myOutputDevice.writeAttr(SUMO_ATTR_ID, myLogics.getActive()->getID());
    myOutputDevice.writeAttr(SUMO_ATTR_PROGRAMID, myLogics.getActive()->getProgramID());
    myOutputDevice.writeAttr(SUMO_ATTR_PHASE, myLogics.getActive()->getCurrentPhaseIndex());
    myOutputDevice.writeAttr(SUMO_ATTR_STATE, myLogics.getActive()->getCurrentPhaseDef().getState());
    if (!myLogics.getActive()->getCurrentPhaseDef().getName().empty()) {
        myOutputDevice.writeAttr(SUMO_ATTR_NAME, myLogics.getActive()->getCurrentPhaseDef().getName());
    }
    if (mySaveDetectors) {
        std::vector<int> states;
        for (auto item : myLogics.getActive()->getDetectorStates()) {
            states.push_back((int)item.second);
        }
        myOutputDevice.writeAttr(SUMO_ATTR_DETECTORS, joinToString(states, " "));
 
    }
    if (mySaveConditions) {
        std::vector<double> states;
        for (auto item : myLogics.getActive()->getConditions()) {
            states.push_back(item.second);
        }
        myOutputDevice.writeAttr(SUMO_ATTR_CONDITIONS, joinToString(states, " "));
    }
    myOutputDevice.closeTag();
    return DELTA_T;
}
 
 
/****************************************************************************/