mirror of
https://github.com/clearlinux/docker.git
synced 2026-09-06 05:31:47 +00:00
Merge pull request #12703 from LK4D4/carry_12596
remove job from image_export
This commit is contained in:
+23
-8
@@ -888,17 +888,32 @@ func (s *Server) getImagesGet(eng *engine.Engine, version version.Version, w htt
|
||||
if err := parseForm(r); err != nil {
|
||||
return err
|
||||
}
|
||||
if version.GreaterThan("1.0") {
|
||||
|
||||
useJSON := version.GreaterThan("1.0")
|
||||
if useJSON {
|
||||
w.Header().Set("Content-Type", "application/x-tar")
|
||||
}
|
||||
var job *engine.Job
|
||||
if name, ok := vars["name"]; ok {
|
||||
job = eng.Job("image_export", name)
|
||||
} else {
|
||||
job = eng.Job("image_export", r.Form["names"]...)
|
||||
|
||||
output := utils.NewWriteFlusher(w)
|
||||
imageExportConfig := &graph.ImageExportConfig{
|
||||
Engine: eng,
|
||||
Outstream: output,
|
||||
}
|
||||
job.Stdout.Add(w)
|
||||
return job.Run()
|
||||
if name, ok := vars["name"]; ok {
|
||||
imageExportConfig.Names = []string{name}
|
||||
} else {
|
||||
imageExportConfig.Names = r.Form["names"]
|
||||
}
|
||||
|
||||
if err := s.daemon.Repositories().ImageExport(imageExportConfig); err != nil {
|
||||
if !output.Flushed() {
|
||||
return err
|
||||
}
|
||||
sf := streamformatter.NewStreamFormatter(useJSON)
|
||||
output.Write(sf.FormatError(err))
|
||||
}
|
||||
return nil
|
||||
|
||||
}
|
||||
|
||||
func (s *Server) postImagesLoad(eng *engine.Engine, version version.Version, w http.ResponseWriter, r *http.Request, vars map[string]string) error {
|
||||
|
||||
Reference in New Issue
Block a user