From 3f5b58ffab3a9b70905d27bd3bef03623f175ce0 Mon Sep 17 00:00:00 2001 From: postmannen Date: Wed, 21 Dec 2022 09:27:52 +0100 Subject: [PATCH] fixed timeouts for copy messages --- requests_copy.go | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/requests_copy.go b/requests_copy.go index bc50d18..4480dae 100644 --- a/requests_copy.go +++ b/requests_copy.go @@ -252,6 +252,10 @@ func (m methodREQCopySrc) handler(proc process, message Message, node string) ([ //msg.Method = REQToFile msg.Method = REQCopyDst msg.Data = cb + msg.ACKTimeout = message.ACKTimeout + msg.Retries = message.Retries + msg.ReplyACKTimeout = message.ReplyACKTimeout + msg.ReplyRetries = message.ReplyRetries // msg.Directory = dstDir // msg.FileName = dstFile @@ -527,6 +531,8 @@ func copySrcSubProcFunc(proc process, cia copyInitialData, cancel context.Cancel IsSubPublishedMsg: true, ACKTimeout: initialMessage.ACKTimeout, Retries: initialMessage.Retries, + ReplyACKTimeout: initialMessage.ReplyACKTimeout, + ReplyRetries: initialMessage.ReplyRetries, } fmt.Printf(" * DEBUG: ACKTimeout:%v, Retries: %v\n", initialMessage.ACKTimeout, initialMessage.Retries) @@ -597,6 +603,8 @@ func copySrcSubProcFunc(proc process, cia copyInitialData, cancel context.Cancel IsSubPublishedMsg: true, ACKTimeout: initialMessage.ACKTimeout, Retries: initialMessage.Retries, + ReplyACKTimeout: initialMessage.ReplyACKTimeout, + ReplyRetries: initialMessage.ReplyRetries, } sam, err := newSubjectAndMessage(msg) @@ -658,6 +666,8 @@ func copyDstSubProcFunc(proc process, cia copyInitialData, message Message, canc IsSubPublishedMsg: true, ACKTimeout: message.ACKTimeout, Retries: message.Retries, + ReplyACKTimeout: message.ReplyACKTimeout, + ReplyRetries: message.ReplyRetries, } sam, err := newSubjectAndMessage(msg) @@ -758,6 +768,8 @@ func copyDstSubProcFunc(proc process, cia copyInitialData, message Message, canc IsSubPublishedMsg: true, ACKTimeout: message.ACKTimeout, Retries: message.Retries, + ReplyACKTimeout: message.ReplyACKTimeout, + ReplyRetries: message.ReplyRetries, } sam, err := newSubjectAndMessage(msg) @@ -789,6 +801,8 @@ func copyDstSubProcFunc(proc process, cia copyInitialData, message Message, canc IsSubPublishedMsg: true, ACKTimeout: message.ACKTimeout, Retries: message.Retries, + ReplyACKTimeout: message.ReplyACKTimeout, + ReplyRetries: message.ReplyRetries, } sam, err := newSubjectAndMessage(msg) @@ -941,6 +955,8 @@ func copyDstSubProcFunc(proc process, cia copyInitialData, message Message, canc IsSubPublishedMsg: true, ACKTimeout: message.ACKTimeout, Retries: message.Retries, + ReplyACKTimeout: message.ReplyACKTimeout, + ReplyRetries: message.ReplyRetries, } sam, err := newSubjectAndMessage(msg)