golang io.pipeからtarファイルへのバグバグ

Question

io.Pipeを使ってファイルをtarとgunzipでタールボールにし、tarユーティリティを使って解凍するコードをテストしています。 tar: Truncated input file (needed 1050624 bytes, only 0 available) tar: Error exit delayed from previous errors.

この問題は本当に狂気私を運転している：次のコードは合格、しかしuntaringプロセスは

エラーを取得して保持します。それは2週間続いた。私は本当にデバッグを助ける必要があります。

ありがとうございました。

開発的環境：バージョン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 
} 

Answer 1

あなたがgzipWriterとtarWriterに係る繰延閉じる呼び出し前にパイプを閉じています。これらのクローズコールのいずれかでエラーをチェックしていないので、エラーはありません。 tarWriterを閉じ、次にgzipWriterを閉じ、次にPipeWriterを順番に閉じる必要があります。

しかし、このコードではパイプを使用する理由は全くありません。ファイルに直接書き込むと、ゴルーチンと関連するコーディネーションを完全に削除することができます。

tarFile, err := os.OpenFile("/tmp/test.tar.gz", os.O_RDWR|os.O_CREATE, 0644) 
if err != nil { 
    log.Fatal(err) 
} 
defer tarFile.Close() 

gzipWriter := gzip.NewWriter(tarFile) 
defer gzipWriter.Close() 
tarWriter := tar.NewWriter(gzipWriter) 
defer tarWriter.Close()