wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Refactor TRACING_UDP_LISTENER_PORT to TRACING_UDP_LISTENER_ADDR.

This commit is contained in:
Ray Jenkins 2022-02-03 12:19:21 -06:00 committed by Lukas Joswiak
parent 276c5bb86a
commit 1bd084810c
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
flow/Knobs.cpp
View File

@ -74,7 +74,7 @@ void FlowKnobs::initialize(Randomize randomize, IsSimulated isSimulated) {
init( WRITE_TRACING_ENABLED, true ); if( randomize && BUGGIFY ) WRITE_TRACING_ENABLED = false;
init( TRACING_SAMPLE_RATE, 0.0 ); // Fraction of distributed traces (not spans) to sample (0 means ignore all traces)
init( TRACING_UDP_LISTENER_PORT, 8889 ); // Only applicable if TracerType is set to a network option
init( TRACING_UDP_LISTENER_ADDR, "127.0.0.1:8889"); // Only applicable if TracerType is set to a network option
//connectionMonitor
init( CONNECTION_MONITOR_LOOP_TIME, isSimulated ? 0.75 : 1.0 ); if( randomize && BUGGIFY ) CONNECTION_MONITOR_LOOP_TIME = 6.0;

2
flow/Knobs.h
View File

@ -122,7 +122,7 @@ public:
bool WRITE_TRACING_ENABLED;
double TRACING_SAMPLE_RATE;
int TRACING_UDP_LISTENER_PORT;
std::string TRACING_UDP_LISTENER_ADDR;
// run loop profiling
double RUN_LOOP_PROFILING_INTERVAL;

6
flow/Tracing.actor.cpp
View File

@ -101,9 +101,9 @@ struct TraceRequest {
// A server listening for UDP trace messages, run only in simulation.
ACTOR Future<Void> simulationStartServer() {
TraceEvent(SevInfo, "UDPServerStarted").detail("Port", FLOW_KNOBS->TRACING_UDP_LISTENER_PORT);
TraceEvent(SevInfo, "UDPServerStarted").detail("Port", FLOW_KNOBS->TRACING_UDP_LISTENER_ADDR);
state NetworkAddress localAddress =
NetworkAddress::parse("127.0.0.1:" + std::to_string(FLOW_KNOBS->TRACING_UDP_LISTENER_PORT));
NetworkAddress::parse(FLOW_KNOBS->TRACING_UDP_LISTENER_ADDR);
state Reference<IUDPSocket> serverSocket = wait(INetworkConnections::net()->createUDPSocket(localAddress));
serverSocket->bind(localAddress);
@ -295,7 +295,7 @@ struct FastUDPTracer : public UDPTracer {
}
NetworkAddress localAddress =
NetworkAddress::parse("127.0.0.1:" + std::to_string(FLOW_KNOBS->TRACING_UDP_LISTENER_PORT));
NetworkAddress::parse(FLOW_KNOBS->TRACING_UDP_LISTENER_ADDR);
socket_ = INetworkConnections::net()->createUDPSocket(localAddress);
});