liuxiulin 7 ماه پیش
والد
کامیت
b9b32faca5
1فایلهای تغییر یافته به همراه3 افزوده شده و 2 حذف شده
  1. 3 2
      services/emqx-agent/agent.go

+ 3 - 2
services/emqx-agent/agent.go

@@ -323,9 +323,10 @@ func (a *Access) chunkUpgrade(params rpcs.ChunkUpgrade) error {
 	}
 	start := params.Offset * int(params.Size)
 	stop := (params.Offset + 1) + int(params.Size)
-	if stop >= len(fileArgs.FileData) {
-		stop = len(fileArgs.FileData)
+	if stop >= len(fileReply.File) {
+		stop = len(fileReply.File)
 	}
+	server.Log.Infof("文件截取位置------: start:%d,stop:%d", start, stop)
 	data := fileReply.File[start:stop]
 	buf.Write(gbinary.BeEncodeUint16(gconv.Uint16(len(data))))
 	buf.Write(data)