From f6b93c1168a03be132ec10a74ad311c90b7f5c6e Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期五, 20 十二月 2019 16:42:03 +0800
Subject: [PATCH] fix bufio write,add flush
---
service/SysService.go | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/service/SysService.go b/service/SysService.go
index 92957eb..f60dc04 100644
--- a/service/SysService.go
+++ b/service/SysService.go
@@ -130,13 +130,14 @@
logger.Debug("read chunkData err:",err,"n:",n)
return false
}
- logger.Debug("read currentChunkData len:",n,"header data len:",arg.Header.Size,"data:",string(chunkData))
nn, err2 := writer.Write(chunkData)
if nn ==0 || err2 !=nil {
logger.Debug("write chunkData err:",err2,"nn:",nn)
return false
}
- logger.Debug("write chunkData len:",nn)
+ if err = writer.Flush(); err != nil {
+ logger.Debug("write flush err:",err)
+ }
isComplete := false
dirFiles, _ := ioutil.ReadDir(fileTmpPath)
if dirFiles != nil && len(dirFiles) == arg.TotalChunks {
--
Gitblit v1.8.0