vbatts/containerd
1
0
Fork 0
Code Pull requests Releases Activity

Add a way to retrieve a test container event channel

Browse source 
Signed-off-by: Kenfe-Mickael Laventure <mickael.laventure@gmail.com>
This commit is contained in:
Kenfe-Mickael Laventure 2016-03-28 11:27:12 -07:00
parent e6b2ed4b7f
commit 3481996e9d
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
integration-test/container_utils_test.go
View file

@ -110,12 +110,21 @@ func (c *containerProcess) openIo() (err error) {
return nil return nil
} }
func (c *containerProcess) GetEventsChannel() chan *types.Event {
return c.eventsCh
}
func (c *containerProcess) GetNextEvent() *types.Event { func (c *containerProcess) GetNextEvent() *types.Event {
if c.hasExited {
return nil
}
e := <-c.eventsCh e := <-c.eventsCh
if e.Type == "exit" && e.Pid == c.pid { if e.Type == "exit" && e.Pid == c.pid {
c.Cleanup() c.Cleanup()
c.hasExited = true c.hasExited = true
close(c.eventsCh)
} }
return e return e