Browse Source

Merge pull request #9970 from shishir-a412ed/docker_load_issue

Implementation of docker load command, load the tar ball directly into /var/lib/docker/graph
Vincent Batts 10 years ago
parent
commit
092d52281d
1 changed files with 2 additions and 17 deletions
  1. 2 17
      graph/load.go

+ 2 - 17
graph/load.go

@@ -4,7 +4,6 @@ package graph
 
 
 import (
 import (
 	"encoding/json"
 	"encoding/json"
-	"io"
 	"io/ioutil"
 	"io/ioutil"
 	"os"
 	"os"
 	"path"
 	"path"
@@ -27,23 +26,9 @@ func (s *TagStore) CmdLoad(job *engine.Job) engine.Status {
 	defer os.RemoveAll(tmpImageDir)
 	defer os.RemoveAll(tmpImageDir)
 
 
 	var (
 	var (
-		repoTarFile = path.Join(tmpImageDir, "repo.tar")
-		repoDir     = path.Join(tmpImageDir, "repo")
+		repoDir = path.Join(tmpImageDir, "repo")
 	)
 	)
 
 
-	tarFile, err := os.Create(repoTarFile)
-	if err != nil {
-		return job.Error(err)
-	}
-	if _, err := io.Copy(tarFile, job.Stdin); err != nil {
-		return job.Error(err)
-	}
-	tarFile.Close()
-
-	repoFile, err := os.Open(repoTarFile)
-	if err != nil {
-		return job.Error(err)
-	}
 	if err := os.Mkdir(repoDir, os.ModeDir); err != nil {
 	if err := os.Mkdir(repoDir, os.ModeDir); err != nil {
 		return job.Error(err)
 		return job.Error(err)
 	}
 	}
@@ -57,7 +42,7 @@ func (s *TagStore) CmdLoad(job *engine.Job) engine.Status {
 		excludes[i] = k
 		excludes[i] = k
 		i++
 		i++
 	}
 	}
-	if err := chrootarchive.Untar(repoFile, repoDir, &archive.TarOptions{ExcludePatterns: excludes}); err != nil {
+	if err := chrootarchive.Untar(job.Stdin, repoDir, &archive.TarOptions{ExcludePatterns: excludes}); err != nil {
 		return job.Error(err)
 		return job.Error(err)
 	}
 	}