Skip to content

Commit e9a2fa6

Browse files
committed
network-mux: removed handshake traces
1 parent 2a5ced0 commit e9a2fa6

File tree

3 files changed

+1
-19
lines changed

3 files changed

+1
-19
lines changed

network-mux/CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
* Polling of the egress queue
99
* run, miniProtocolJob, monitor now accept MuxTracerBundle record
1010
instead of `Tracer m Trace` type.
11+
* Removed handshake trace events from mux trace.
1112

1213
### Non-breaking changes
1314
* Define msHeaderLength instead of using '8'

network-mux/src/Network/Mux/Trace.hs

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -146,12 +146,6 @@ data Trace =
146146
| TraceSDUReadTimeoutException
147147
| TraceSDUWriteTimeoutException
148148
| TraceTCPInfo StructTCPInfo Word16
149-
-- low level handshake bearer tags (not traced by tracer in Mux)
150-
| TraceHandshakeStart
151-
| TraceHandshakeClientEnd DiffTime
152-
| TraceHandshakeServerEnd
153-
| forall e. Exception e => TraceHandshakeClientError e DiffTime
154-
| forall e. Exception e => TraceHandshakeServerError e
155149
-- mid level channel tags traced independently by each mini protocol
156150
-- job in Mux, for each complete message, by the 'channelTracer'
157151
-- within 'MuxTracerBundle'
@@ -198,13 +192,6 @@ instance Show Trace where
198192
show (TraceChannelSendStart mid len) = printf "Channel Send Start on (%s) %d" (show mid)
199193
len
200194
show (TraceChannelSendEnd mid) = printf "Channel Send End on %s" (show mid)
201-
show TraceHandshakeStart = "Handshake start"
202-
show (TraceHandshakeClientEnd duration) = printf "Handshake Client end, duration %s" (show duration)
203-
show TraceHandshakeServerEnd = "Handshake Server end"
204-
show (TraceHandshakeClientError e duration) =
205-
-- Client Error can include an error string from the peer which could be very large.
206-
printf "Handshake Client Error %s duration %s" (take 256 $ show e) (show duration)
207-
show (TraceHandshakeServerError e) = printf "Handshake Server Error %s" (show e)
208195
show TraceSDUReadTimeoutException = "Timed out reading SDU"
209196
show TraceSDUWriteTimeoutException = "Timed out writing SDU"
210197
show (TraceStartEagerly mid dir) = printf "Eagerly started (%s) in %s" (show mid) (show dir)

ouroboros-network-framework/src/Ouroboros/Network/Socket.hs

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -377,7 +377,6 @@ connectToNodeWithMux'
377377
connectionId <- (\localAddress remoteAddress -> ConnectionId { localAddress, remoteAddress })
378378
<$> Snocket.getLocalAddr sn sd <*> Snocket.getRemoteAddr sn sd
379379
muxTracer <- initDeltaQTracer' $ Mx.WithBearer connectionId `contramap` nctMuxTracer
380-
ts_start <- getMonotonicTime
381380

382381
handshakeBearer <- Mx.getBearer makeBearer sduHandshakeTimeout muxTracer sd Nothing
383382
app_e <-
@@ -394,18 +393,14 @@ connectToNodeWithMux'
394393
haTimeLimits = handshakeTimeLimits
395394
}
396395
versions
397-
ts_end <- getMonotonicTime
398396
case app_e of
399397
Left (HandshakeProtocolLimit err) -> do
400-
traceWith muxTracer $ Mx.TraceHandshakeClientError err (diffTime ts_end ts_start)
401398
throwIO err
402399

403400
Left (HandshakeProtocolError err) -> do
404-
traceWith muxTracer $ Mx.TraceHandshakeClientError err (diffTime ts_end ts_start)
405401
throwIO err
406402

407403
Right (HandshakeNegotiationResult app versionNumber agreedOptions) -> do
408-
traceWith muxTracer $ Mx.TraceHandshakeClientEnd (diffTime ts_end ts_start)
409404
Mx.withReadBufferIO (\buffer -> do
410405
bearer <- Mx.getBearer makeBearer sduTimeout muxTracer sd buffer
411406
mux <- Mx.new (toMiniProtocolInfos (runForkPolicy noBindForkPolicy remoteAddress) app)
@@ -414,7 +409,6 @@ connectToNodeWithMux'
414409
)
415410

416411
Right (HandshakeQueryResult _vMap) -> do
417-
traceWith muxTracer $ Mx.TraceHandshakeClientEnd (diffTime ts_end ts_start)
418412
throwIO (QueryNotSupported @vNumber)
419413

420414

0 commit comments

Comments
 (0)