|
@@ -3,11 +3,13 @@
|
|
package main
|
|
package main
|
|
|
|
|
|
import (
|
|
import (
|
|
|
|
+ "context"
|
|
"fmt"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"io/ioutil"
|
|
"os"
|
|
"os"
|
|
"os/exec"
|
|
"os/exec"
|
|
"strings"
|
|
"strings"
|
|
|
|
+ "time"
|
|
|
|
|
|
"github.com/docker/docker/pkg/integration/checker"
|
|
"github.com/docker/docker/pkg/integration/checker"
|
|
"github.com/go-check/check"
|
|
"github.com/go-check/check"
|
|
@@ -86,3 +88,22 @@ func (s *DockerSuite) TestSaveAndLoadWithProgressBar(c *check.C) {
|
|
expected := fmt.Sprintf("The image %s:latest already exists, renaming the old one with ID", name)
|
|
expected := fmt.Sprintf("The image %s:latest already exists, renaming the old one with ID", name)
|
|
c.Assert(out, checker.Contains, expected)
|
|
c.Assert(out, checker.Contains, expected)
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+// fail because load didn't receive data from stdin
|
|
|
|
+func (s *DockerSuite) TestLoadNoStdinFail(c *check.C) {
|
|
|
|
+ pty, tty, err := pty.Open()
|
|
|
|
+ c.Assert(err, check.IsNil)
|
|
|
|
+ ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
|
|
|
|
+ defer cancel()
|
|
|
|
+ cmd := exec.CommandContext(ctx, dockerBinary, "load")
|
|
|
|
+ cmd.Stdin = tty
|
|
|
|
+ cmd.Stdout = tty
|
|
|
|
+ cmd.Stderr = tty
|
|
|
|
+ c.Assert(cmd.Run(), check.NotNil) // docker-load should fail
|
|
|
|
+
|
|
|
|
+ buf := make([]byte, 1024)
|
|
|
|
+
|
|
|
|
+ n, err := pty.Read(buf)
|
|
|
|
+ c.Assert(err, check.IsNil) //could not read tty output
|
|
|
|
+ c.Assert(string(buf[:n]), checker.Contains, "requested load from stdin, but stdin is empty")
|
|
|
|
+}
|