diff --git a/cmix/sendCmix.go b/cmix/sendCmix.go index 3815528ec6fc237a2850b21d1b6eb2105102d55f..9c7b95f758da2479ce11caca629c56827b400401 100644 --- a/cmix/sendCmix.go +++ b/cmix/sendCmix.go @@ -173,9 +173,6 @@ func sendCmixHelper(sender gateway.Sender, assembler messageAssembler, recipient attempted = excludedRounds.NewSet() } - jww.INFO.Printf("[Send-%s] Looking for round to send cMix message to "+ - "%s", cmixParams.DebugTag, recipient) - stream := rng.GetStream() defer stream.Close() @@ -184,13 +181,23 @@ func sendCmixHelper(sender gateway.Sender, assembler messageAssembler, recipient optimalAttempts, ready := attemptTracker.GetOptimalNumAttempts() if ready { numAttempts = optimalAttempts + jww.INFO.Printf("[Send-%s] Looking for round to send cMix message to "+ + "%s, sending non probe with %d optimalAttempts", cmixParams.DebugTag, recipient, numAttempts) } else { numAttempts = 4 + jww.INFO.Printf("[Send-%s] Looking for round to send cMix message to "+ + "%s, sending non probe with %d non optimalAttempts, insufficient data", + cmixParams.DebugTag, recipient, numAttempts) } } else { + jww.INFO.Printf("[Send-%s] Looking for round to send cMix message to "+ + "%s, sending probe with %d Attempts, insufficient data", + cmixParams.DebugTag, recipient, numAttempts) defer attemptTracker.SubmitProbeAttempt(numAttempts) } + jww.INFO.Printf("") + for numRoundTries := uint(0); numRoundTries < cmixParams.RoundTries; numRoundTries, numAttempts = numRoundTries+1, numAttempts+1 { elapsed := netTime.Since(timeStart)