liuxiaolong
2019-12-20 f6b93c1168a03be132ec10a74ad311c90b7f5c6e
fix bufio write,add flush
1个文件已修改
5 ■■■■■ 已修改文件
service/SysService.go 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
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 {