From ec70a511279cafab0f6f18d433c018170d6d728e Mon Sep 17 00:00:00 2001 From: Jono Wenger <jono@elixxir.io> Date: Wed, 29 Dec 2021 13:28:10 -0800 Subject: [PATCH] Set send timeout for SendManyCMIX --- fileTransfer/send.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/fileTransfer/send.go b/fileTransfer/send.go index f6c04551f..3494f1de0 100644 --- a/fileTransfer/send.go +++ b/fileTransfer/send.go @@ -66,6 +66,9 @@ const ( // Age when rounds that files were sent from are deleted from the tracker clearSentRoundsAge = 10 * time.Second + + // Duration before sending on a round times out + sendTimeout = 500 * time.Millisecond ) // sendThread waits on the sendQueue channel for parts to send. Once its @@ -245,6 +248,7 @@ func (m *Manager) sendParts(partList []queuedPart, // Create cMix parameters with round exclusion list p := params.GetDefaultCMIX() + p.SendTimeout = sendTimeout p.ExcludedRounds = sentRounds // Send parts -- GitLab