1
0
Fork 0
mirror of https://github.com/moby/moby.git synced 2022-11-09 12:21:53 -05:00

Fix panic in stats test

Signed-off-by: Tonis Tiigi <tonistiigi@gmail.com>
This commit is contained in:
Tonis Tiigi 2016-07-14 16:59:44 -07:00
parent 9df2a825ba
commit f5fb3c69fd

View file

@ -215,28 +215,20 @@ func (s *DockerSuite) TestGetContainerStatsRmRunning(c *check.C) {
buf := &integration.ChannelBuffer{make(chan []byte, 1)} buf := &integration.ChannelBuffer{make(chan []byte, 1)}
defer buf.Close() defer buf.Close()
_, body, err := sockRequestRaw("GET", "/containers/"+id+"/stats?stream=1", nil, "application/json")
c.Assert(err, checker.IsNil)
defer body.Close()
chErr := make(chan error, 1) chErr := make(chan error, 1)
go func() { go func() {
_, body, err := sockRequestRaw("GET", "/containers/"+id+"/stats?stream=1", nil, "application/json")
if err != nil {
chErr <- err
}
defer body.Close()
_, err = io.Copy(buf, body) _, err = io.Copy(buf, body)
chErr <- err chErr <- err
}() }()
defer func() {
select {
case err := <-chErr:
c.Assert(err, checker.IsNil)
default:
return
}
}()
b := make([]byte, 32) b := make([]byte, 32)
// make sure we've got some stats // make sure we've got some stats
_, err := buf.ReadTimeout(b, 2*time.Second) _, err = buf.ReadTimeout(b, 2*time.Second)
c.Assert(err, checker.IsNil) c.Assert(err, checker.IsNil)
// Now remove without `-f` and make sure we are still pulling stats // Now remove without `-f` and make sure we are still pulling stats
@ -245,7 +237,8 @@ func (s *DockerSuite) TestGetContainerStatsRmRunning(c *check.C) {
_, err = buf.ReadTimeout(b, 2*time.Second) _, err = buf.ReadTimeout(b, 2*time.Second)
c.Assert(err, checker.IsNil) c.Assert(err, checker.IsNil)
dockerCmd(c, "kill", id) dockerCmd(c, "rm", "-f", id)
c.Assert(<-chErr, checker.IsNil)
} }
// regression test for gh13421 // regression test for gh13421