mirrors/ctrl
mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2024-12-14 12:37:31 +00:00
Code Activity

fixed copySrc reply message

Browse source
This commit is contained in:
postmannen 2022-06-09 10:27:20 +02:00
parent 680cb1f4dd
commit f1e1577a03
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
requests_copy.go
View file

@ -77,9 +77,9 @@ func (m methodREQCopySrc) handler(proc process, message Message, node string) ([
return return
} }
// SrcFilePath := message.MethodArgs[0] SrcFilePath := message.MethodArgs[0]
// DstNode := message.MethodArgs[1] DstNode := message.MethodArgs[1]
// DstFilePath := message.MethodArgs[2] DstFilePath := message.MethodArgs[2]
// Get a context with the timeout specified in message.MethodTimeout. // Get a context with the timeout specified in message.MethodTimeout.
// Since the subProc spawned will outlive this method here we do not // 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. // The process will be killed when the context expires.
go copySrcSubProc.spawnWorker() 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))
}() }()