Skip to content
Snippets Groups Projects
Commit 49c468b6 authored by Benjamin Wenger's avatar Benjamin Wenger
Browse files

removed the connection durration

parent 82ca7186
No related branches found
No related tags found
No related merge requests found
...@@ -64,14 +64,12 @@ func StreamTransmitPhase(roundID id.Round, serverInstance phase.GenericInstance, ...@@ -64,14 +64,12 @@ func StreamTransmitPhase(roundID id.Round, serverInstance phase.GenericInstance,
// This gets the streaming client which used to send slots // This gets the streaming client which used to send slots
// using the recipient node id and the batch info header // using the recipient node id and the batch info header
// It's context must be canceled after receiving an ack // It's context must be canceled after receiving an ack
openClientStart := time.Now()
streamClient, cancel, err := instance.GetNetwork().GetPostPhaseStreamClient( streamClient, cancel, err := instance.GetNetwork().GetPostPhaseStreamClient(
recipient, header) recipient, header)
if err != nil { if err != nil {
return errors.Errorf("Error on comm, unable to get streaming "+ return errors.Errorf("Error on comm, unable to get streaming "+
"client: %+v", err) "client: %+v", err)
} }
openClientDelta := time.Now().Sub(openClientStart)
//pull the first chunk reception out so it can be timestmaped //pull the first chunk reception out so it can be timestmaped
chunk, finish := getChunk() chunk, finish := getChunk()
...@@ -126,10 +124,10 @@ func StreamTransmitPhase(roundID id.Round, serverInstance phase.GenericInstance, ...@@ -126,10 +124,10 @@ func StreamTransmitPhase(roundID id.Round, serverInstance phase.GenericInstance,
"from: %s, to: %s, "+ "from: %s, to: %s, "+
"started: %v, "+ "started: %v, "+
"ended: %v, "+ "ended: %v, "+
"duration: %d, connectionDuration: %d", "duration: %d",
roundID, currentPhase.GetType(), roundID, currentPhase.GetType(),
instance.GetID(), recipientID, instance.GetID(), recipientID,
start, end, end.Sub(start).Milliseconds(), openClientDelta.Milliseconds()) start, end, end.Sub(start).Milliseconds())
cancel() cancel()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment