| | |
| | | } |
| | | defer file.Close() |
| | | writer := bufio.NewWriter(file) |
| | | chunkData := make([]byte, arg.CurrentChunkSize) |
| | | chunkData := make([]byte, arg.Header.Size) |
| | | n, err := (*arg.File).ReadAt(chunkData, 0) |
| | | if n ==0 || err !=nil { |
| | | logger.Debug("read chunkData err:",err,"n:",n) |
| | | return false |
| | | } |
| | | logger.Debug("read chunkData len:",n) |
| | | logger.Debug("read currentChunkData len:",n,"header data len:",arg.Header.Size) |
| | | nn, err2 := writer.Write(chunkData) |
| | | if nn ==0 || err2 !=nil { |
| | | logger.Debug("write chunkData err:",err2,"nn:",nn) |