我一直在使用io.Pipe測試代碼,將tar和gunzip文件轉換成tar球,然後使用tar實用程序進行解壓縮。後續的代碼通過,但是untaring過程中不斷變得使用golang io.pipe到tar文件的錯誤
錯誤: tar: Truncated input file (needed 1050624 bytes, only 0 available) tar: Error exit delayed from previous errors.
這個問題真的快把我逼瘋了。已經兩週了。我真的需要幫助調試。
謝謝。
開發環境:去版本go1.9達爾文/ AMD64
package main
import (
"archive/tar"
"compress/gzip"
"fmt"
"io"
"log"
"os"
"path/filepath"
"testing"
)
func testTarGzipPipe2(t *testing.T) {
src := "/path/to/file/folder"
pr, pw := io.Pipe()
gzipWriter := gzip.NewWriter(pw)
defer gzipWriter.Close()
tarWriter := tar.NewWriter(gzipWriter)
defer tarWriter.Close()
status := make(chan bool)
go func() {
defer pr.Close()
// tar to local disk
tarFile, err := os.OpenFile("/path/to/tar/ball/test.tar.gz", os.O_RDWR|os.O_CREATE, 0755)
if err != nil {
log.Fatal(err)
}
defer tarFile.Close()
if _, err := io.Copy(tarFile, pr); err != nil {
log.Fatal(err)
}
status <- true
}()
err := filepath.Walk(src, func(path string, info os.FileInfo, err error) error {
if err != nil {
return err
}
header, err := tar.FileInfoHeader(info, info.Name())
if err != nil {
return err
}
// header.Name = strings.TrimPrefix(strings.Replace(path, src, "", -1), string(filepath.Separator))
if err := tarWriter.WriteHeader(header); err != nil {
return err
}
if info.Mode().IsDir() {
return nil
}
fmt.Println(path)
f, err := os.Open(path)
if err != nil {
return err
}
defer f.Close()
if _, err := io.Copy(tarWriter, f); err != nil {
return err
}
return nil
})
if err != nil {
log.Fatal(err)
}
pw.Close()
<-status
}
什麼是錯誤?還請'去fmt'文件 – reticentroot
不相關:你不應該在測試中(或者你期望執行'defer'語句的任何地方)調用log.Fatal,因爲它阻止了你打算做的任何清理,並且可以隱藏未通過測試。有一個't.Fatal'這是你想要的。一個tar文件不應該是可執行的。關閉一個通道而不是發送一個標記值作爲信號,或者更好的是,使用WaitGroup來等待goroutines。 – JimB