![]() |
SUMO - Simulation of Urban MObility
|
TraCI server used to control sumo by a remote TraCI client. More...
#include <TraCIServer.h>
Data Structures | |
struct | SocketInfo |
Public Types | |
typedef bool(* | CmdExecutor) (TraCIServer &server, tcpip::Storage &inputStorage, tcpip::Storage &outputStorage) |
Definition of a method to be called for serving an associated commandID. More... | |
typedef bool(* | SubscriptionHandler) (const std::string &objID, const int variable, VariableWrapper *wrapper) |
Definition of a method to be called for serving an associated commandID. More... | |
Public Member Functions | |
void | cleanup () |
clean up subscriptions More... | |
std::vector< std::string > & | getLoadArgs () |
SUMOTime | getTargetTime () const |
const std::map< MSNet::VehicleState, std::vector< std::string > > & | getVehicleStateChanges () const |
bool | isEmbedded () const |
void | processCommandsUntilSimStep (SUMOTime step) |
process all commands until the next SUMO simulation step. It is guaranteed that t->getTargetTime() >= myStep after call (except the case that a load or close command is received)s More... | |
virtual void | setContext (const std::string &) |
void | setTargetTime (SUMOTime targetTime) |
Sets myTargetTime on server and sockets to the given value. More... | |
void | vehicleStateChanged (const SUMOVehicle *const vehicle, MSNet::VehicleState to, const std::string &info="") |
Called if a vehicle changes its state. More... | |
void | writePositionVector (tcpip::Storage &outputStorage, const libsumo::TraCIPositionVector &shape) |
void | writeResponseWithLength (tcpip::Storage &outputStorage, tcpip::Storage &tempMsg) |
Writing Status Messages | |
void | writeStatusCmd (int commandId, int status, const std::string &description, tcpip::Storage &outputStorage) |
Writes a status command to the given storage. More... | |
void | writeStatusCmd (int commandId, int status, const std::string &description) |
Writes a status command to myOutputStorage. More... | |
bool | writeErrorStatusCmd (int commandId, const std::string &description, tcpip::Storage &outputStorage) |
Writes a status command to the given storage with status = RTYPE_ERR. More... | |
Helpers for reading and checking values | |
bool | readTypeCheckingInt (tcpip::Storage &inputStorage, int &into) |
Reads the value type and an int, verifying the type. More... | |
bool | readTypeCheckingDouble (tcpip::Storage &inputStorage, double &into) |
Reads the value type and a double, verifying the type. More... | |
bool | readTypeCheckingString (tcpip::Storage &inputStorage, std::string &into) |
Reads the value type and a string, verifying the type. More... | |
bool | readTypeCheckingStringList (tcpip::Storage &inputStorage, std::vector< std::string > &into) |
Reads the value type and a string list, verifying the type. More... | |
bool | readTypeCheckingColor (tcpip::Storage &inputStorage, libsumo::TraCIColor &into) |
Reads the value type and a color, verifying the type. More... | |
bool | readTypeCheckingPosition2D (tcpip::Storage &inputStorage, libsumo::TraCIPosition &into) |
Reads the value type and a 2D position, verifying the type. More... | |
bool | readTypeCheckingByte (tcpip::Storage &inputStorage, int &into) |
Reads the value type and a byte, verifying the type. More... | |
bool | readTypeCheckingUnsignedByte (tcpip::Storage &inputStorage, int &into) |
Reads the value type and an unsigned byte, verifying the type. More... | |
bool | readTypeCheckingPolygon (tcpip::Storage &inputStorage, PositionVector &into) |
Reads the value type and a polygon, verifying the type. More... | |
VariableWrapper interface | |
void | initWrapper (const int domainID, const int variable, const std::string &objID) |
bool | wrapDouble (const std::string &objID, const int variable, const double value) |
bool | wrapInt (const std::string &objID, const int variable, const int value) |
bool | wrapString (const std::string &objID, const int variable, const std::string &value) |
bool | wrapStringList (const std::string &objID, const int variable, const std::vector< std::string > &value) |
bool | wrapPosition (const std::string &objID, const int variable, const libsumo::TraCIPosition &value) |
bool | wrapColor (const std::string &objID, const int variable, const libsumo::TraCIColor &value) |
tcpip::Storage & | getWrapperStorage () |
Static Public Member Functions | |
static TraCIServer * | getInstance () |
Initialisation and Shutdown | |
static void | openSocket (const std::map< int, CmdExecutor > &execs) |
Initialises the server. More... | |
static void | close () |
request termination of connection More... | |
static bool | wasClosed () |
check whether close was requested More... | |
Data Fields | |
SubscriptionHandler | handle |
Private Member Functions | |
bool | addObjectVariableSubscription (const int commandId, const bool hasContext) |
bool | addSubscriptionFilter () |
void | addSubscriptionFilterDownstreamDistance (double dist) |
void | addSubscriptionFilterLanes (std::vector< int > lanes) |
void | addSubscriptionFilterLeadFollow () |
void | addSubscriptionFilterNoOpposite () |
void | addSubscriptionFilterTurn () |
void | addSubscriptionFilterUpstreamDistance (double dist) |
void | addSubscriptionFilterVClass (SVCPermissions vClasses) |
void | addSubscriptionFilterVType (std::set< std::string > vTypes) |
bool | centralObject (const libsumo::Subscription &s, const std::string &objID) |
check whether a found objID refers to the central object of a context subscription More... | |
void | checkClientOrdering () |
Called once after connection of all clients for executing SET_ORDER (and possibly prior GET_VERSION) commands, that should be executed before simulation starts (in processCommandsUntilNextSimStep()). More... | |
int | dispatchCommand () |
Handles command, writes response to myOutputStorage. More... | |
bool | findObjectShape (int domain, const std::string &id, PositionVector &shape) |
void | initialiseSubscription (libsumo::Subscription &s) |
bool | isVehicleToVehicleContextSubscription (const libsumo::Subscription &s) |
SUMOTime | nextTargetTime () const |
get the minimal next target time among all clients More... | |
TraCIServer & | operator= (const TraCIServer &s) |
Invalidated assignment operator. More... | |
void | processReorderingRequests () |
checks for and processes reordering requests (relevant for multiple clients) More... | |
bool | processSingleSubscription (const libsumo::Subscription &s, tcpip::Storage &writeInto, std::string &errors) |
int | readCommandID (int &commandStart, int &commandLength) |
Reads the next command ID from the input storage. More... | |
std::map< int, SocketInfo * >::iterator | removeCurrentSocket () |
removes myCurrentSocket from mySockets and returns an iterator pointing to the next member according to the ordering More... | |
void | removeFilters () |
void | removeSubscription (int commandId, const std::string &identity, int domain) |
void | sendOutputToAll () const |
send out subscription results (actually just the content of myOutputStorage) to clients which will act in this step (i.e. with client target time <= myTargetTime) More... | |
void | sendSingleSimStepResponse () |
sends an empty response to a simstep command to the current client. (This applies to a situation where the TraCI step frequency is higher than the SUMO step frequency) More... | |
TraCIServer (const SUMOTime begin, const int port, const int numClients) | |
Constructor. More... | |
virtual | ~TraCIServer () |
Destructor. More... | |
Server-internal command handling | |
bool | commandGetVersion () |
Returns the TraCI-version. More... | |
void | postProcessSimulationStep () |
Handles subscriptions to send after a simstep2 command. More... | |
Private Attributes | |
const bool | myAmEmbedded |
Whether the server runs in embedded mode. More... | |
std::map< int, SocketInfo * >::iterator | myCurrentSocket |
The currently active client socket. More... | |
std::map< int, CmdExecutor > | myExecutors |
Map of commandIds -> their executors; applicable if the executor applies to the method footprint. More... | |
tcpip::Storage | myInputStorage |
The storage to read from. More... | |
libsumo::Subscription * | myLastContextSubscription |
The last modified context subscription (the one to add a filter to, see (), currently only for vehicle to vehicle context) More... | |
std::vector< std::string > | myLoadArgs |
tcpip::Storage | myOutputStorage |
The storage to write to. More... | |
std::map< int, int > | myParameterSizes |
Map of variable ids to the size of the parameter in bytes. More... | |
tcpip::Socket * | myServerSocket |
The server socket. More... | |
std::map< int, SocketInfo * > | mySocketReorderRequests |
This stores the setOrder(int) requests of the clients. More... | |
std::map< int, SocketInfo * > | mySockets |
The socket connections to the clients the first component (index) determines the client's order (lowest index's commands are processed first),. More... | |
tcpip::Storage | mySubscriptionCache |
The last timestep's subscription results. More... | |
std::vector< libsumo::Subscription > | mySubscriptions |
The list of known, still valid subscriptions. More... | |
SUMOTime | myTargetTime |
The time step to reach until processing the next commands. More... | |
std::map< MSNet::VehicleState, std::vector< std::string > > | myVehicleStateChanges |
Changes in the states of simulated vehicles. More... | |
tcpip::Storage | myWrapperStorage |
A temporary storage to let the wrapper write to. More... | |
Static Private Attributes | |
static bool | myDoCloseConnection = false |
Whether the connection was set to be to close. More... | |
static TraCIServer * | myInstance = nullptr |
Singleton instance of the server. More... | |
TraCI server used to control sumo by a remote TraCI client.
Definition at line 62 of file TraCIServer.h.
typedef bool(* TraCIServer::CmdExecutor) (TraCIServer &server, tcpip::Storage &inputStorage, tcpip::Storage &outputStorage) |
Definition of a method to be called for serving an associated commandID.
Definition at line 65 of file TraCIServer.h.
|
inherited |
Definition of a method to be called for serving an associated commandID.
Definition at line 117 of file Subscription.h.
|
private |
Constructor.
[in] | port | The port to listen to (to open) |
Definition at line 177 of file TraCIServer.cpp.
References tcpip::Socket::accept(), checkClientOrdering(), CMD_GET_EDGE_VARIABLE, CMD_GET_INDUCTIONLOOP_VARIABLE, CMD_GET_JUNCTION_VARIABLE, CMD_GET_LANE_VARIABLE, CMD_GET_LANEAREA_VARIABLE, CMD_GET_MULTIENTRYEXIT_VARIABLE, CMD_GET_PERSON_VARIABLE, CMD_GET_POI_VARIABLE, CMD_GET_POLYGON_VARIABLE, CMD_GET_ROUTE_VARIABLE, CMD_GET_SIM_VARIABLE, CMD_GET_TL_VARIABLE, CMD_GET_VEHICLE_VARIABLE, CMD_GET_VEHICLETYPE_VARIABLE, CMD_SET_EDGE_VARIABLE, CMD_SET_LANE_VARIABLE, CMD_SET_PERSON_VARIABLE, CMD_SET_POI_VARIABLE, CMD_SET_POLYGON_VARIABLE, CMD_SET_ROUTE_VARIABLE, CMD_SET_SIM_VARIABLE, CMD_SET_TL_VARIABLE, CMD_SET_VEHICLE_VARIABLE, CMD_SET_VEHICLETYPE_VARIABLE, MsgHandler::getWarningInstance(), MSGlobals::gUsingInternalLanes, MsgHandler::inform(), MAX_ORDER, myAmEmbedded, myCurrentSocket, myDoCloseConnection, myExecutors, myParameterSizes, myServerSocket, mySockets, myVehicleStateChanges, TraCIServerAPI_Edge::processGet(), TraCIServerAPI_InductionLoop::processGet(), TraCIServerAPI_Route::processGet(), TraCIServerAPI_MultiEntryExit::processGet(), TraCIServerAPI_VehicleType::processGet(), TraCIServerAPI_POI::processGet(), TraCIServerAPI_Polygon::processGet(), TraCIServerAPI_TrafficLight::processGet(), TraCIServerAPI_Vehicle::processGet(), TraCIServerAPI_Simulation::processGet(), TraCIServerAPI_Person::processGet(), TraCIServerAPI_LaneArea::processGet(), TraCIServerAPI_Lane::processGet(), TraCIServerAPI_Junction::processGet(), TraCIServerAPI_Edge::processSet(), TraCIServerAPI_Polygon::processSet(), TraCIServerAPI_Route::processSet(), TraCIServerAPI_POI::processSet(), TraCIServerAPI_TrafficLight::processSet(), TraCIServerAPI_VehicleType::processSet(), TraCIServerAPI_Vehicle::processSet(), TraCIServerAPI_Simulation::processSet(), TraCIServerAPI_Person::processSet(), TraCIServerAPI_Lane::processSet(), toString(), VAR_LEADER, MSNet::VEHICLE_STATE_ARRIVED, MSNet::VEHICLE_STATE_BUILT, MSNet::VEHICLE_STATE_COLLISION, MSNet::VEHICLE_STATE_DEPARTED, MSNet::VEHICLE_STATE_EMERGENCYSTOP, MSNet::VEHICLE_STATE_ENDING_PARKING, MSNet::VEHICLE_STATE_ENDING_STOP, MSNet::VEHICLE_STATE_ENDING_TELEPORT, MSNet::VEHICLE_STATE_NEWROUTE, MSNet::VEHICLE_STATE_STARTING_PARKING, MSNet::VEHICLE_STATE_STARTING_STOP, MSNet::VEHICLE_STATE_STARTING_TELEPORT, WRITE_MESSAGE, and WRITE_WARNING.
Referenced by getLoadArgs(), and openSocket().
|
privatevirtual |
Destructor.
Definition at line 265 of file TraCIServer.cpp.
References cleanup(), myCurrentSocket, myServerSocket, and mySockets.
Referenced by getLoadArgs().
|
private |
Definition at line 1265 of file TraCIServer.cpp.
References initialiseSubscription(), INVALID_DOUBLE_VALUE, myInputStorage, myParameterSizes, tcpip::Storage::readChar(), tcpip::Storage::readDouble(), tcpip::Storage::readString(), tcpip::Storage::readUnsignedByte(), removeSubscription(), STEPS2TIME, SUMOTime_MAX, and TIME2STEPS.
Referenced by dispatchCommand().
|
private |
Definition at line 1298 of file TraCIServer.cpp.
References addSubscriptionFilterDownstreamDistance(), addSubscriptionFilterLanes(), addSubscriptionFilterLeadFollow(), addSubscriptionFilterNoOpposite(), addSubscriptionFilterTurn(), addSubscriptionFilterUpstreamDistance(), addSubscriptionFilterVClass(), addSubscriptionFilterVType(), CMD_ADD_SUBSCRIPTION_FILTER, FILTER_TYPE_DOWNSTREAM_DIST, FILTER_TYPE_LANES, FILTER_TYPE_LEAD_FOLLOW, FILTER_TYPE_NONE, FILTER_TYPE_NOOPPOSITE, FILTER_TYPE_TURN, FILTER_TYPE_UPSTREAM_DIST, FILTER_TYPE_VCLASS, FILTER_TYPE_VTYPE, myInputStorage, myLastContextSubscription, parseVehicleClasses(), tcpip::Storage::readByte(), tcpip::Storage::readDouble(), tcpip::Storage::readStringList(), tcpip::Storage::readUnsignedByte(), removeFilters(), RTYPE_NOTIMPLEMENTED, RTYPE_OK, toString(), WRITE_WARNING, and writeStatusCmd().
Referenced by dispatchCommand().
|
private |
Definition at line 1401 of file TraCIServer.cpp.
References libsumo::Subscription::activeFilters, libsumo::Subscription::filterDownstreamDist, myLastContextSubscription, libsumo::SUBS_FILTER_DOWNSTREAM_DIST, and toString().
Referenced by addSubscriptionFilter().
|
private |
Definition at line 1384 of file TraCIServer.cpp.
References libsumo::Subscription::activeFilters, libsumo::Subscription::filterLanes, myLastContextSubscription, libsumo::SUBS_FILTER_LANES, and toString().
Referenced by addSubscriptionFilter().
|
private |
Definition at line 1419 of file TraCIServer.cpp.
References libsumo::Subscription::activeFilters, myLastContextSubscription, and libsumo::SUBS_FILTER_LEAD_FOLLOW.
Referenced by addSubscriptionFilter().
|
private |
Definition at line 1393 of file TraCIServer.cpp.
References libsumo::Subscription::activeFilters, myLastContextSubscription, and libsumo::SUBS_FILTER_NOOPPOSITE.
Referenced by addSubscriptionFilter().
|
private |
Definition at line 1427 of file TraCIServer.cpp.
References libsumo::Subscription::activeFilters, myLastContextSubscription, and libsumo::SUBS_FILTER_TURN.
Referenced by addSubscriptionFilter().
|
private |
Definition at line 1410 of file TraCIServer.cpp.
References libsumo::Subscription::activeFilters, libsumo::Subscription::filterUpstreamDist, myLastContextSubscription, libsumo::SUBS_FILTER_UPSTREAM_DIST, and toString().
Referenced by addSubscriptionFilter().
|
private |
Definition at line 1435 of file TraCIServer.cpp.
References libsumo::Subscription::activeFilters, libsumo::Subscription::filterVClasses, myLastContextSubscription, libsumo::SUBS_FILTER_VCLASS, and toString().
Referenced by addSubscriptionFilter().
|
private |
Definition at line 1444 of file TraCIServer.cpp.
References libsumo::Subscription::activeFilters, libsumo::Subscription::filterVTypes, myLastContextSubscription, libsumo::SUBS_FILTER_VTYPE, and toString().
Referenced by addSubscriptionFilter().
|
private |
check whether a found objID refers to the central object of a context subscription
Definition at line 1597 of file TraCIServer.cpp.
References libsumo::Subscription::commandId, libsumo::Subscription::contextDomain, and libsumo::Subscription::id.
|
private |
Called once after connection of all clients for executing SET_ORDER (and possibly prior GET_VERSION) commands, that should be executed before simulation starts (in processCommandsUntilNextSimStep()).
Definition at line 331 of file TraCIServer.cpp.
References CMD_GETVERSION, CMD_SETORDER, dispatchCommand(), myCurrentSocket, myInputStorage, myOutputStorage, mySockets, readCommandID(), tcpip::Storage::reset(), tcpip::Storage::writeStorage(), and tcpip::Storage::writeUnsignedByte().
Referenced by TraCIServer().
void TraCIServer::cleanup | ( | ) |
clean up subscriptions
Definition at line 644 of file TraCIServer.cpp.
References tcpip::Storage::begin(), dispatchCommand(), tcpip::Storage::end(), FileHelpers::getFilePath(), OptionsCont::getOptions(), myCurrentSocket, myInputStorage, myInstance, myOutputStorage, mySockets, mySubscriptionCache, mySubscriptions, myTargetTime, myVehicleStateChanges, tcpip::Storage::reset(), string2time(), and tcpip::Storage::writeChar().
Referenced by MSNet::clearAll(), getInstance(), and ~TraCIServer().
|
static |
request termination of connection
Definition at line 298 of file TraCIServer.cpp.
References myDoCloseConnection, and myInstance.
Referenced by getInstance(), and main().
|
private |
Returns the TraCI-version.
Definition at line 947 of file TraCIServer.cpp.
References CMD_GETVERSION, myOutputStorage, RTYPE_OK, tcpip::Storage::size(), TRACI_VERSION, VERSION_STRING, tcpip::Storage::writeInt(), writeStatusCmd(), tcpip::Storage::writeStorage(), tcpip::Storage::writeString(), and tcpip::Storage::writeUnsignedByte().
Referenced by dispatchCommand().
|
private |
Handles command, writes response to myOutputStorage.
Definition at line 784 of file TraCIServer.cpp.
References addObjectVariableSubscription(), addSubscriptionFilter(), CMD_ADD_SUBSCRIPTION_FILTER, CMD_CLOSE, CMD_GET_GUI_VARIABLE, CMD_GETVERSION, CMD_LOAD, CMD_SET_GUI_VARIABLE, CMD_SETORDER, CMD_SIMSTEP, CMD_SUBSCRIBE_EDGE_CONTEXT, CMD_SUBSCRIBE_EDGE_VARIABLE, CMD_SUBSCRIBE_GUI_CONTEXT, CMD_SUBSCRIBE_GUI_VARIABLE, CMD_SUBSCRIBE_INDUCTIONLOOP_CONTEXT, CMD_SUBSCRIBE_INDUCTIONLOOP_VARIABLE, CMD_SUBSCRIBE_JUNCTION_CONTEXT, CMD_SUBSCRIBE_JUNCTION_VARIABLE, CMD_SUBSCRIBE_LANE_CONTEXT, CMD_SUBSCRIBE_LANE_VARIABLE, CMD_SUBSCRIBE_LANEAREA_CONTEXT, CMD_SUBSCRIBE_LANEAREA_VARIABLE, CMD_SUBSCRIBE_MULTIENTRYEXIT_CONTEXT, CMD_SUBSCRIBE_MULTIENTRYEXIT_VARIABLE, CMD_SUBSCRIBE_PERSON_CONTEXT, CMD_SUBSCRIBE_PERSON_VARIABLE, CMD_SUBSCRIBE_POI_CONTEXT, CMD_SUBSCRIBE_POI_VARIABLE, CMD_SUBSCRIBE_POLYGON_CONTEXT, CMD_SUBSCRIBE_POLYGON_VARIABLE, CMD_SUBSCRIBE_ROUTE_CONTEXT, CMD_SUBSCRIBE_ROUTE_VARIABLE, CMD_SUBSCRIBE_SIM_CONTEXT, CMD_SUBSCRIBE_SIM_VARIABLE, CMD_SUBSCRIBE_TL_CONTEXT, CMD_SUBSCRIBE_TL_VARIABLE, CMD_SUBSCRIBE_VEHICLE_CONTEXT, CMD_SUBSCRIBE_VEHICLE_VARIABLE, CMD_SUBSCRIBE_VEHICLETYPE_CONTEXT, CMD_SUBSCRIBE_VEHICLETYPE_VARIABLE, commandGetVersion(), DELTA_T, MSNet::getCurrentTimeStep(), MSNet::getInstance(), MAX_ORDER, myAmEmbedded, myCurrentSocket, myDoCloseConnection, myExecutors, myInputStorage, myLoadArgs, myOutputStorage, mySocketReorderRequests, mySockets, myTargetTime, myVehicleStateChanges, tcpip::Storage::position(), postProcessSimulationStep(), tcpip::Storage::readChar(), readCommandID(), tcpip::Storage::readDouble(), tcpip::Storage::readInt(), readTypeCheckingStringList(), tcpip::Storage::reset(), RTYPE_ERR, RTYPE_NOTIMPLEMENTED, RTYPE_OK, sendSingleSimStepResponse(), MSNet::simulationStep(), TIME2STEPS, toString(), tcpip::Storage::valid_pos(), writeErrorStatusCmd(), and writeStatusCmd().
Referenced by checkClientOrdering(), cleanup(), and processCommandsUntilSimStep().
|
private |
|
inlinestatic |
Definition at line 73 of file TraCIServer.h.
References cleanup(), close(), myInstance, openSocket(), processCommandsUntilSimStep(), vehicleStateChanged(), wasClosed(), writeErrorStatusCmd(), and writeStatusCmd().
Referenced by NLBuilder::build(), MSNet::clearAll(), GUIRunThread::makeStep(), MSNet::postSimStepOutput(), MSNet::simulate(), MSNet::simulationState(), and MSNet::simulationStep().
|
inline |
Definition at line 252 of file TraCIServer.h.
References getWrapperStorage(), initWrapper(), myLoadArgs, TraCIServer(), wrapColor(), wrapDouble(), wrapInt(), wrapPosition(), wrapString(), wrapStringList(), and ~TraCIServer().
Referenced by GUIRunThread::makeStep(), and MSNet::simulate().
|
inline |
Definition at line 67 of file TraCIServer.h.
References myTargetTime.
Referenced by MSNet::simulationStep().
|
inline |
Definition at line 146 of file TraCIServer.h.
References myAmEmbedded, myCurrentSocket, mySockets, myVehicleStateChanges, readTypeCheckingByte(), readTypeCheckingColor(), readTypeCheckingDouble(), readTypeCheckingInt(), readTypeCheckingPolygon(), readTypeCheckingPosition2D(), readTypeCheckingString(), readTypeCheckingStringList(), readTypeCheckingUnsignedByte(), setTargetTime(), writePositionVector(), and writeResponseWithLength().
Referenced by TraCIServerAPI_Simulation::writeVehicleStateIDs(), and TraCIServerAPI_Simulation::writeVehicleStateNumber().
tcpip::Storage & TraCIServer::getWrapperStorage | ( | ) |
Definition at line 171 of file TraCIServer.cpp.
References myWrapperStorage.
Referenced by getLoadArgs(), TraCIServerAPI_Edge::processGet(), TraCIServerAPI_VehicleType::processGet(), TraCIServerAPI_POI::processGet(), TraCIServerAPI_Polygon::processGet(), TraCIServerAPI_Route::processGet(), TraCIServerAPI_InductionLoop::processGet(), TraCIServerAPI_TrafficLight::processGet(), TraCIServerAPI_MultiEntryExit::processGet(), TraCIServerAPI_Vehicle::processGet(), TraCIServerAPI_Simulation::processGet(), TraCIServerAPI_Person::processGet(), TraCIServerAPI_LaneArea::processGet(), TraCIServerAPI_Lane::processGet(), and TraCIServerAPI_Junction::processGet().
|
private |
Definition at line 1073 of file TraCIServer.cpp.
References libsumo::Subscription::beginTime, libsumo::Subscription::commandId, libsumo::Subscription::contextDomain, libsumo::Subscription::endTime, MSNet::getCurrentTimeStep(), MSNet::getInstance(), libsumo::Subscription::id, isVehicleToVehicleContextSubscription(), myLastContextSubscription, myOutputStorage, mySubscriptionCache, mySubscriptions, libsumo::Subscription::parameters, processSingleSubscription(), libsumo::Subscription::range, tcpip::Storage::readByte(), tcpip::Storage::readInt(), tcpip::Storage::reset(), RTYPE_ERR, RTYPE_OK, tcpip::Storage::size(), tcpip::Storage::valid_pos(), libsumo::Subscription::variables, tcpip::Storage::writeByte(), tcpip::Storage::writeInt(), writeStatusCmd(), and tcpip::Storage::writeStorage().
Referenced by addObjectVariableSubscription().
void TraCIServer::initWrapper | ( | const int | domainID, |
const int | variable, | ||
const std::string & | objID | ||
) |
Definition at line 106 of file TraCIServer.cpp.
References myWrapperStorage, tcpip::Storage::reset(), tcpip::Storage::writeString(), and tcpip::Storage::writeUnsignedByte().
Referenced by getLoadArgs(), TraCIServerAPI_Edge::processGet(), TraCIServerAPI_VehicleType::processGet(), TraCIServerAPI_POI::processGet(), TraCIServerAPI_Polygon::processGet(), TraCIServerAPI_Route::processGet(), TraCIServerAPI_InductionLoop::processGet(), TraCIServerAPI_TrafficLight::processGet(), TraCIServerAPI_MultiEntryExit::processGet(), TraCIServerAPI_Vehicle::processGet(), TraCIServerAPI_Simulation::processGet(), TraCIServerAPI_Person::processGet(), TraCIServerAPI_LaneArea::processGet(), TraCIServerAPI_Lane::processGet(), and TraCIServerAPI_Junction::processGet().
|
inline |
Definition at line 70 of file TraCIServer.h.
References myAmEmbedded.
Referenced by MSNet::simulationStep().
|
private |
Definition at line 1157 of file TraCIServer.cpp.
References CMD_GET_VEHICLE_VARIABLE, CMD_SUBSCRIBE_VEHICLE_CONTEXT, libsumo::Subscription::commandId, and libsumo::Subscription::contextDomain.
Referenced by initialiseSubscription().
|
private |
get the minimal next target time among all clients
Definition at line 440 of file TraCIServer.cpp.
References MIN2(), and mySockets.
Referenced by processCommandsUntilSimStep().
|
static |
Initialises the server.
[in] | execs | The (additional) command executors to use |
Definition at line 276 of file TraCIServer.cpp.
References MSNet::addVehicleStateListener(), MSNet::getInstance(), OptionsCont::getOptions(), myDoCloseConnection, myExecutors, myInstance, mySubscriptionCache, string2time(), TraCIServer(), and tcpip::Storage::writeInt().
Referenced by getInstance(), NLBuilder::init(), and GUILoadThread::run().
|
private |
Invalidated assignment operator.
|
private |
Handles subscriptions to send after a simstep2 command.
Definition at line 966 of file TraCIServer.cpp.
References libsumo::Subscription::beginTime, CMD_SIMSTEP, CMD_SUBSCRIBE_PERSON_CONTEXT, CMD_SUBSCRIBE_PERSON_VARIABLE, CMD_SUBSCRIBE_VEHICLE_CONTEXT, CMD_SUBSCRIBE_VEHICLE_VARIABLE, libsumo::Subscription::commandId, libsumo::Subscription::endTime, MSTransportableControl::get(), MSNet::getCurrentTimeStep(), MSNet::getInstance(), MSNet::getPersonControl(), libsumo::Subscription::id, myOutputStorage, mySubscriptionCache, mySubscriptions, myVehicleStateChanges, processSingleSubscription(), tcpip::Storage::reset(), RTYPE_OK, tcpip::Storage::size(), MSNet::VEHICLE_STATE_ARRIVED, tcpip::Storage::writeInt(), writeStatusCmd(), and tcpip::Storage::writeStorage().
Referenced by dispatchCommand(), and processCommandsUntilSimStep().
void TraCIServer::processCommandsUntilSimStep | ( | SUMOTime | step | ) |
process all commands until the next SUMO simulation step. It is guaranteed that t->getTargetTime() >= myStep after call (except the case that a load or close command is received)s
Definition at line 486 of file TraCIServer.cpp.
References CMD_CLOSE, CMD_LOAD, CMD_SIMSTEP, dispatchCommand(), MSNet::getInstance(), myAmEmbedded, myCurrentSocket, myDoCloseConnection, myInputStorage, myLoadArgs, myOutputStorage, mySockets, myTargetTime, myVehicleStateChanges, nextTargetTime(), postProcessSimulationStep(), processReorderingRequests(), removeCurrentSocket(), tcpip::Storage::reset(), sendOutputToAll(), SIMTIME, tcpip::Storage::size(), and tcpip::Storage::valid_pos().
Referenced by getInstance(), and MSNet::simulationStep().
|
private |
checks for and processes reordering requests (relevant for multiple clients)
Definition at line 396 of file TraCIServer.cpp.
References mySocketReorderRequests, mySockets, and SIMTIME.
Referenced by processCommandsUntilSimStep().
|
private |
Definition at line 1163 of file TraCIServer.cpp.
References libsumo::Subscription::activeFilters, libsumo::Helper::applySubscriptionFilters(), libsumo::Helper::collectObjectsInRange(), libsumo::Subscription::commandId, libsumo::Subscription::contextDomain, libsumo::Helper::findObjectShape(), libsumo::Subscription::id, myExecutors, libsumo::Subscription::parameters, libsumo::Subscription::range, tcpip::Storage::readInt(), tcpip::Storage::readString(), tcpip::Storage::readUnsignedByte(), RTYPE_ERR, RTYPE_NOTIMPLEMENTED, RTYPE_OK, tcpip::Storage::size(), libsumo::SUBS_FILTER_NO_RTREE, TRACI_ID_LIST, TYPE_STRING, libsumo::Subscription::variables, tcpip::Storage::writeInt(), tcpip::Storage::writePacket(), writeStatusCmd(), tcpip::Storage::writeStorage(), tcpip::Storage::writeString(), and tcpip::Storage::writeUnsignedByte().
Referenced by initialiseSubscription(), and postProcessSimulationStep().
|
private |
Reads the next command ID from the input storage.
[out] | the | version with reference parameters provides information on the command start position and length used in dispatchCommand for checking purposes |
Definition at line 773 of file TraCIServer.cpp.
References myInputStorage, tcpip::Storage::position(), tcpip::Storage::readInt(), and tcpip::Storage::readUnsignedByte().
Referenced by checkClientOrdering(), and dispatchCommand().
bool TraCIServer::readTypeCheckingByte | ( | tcpip::Storage & | inputStorage, |
int & | into | ||
) |
Reads the value type and a byte, verifying the type.
Definition at line 1546 of file TraCIServer.cpp.
References tcpip::Storage::readByte(), and TYPE_BYTE.
Referenced by getVehicleStateChanges(), TraCIServerAPI_Vehicle::processSet(), and TraCIServerAPI_Person::processSet().
bool TraCIServer::readTypeCheckingColor | ( | tcpip::Storage & | inputStorage, |
libsumo::TraCIColor & | into | ||
) |
Reads the value type and a color, verifying the type.
Definition at line 1521 of file TraCIServer.cpp.
References libsumo::TraCIColor::a, libsumo::TraCIColor::b, libsumo::TraCIColor::g, libsumo::TraCIColor::r, tcpip::Storage::readUnsignedByte(), and TYPE_COLOR.
Referenced by getVehicleStateChanges(), TraCIServerAPI_Polygon::processSet(), TraCIServerAPI_POI::processSet(), TraCIServerAPI_Vehicle::processSet(), TraCIServerAPI_Person::processSet(), and TraCIServerAPI_VehicleType::setVariable().
bool TraCIServer::readTypeCheckingDouble | ( | tcpip::Storage & | inputStorage, |
double & | into | ||
) |
Reads the value type and a double, verifying the type.
Definition at line 1491 of file TraCIServer.cpp.
References tcpip::Storage::readDouble(), tcpip::Storage::readUnsignedByte(), and TYPE_DOUBLE.
Referenced by getVehicleStateChanges(), TraCIServerAPI_Edge::processGet(), TraCIServerAPI_Vehicle::processGet(), TraCIServerAPI_Simulation::processGet(), TraCIServerAPI_Edge::processSet(), TraCIServerAPI_TrafficLight::processSet(), TraCIServerAPI_Polygon::processSet(), TraCIServerAPI_GUI::processSet(), TraCIServerAPI_Vehicle::processSet(), TraCIServerAPI_Person::processSet(), TraCIServerAPI_Lane::processSet(), and TraCIServerAPI_VehicleType::setVariable().
bool TraCIServer::readTypeCheckingInt | ( | tcpip::Storage & | inputStorage, |
int & | into | ||
) |
Reads the value type and an int, verifying the type.
Definition at line 1481 of file TraCIServer.cpp.
References tcpip::Storage::readInt(), tcpip::Storage::readUnsignedByte(), and TYPE_INTEGER.
Referenced by getVehicleStateChanges(), TraCIServerAPI_Vehicle::processGet(), TraCIServerAPI_Simulation::processGet(), TraCIServerAPI_Person::processGet(), TraCIServerAPI_POI::processSet(), TraCIServerAPI_TrafficLight::processSet(), TraCIServerAPI_Polygon::processSet(), TraCIServerAPI_Vehicle::processSet(), TraCIServerAPI_GUI::processSet(), and TraCIServerAPI_Person::processSet().
bool TraCIServer::readTypeCheckingPolygon | ( | tcpip::Storage & | inputStorage, |
PositionVector & | into | ||
) |
Reads the value type and a polygon, verifying the type.
Definition at line 1566 of file TraCIServer.cpp.
References tcpip::Storage::readDouble(), tcpip::Storage::readInt(), tcpip::Storage::readUnsignedByte(), and TYPE_POLYGON.
Referenced by getVehicleStateChanges(), TraCIServerAPI_Polygon::processSet(), and TraCIServerAPI_GUI::processSet().
bool TraCIServer::readTypeCheckingPosition2D | ( | tcpip::Storage & | inputStorage, |
libsumo::TraCIPosition & | into | ||
) |
Reads the value type and a 2D position, verifying the type.
Definition at line 1534 of file TraCIServer.cpp.
References POSITION_2D, tcpip::Storage::readDouble(), tcpip::Storage::readUnsignedByte(), libsumo::TraCIPosition::x, libsumo::TraCIPosition::y, and libsumo::TraCIPosition::z.
Referenced by getVehicleStateChanges(), TraCIServerAPI_POI::processSet(), and TraCIServerAPI_GUI::processSet().
bool TraCIServer::readTypeCheckingString | ( | tcpip::Storage & | inputStorage, |
std::string & | into | ||
) |
Reads the value type and a string, verifying the type.
Definition at line 1501 of file TraCIServer.cpp.
References tcpip::Storage::readString(), tcpip::Storage::readUnsignedByte(), and TYPE_STRING.
Referenced by getVehicleStateChanges(), TraCIServerAPI_Edge::processGet(), TraCIServerAPI_POI::processGet(), TraCIServerAPI_TrafficLight::processGet(), TraCIServerAPI_Polygon::processGet(), TraCIServerAPI_VehicleType::processGet(), TraCIServerAPI_Route::processGet(), TraCIServerAPI_Vehicle::processGet(), TraCIServerAPI_Simulation::processGet(), TraCIServerAPI_Person::processGet(), TraCIServerAPI_Lane::processGet(), TraCIServerAPI_Edge::processSet(), TraCIServerAPI_POI::processSet(), TraCIServerAPI_TrafficLight::processSet(), TraCIServerAPI_Polygon::processSet(), TraCIServerAPI_Route::processSet(), TraCIServerAPI_GUI::processSet(), TraCIServerAPI_Vehicle::processSet(), TraCIServerAPI_Simulation::processSet(), TraCIServerAPI_Person::processSet(), TraCIServerAPI_Lane::processSet(), and TraCIServerAPI_VehicleType::setVariable().
bool TraCIServer::readTypeCheckingStringList | ( | tcpip::Storage & | inputStorage, |
std::vector< std::string > & | into | ||
) |
Reads the value type and a string list, verifying the type.
Definition at line 1511 of file TraCIServer.cpp.
References tcpip::Storage::readStringList(), tcpip::Storage::readUnsignedByte(), and TYPE_STRINGLIST.
Referenced by dispatchCommand(), getVehicleStateChanges(), TraCIServerAPI_Edge::processSet(), TraCIServerAPI_Route::processSet(), TraCIServerAPI_TrafficLight::processSet(), TraCIServerAPI_Vehicle::processSet(), TraCIServerAPI_Person::processSet(), and TraCIServerAPI_Lane::processSet().
bool TraCIServer::readTypeCheckingUnsignedByte | ( | tcpip::Storage & | inputStorage, |
int & | into | ||
) |
Reads the value type and an unsigned byte, verifying the type.
Definition at line 1556 of file TraCIServer.cpp.
References tcpip::Storage::readUnsignedByte(), and TYPE_UBYTE.
Referenced by TraCIServerAPI_Simulation::commandPositionConversion(), getVehicleStateChanges(), and TraCIServerAPI_Polygon::processSet().
|
private |
removes myCurrentSocket from mySockets and returns an iterator pointing to the next member according to the ordering
Definition at line 743 of file TraCIServer.cpp.
References myCurrentSocket, and mySockets.
Referenced by processCommandsUntilSimStep().
|
private |
Definition at line 1376 of file TraCIServer.cpp.
References libsumo::Subscription::activeFilters, myLastContextSubscription, and libsumo::SUBS_FILTER_NONE.
Referenced by addSubscriptionFilter().
|
private |
Definition at line 1133 of file TraCIServer.cpp.
References myLastContextSubscription, mySubscriptions, RTYPE_ERR, RTYPE_OK, and writeStatusCmd().
Referenced by addObjectVariableSubscription().
|
private |
send out subscription results (actually just the content of myOutputStorage) to clients which will act in this step (i.e. with client target time <= myTargetTime)
Definition at line 464 of file TraCIServer.cpp.
References MSNet::getCurrentTimeStep(), MSNet::getInstance(), myOutputStorage, and mySockets.
Referenced by processCommandsUntilSimStep().
|
private |
sends an empty response to a simstep command to the current client. (This applies to a situation where the TraCI step frequency is higher than the SUMO step frequency)
Definition at line 1025 of file TraCIServer.cpp.
References CMD_SIMSTEP, myCurrentSocket, myOutputStorage, mySubscriptionCache, tcpip::Storage::reset(), RTYPE_OK, tcpip::Storage::size(), writeStatusCmd(), and tcpip::Storage::writeStorage().
Referenced by dispatchCommand().
|
inlinevirtualinherited |
Reimplemented in libsumo::Helper::SubscriptionWrapper.
Definition at line 120 of file Subscription.h.
void TraCIServer::setTargetTime | ( | SUMOTime | targetTime | ) |
Sets myTargetTime on server and sockets to the given value.
Definition at line 1589 of file TraCIServer.cpp.
References mySockets, and myTargetTime.
Referenced by NLBuilder::build(), and getVehicleStateChanges().
|
virtual |
Called if a vehicle changes its state.
[in] | vehicle | The vehicle which changed its state |
[in] | to | The state the vehicle has changed to |
[in] | info | Additional information on the state change |
Implements MSNet::VehicleStateListener.
Definition at line 318 of file TraCIServer.cpp.
References SUMOVehicle::getID(), myAmEmbedded, myDoCloseConnection, mySockets, and myVehicleStateChanges.
Referenced by getInstance().
|
static |
check whether close was requested
Definition at line 309 of file TraCIServer.cpp.
References myDoCloseConnection.
Referenced by getInstance(), GUIRunThread::makeStep(), MSNet::simulate(), MSNet::simulationState(), and MSNet::simulationStep().
|
virtual |
Implements libsumo::VariableWrapper.
Definition at line 160 of file TraCIServer.cpp.
References libsumo::TraCIColor::a, libsumo::TraCIColor::b, libsumo::TraCIColor::g, myWrapperStorage, libsumo::TraCIColor::r, TYPE_COLOR, and tcpip::Storage::writeUnsignedByte().
Referenced by getLoadArgs().
|
virtual |
Implements libsumo::VariableWrapper.
Definition at line 115 of file TraCIServer.cpp.
References myWrapperStorage, TYPE_DOUBLE, tcpip::Storage::writeDouble(), and tcpip::Storage::writeUnsignedByte().
Referenced by getLoadArgs().
|
virtual |
Implements libsumo::VariableWrapper.
Definition at line 123 of file TraCIServer.cpp.
References myWrapperStorage, TYPE_INTEGER, tcpip::Storage::writeInt(), and tcpip::Storage::writeUnsignedByte().
Referenced by getLoadArgs().
|
virtual |
Implements libsumo::VariableWrapper.
Definition at line 147 of file TraCIServer.cpp.
References myWrapperStorage, POSITION_2D, POSITION_3D, VAR_POSITION3D, tcpip::Storage::writeDouble(), tcpip::Storage::writeUnsignedByte(), libsumo::TraCIPosition::x, libsumo::TraCIPosition::y, and libsumo::TraCIPosition::z.
Referenced by getLoadArgs().
|
virtual |
Implements libsumo::VariableWrapper.
Definition at line 131 of file TraCIServer.cpp.
References myWrapperStorage, TYPE_STRING, tcpip::Storage::writeString(), and tcpip::Storage::writeUnsignedByte().
Referenced by getLoadArgs().
|
virtual |
Implements libsumo::VariableWrapper.
Definition at line 139 of file TraCIServer.cpp.
References myWrapperStorage, TYPE_STRINGLIST, tcpip::Storage::writeStringList(), and tcpip::Storage::writeUnsignedByte().
Referenced by getLoadArgs().
bool TraCIServer::writeErrorStatusCmd | ( | int | commandId, |
const std::string & | description, | ||
tcpip::Storage & | outputStorage | ||
) |
Writes a status command to the given storage with status = RTYPE_ERR.
[in] | commandId | The id of the command to respond to |
[in] | description | The status description (error message, for example) |
Definition at line 1066 of file TraCIServer.cpp.
References RTYPE_ERR, and writeStatusCmd().
Referenced by dispatchCommand(), getInstance(), TraCIServerAPI_Edge::processGet(), TraCIServerAPI_Polygon::processGet(), TraCIServerAPI_Route::processGet(), TraCIServerAPI_TrafficLight::processGet(), TraCIServerAPI_MultiEntryExit::processGet(), TraCIServerAPI_VehicleType::processGet(), TraCIServerAPI_InductionLoop::processGet(), TraCIServerAPI_POI::processGet(), TraCIServerAPI_GUI::processGet(), TraCIServerAPI_Vehicle::processGet(), TraCIServerAPI_Simulation::processGet(), TraCIServerAPI_Person::processGet(), TraCIServerAPI_LaneArea::processGet(), TraCIServerAPI_Lane::processGet(), TraCIServerAPI_Junction::processGet(), TraCIServerAPI_Edge::processSet(), TraCIServerAPI_POI::processSet(), TraCIServerAPI_Polygon::processSet(), TraCIServerAPI_TrafficLight::processSet(), TraCIServerAPI_Route::processSet(), TraCIServerAPI_VehicleType::processSet(), TraCIServerAPI_Vehicle::processSet(), TraCIServerAPI_GUI::processSet(), TraCIServerAPI_Simulation::processSet(), TraCIServerAPI_Person::processSet(), TraCIServerAPI_Lane::processSet(), and TraCIServerAPI_VehicleType::setVariable().
void TraCIServer::writePositionVector | ( | tcpip::Storage & | outputStorage, |
const libsumo::TraCIPositionVector & | shape | ||
) |
Definition at line 1465 of file TraCIServer.cpp.
References TYPE_POLYGON, tcpip::Storage::writeDouble(), tcpip::Storage::writeInt(), and tcpip::Storage::writeUnsignedByte().
Referenced by getVehicleStateChanges(), TraCIServerAPI_Polygon::processGet(), TraCIServerAPI_Lane::processGet(), and TraCIServerAPI_Junction::processGet().
void TraCIServer::writeResponseWithLength | ( | tcpip::Storage & | outputStorage, |
tcpip::Storage & | tempMsg | ||
) |
Definition at line 1453 of file TraCIServer.cpp.
References tcpip::Storage::size(), tcpip::Storage::writeInt(), tcpip::Storage::writeStorage(), and tcpip::Storage::writeUnsignedByte().
Referenced by getVehicleStateChanges(), TraCIServerAPI_Edge::processGet(), TraCIServerAPI_VehicleType::processGet(), TraCIServerAPI_InductionLoop::processGet(), TraCIServerAPI_MultiEntryExit::processGet(), TraCIServerAPI_POI::processGet(), TraCIServerAPI_Polygon::processGet(), TraCIServerAPI_Route::processGet(), TraCIServerAPI_TrafficLight::processGet(), TraCIServerAPI_Vehicle::processGet(), TraCIServerAPI_GUI::processGet(), TraCIServerAPI_Simulation::processGet(), TraCIServerAPI_Person::processGet(), TraCIServerAPI_LaneArea::processGet(), TraCIServerAPI_Lane::processGet(), and TraCIServerAPI_Junction::processGet().
void TraCIServer::writeStatusCmd | ( | int | commandId, |
int | status, | ||
const std::string & | description, | ||
tcpip::Storage & | outputStorage | ||
) |
Writes a status command to the given storage.
[in] | commandId | The id of the command to respond to |
[in] | status | The status to send |
[in] | description | The status description (error message, for example) |
Definition at line 1052 of file TraCIServer.cpp.
References RTYPE_ERR, RTYPE_NOTIMPLEMENTED, toHex(), WRITE_ERROR, tcpip::Storage::writeString(), and tcpip::Storage::writeUnsignedByte().
Referenced by addSubscriptionFilter(), TraCIServerAPI_Simulation::commandDistanceRequest(), commandGetVersion(), TraCIServerAPI_Simulation::commandPositionConversion(), dispatchCommand(), getInstance(), initialiseSubscription(), postProcessSimulationStep(), TraCIServerAPI_Edge::processGet(), TraCIServerAPI_InductionLoop::processGet(), TraCIServerAPI_TrafficLight::processGet(), TraCIServerAPI_VehicleType::processGet(), TraCIServerAPI_MultiEntryExit::processGet(), TraCIServerAPI_POI::processGet(), TraCIServerAPI_Polygon::processGet(), TraCIServerAPI_Route::processGet(), TraCIServerAPI_Vehicle::processGet(), TraCIServerAPI_GUI::processGet(), TraCIServerAPI_Simulation::processGet(), TraCIServerAPI_Person::processGet(), TraCIServerAPI_LaneArea::processGet(), TraCIServerAPI_Lane::processGet(), TraCIServerAPI_Junction::processGet(), TraCIServerAPI_Edge::processSet(), TraCIServerAPI_VehicleType::processSet(), TraCIServerAPI_TrafficLight::processSet(), TraCIServerAPI_Route::processSet(), TraCIServerAPI_POI::processSet(), TraCIServerAPI_Polygon::processSet(), TraCIServerAPI_GUI::processSet(), TraCIServerAPI_Vehicle::processSet(), TraCIServerAPI_Simulation::processSet(), TraCIServerAPI_Person::processSet(), TraCIServerAPI_Lane::processSet(), processSingleSubscription(), removeSubscription(), sendSingleSimStepResponse(), writeErrorStatusCmd(), and writeStatusCmd().
void TraCIServer::writeStatusCmd | ( | int | commandId, |
int | status, | ||
const std::string & | description | ||
) |
Writes a status command to myOutputStorage.
[in] | commandId | The id of the command to respond to |
[in] | status | The status to send |
[in] | description | The status description (error message, for example) |
Definition at line 1046 of file TraCIServer.cpp.
References myOutputStorage, and writeStatusCmd().
|
inherited |
Definition at line 119 of file Subscription.h.
|
private |
Whether the server runs in embedded mode.
Definition at line 379 of file TraCIServer.h.
Referenced by dispatchCommand(), getVehicleStateChanges(), isEmbedded(), processCommandsUntilSimStep(), TraCIServer(), and vehicleStateChanged().
|
private |
The currently active client socket.
Definition at line 361 of file TraCIServer.h.
Referenced by checkClientOrdering(), cleanup(), dispatchCommand(), getVehicleStateChanges(), processCommandsUntilSimStep(), removeCurrentSocket(), sendSingleSimStepResponse(), TraCIServer(), and ~TraCIServer().
|
staticprivate |
Whether the connection was set to be to close.
Definition at line 348 of file TraCIServer.h.
Referenced by close(), dispatchCommand(), openSocket(), processCommandsUntilSimStep(), TraCIServer(), vehicleStateChanged(), and wasClosed().
|
private |
Map of commandIds -> their executors; applicable if the executor applies to the method footprint.
Definition at line 382 of file TraCIServer.h.
Referenced by dispatchCommand(), openSocket(), processSingleSubscription(), and TraCIServer().
|
private |
The storage to read from.
Definition at line 367 of file TraCIServer.h.
Referenced by addObjectVariableSubscription(), addSubscriptionFilter(), checkClientOrdering(), cleanup(), dispatchCommand(), processCommandsUntilSimStep(), and readCommandID().
|
staticprivate |
Singleton instance of the server.
Definition at line 345 of file TraCIServer.h.
Referenced by cleanup(), close(), getInstance(), and openSocket().
|
private |
The last modified context subscription (the one to add a filter to, see (), currently only for vehicle to vehicle context)
Definition at line 393 of file TraCIServer.h.
Referenced by addSubscriptionFilter(), addSubscriptionFilterDownstreamDistance(), addSubscriptionFilterLanes(), addSubscriptionFilterLeadFollow(), addSubscriptionFilterNoOpposite(), addSubscriptionFilterTurn(), addSubscriptionFilterUpstreamDistance(), addSubscriptionFilterVClass(), addSubscriptionFilterVType(), initialiseSubscription(), removeFilters(), and removeSubscription().
|
private |
Definition at line 387 of file TraCIServer.h.
Referenced by dispatchCommand(), getLoadArgs(), and processCommandsUntilSimStep().
|
private |
The storage to write to.
Definition at line 370 of file TraCIServer.h.
Referenced by checkClientOrdering(), cleanup(), commandGetVersion(), dispatchCommand(), initialiseSubscription(), postProcessSimulationStep(), processCommandsUntilSimStep(), sendOutputToAll(), sendSingleSimStepResponse(), and writeStatusCmd().
|
private |
Map of variable ids to the size of the parameter in bytes.
Definition at line 385 of file TraCIServer.h.
Referenced by addObjectVariableSubscription(), and TraCIServer().
|
private |
The server socket.
Definition at line 351 of file TraCIServer.h.
Referenced by TraCIServer(), and ~TraCIServer().
|
private |
This stores the setOrder(int) requests of the clients.
Definition at line 358 of file TraCIServer.h.
Referenced by dispatchCommand(), and processReorderingRequests().
|
private |
The socket connections to the clients the first component (index) determines the client's order (lowest index's commands are processed first),.
Definition at line 355 of file TraCIServer.h.
Referenced by checkClientOrdering(), cleanup(), dispatchCommand(), getVehicleStateChanges(), nextTargetTime(), processCommandsUntilSimStep(), processReorderingRequests(), removeCurrentSocket(), sendOutputToAll(), setTargetTime(), TraCIServer(), vehicleStateChanged(), and ~TraCIServer().
|
private |
The last timestep's subscription results.
Definition at line 376 of file TraCIServer.h.
Referenced by cleanup(), initialiseSubscription(), openSocket(), postProcessSimulationStep(), and sendSingleSimStepResponse().
|
private |
The list of known, still valid subscriptions.
Definition at line 390 of file TraCIServer.h.
Referenced by cleanup(), initialiseSubscription(), postProcessSimulationStep(), and removeSubscription().
|
private |
The time step to reach until processing the next commands.
Definition at line 364 of file TraCIServer.h.
Referenced by cleanup(), dispatchCommand(), getTargetTime(), processCommandsUntilSimStep(), and setTargetTime().
|
private |
Changes in the states of simulated vehicles.
Definition at line 402 of file TraCIServer.h.
Referenced by cleanup(), dispatchCommand(), getVehicleStateChanges(), postProcessSimulationStep(), processCommandsUntilSimStep(), TraCIServer(), and vehicleStateChanged().
|
private |
A temporary storage to let the wrapper write to.
Definition at line 373 of file TraCIServer.h.
Referenced by getWrapperStorage(), initWrapper(), wrapColor(), wrapDouble(), wrapInt(), wrapPosition(), wrapString(), and wrapStringList().