From f1e1577a030503ff52d630bd64dd585982817020 Mon Sep 17 00:00:00 2001 From: postmannen Date: Thu, 9 Jun 2022 10:27:20 +0200 Subject: [PATCH] fixed copySrc reply message --- requests_copy.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/requests_copy.go b/requests_copy.go index 77374d1..e7dbd69 100644 --- a/requests_copy.go +++ b/requests_copy.go @@ -77,9 +77,9 @@ func (m methodREQCopySrc) handler(proc process, message Message, node string) ([ return } - // SrcFilePath := message.MethodArgs[0] - // DstNode := message.MethodArgs[1] - // DstFilePath := message.MethodArgs[2] + SrcFilePath := message.MethodArgs[0] + DstNode := message.MethodArgs[1] + DstFilePath := message.MethodArgs[2] // Get a context with the timeout specified in message.MethodTimeout. // Since the subProc spawned will outlive this method here we do not @@ -102,9 +102,10 @@ func (m methodREQCopySrc) handler(proc process, message Message, node string) ([ // The process will be killed when the context expires. go copySrcSubProc.spawnWorker() - //replyData := fmt.Sprintf("info: succesfully initiated copy: srcNode=%v, srcPath=%v, dstNode=%v, dstPath=%v, starting sub process=%v for the actual copying\n", node, SrcFilePath, DstNode, DstFilePath, subProcessName) + replyData := fmt.Sprintf("info: succesfully initiated copy process: procName=%v, srcNode=%v, srcPath=%v, dstNode=%v, dstPath=%v, starting sub process=%v for the actual copying\n", copySrcSubProc.processName, node, SrcFilePath, DstNode, DstFilePath, subProcessName) // - //newReplyMessage(proc, message, []byte(replyData)) + + newReplyMessage(proc, message, []byte(replyData)) }()