From 8a81c462722c7158e481f974f628843e7c172158 Mon Sep 17 00:00:00 2001 From: Tonis Tiigi Date: Thu, 30 Oct 2014 20:52:13 +0200 Subject: [PATCH] Move consumeSlow() under test utils MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Tõnis Tiigi (github: tonistiigi) --- integration-cli/docker_cli_run_test.go | 16 ---------------- integration-cli/utils.go | 16 ++++++++++++++++ 2 files changed, 16 insertions(+), 16 deletions(-) diff --git a/integration-cli/docker_cli_run_test.go b/integration-cli/docker_cli_run_test.go index 072c6f6b44..eb174ad974 100644 --- a/integration-cli/docker_cli_run_test.go +++ b/integration-cli/docker_cli_run_test.go @@ -2474,19 +2474,3 @@ func TestRunSlowStdoutConsumer(t *testing.T) { logDone("run - slow consumer") } - -func consumeSlow(reader io.Reader, chunkSize int, interval time.Duration) (n int, err error) { - buffer := make([]byte, chunkSize) - for { - var readBytes int - readBytes, err = reader.Read(buffer) - n += readBytes - if err != nil { - if err == io.EOF { - err = nil - } - return - } - time.Sleep(interval) - } -} diff --git a/integration-cli/utils.go b/integration-cli/utils.go index e99e45591b..3d15f66f1d 100644 --- a/integration-cli/utils.go +++ b/integration-cli/utils.go @@ -253,3 +253,19 @@ func makeRandomString(n int) string { } return string(b) } + +func consumeSlow(reader io.Reader, chunkSize int, interval time.Duration) (n int, err error) { + buffer := make([]byte, chunkSize) + for { + var readBytes int + readBytes, err = reader.Read(buffer) + n += readBytes + if err != nil { + if err == io.EOF { + err = nil + } + return + } + time.Sleep(interval) + } +}