github/containerd
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

Simplify task.Wait() a bit

Browse Source 
Signed-off-by: Kenfe-Mickael Laventure <mickael.laventure@gmail.com>
This commit is contained in:
Kenfe-Mickael Laventure 2017-06-23 12:05:24 -07:00
parent 003ed58859
commit 79086a1873
No known key found for this signature in database
GPG Key ID: 40CF16616B361216
1 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
task.go
View File

@ -147,22 +147,25 @@ func (t *task) Wait(ctx context.Context) (uint32, error) {
return UnknownExitStatus, err return UnknownExitStatus, err
} }
<-t.pidSync <-t.pidSync
evloop:
var e eventsapi.RuntimeEvent
for { for {
evt, err := eventstream.Recv() evt, err := eventstream.Recv()
if err != nil { if err != nil {
return UnknownExitStatus, err return UnknownExitStatus, err
} }
switch { if !events.Is(evt.Event, &eventsapi.RuntimeEvent{}) {
case events.Is(evt.Event, &eventsapi.RuntimeEvent{}): continue
var e eventsapi.RuntimeEvent }
if err := events.UnmarshalEvent(evt.Event, &e); err != nil { if err := events.UnmarshalEvent(evt.Event, &e); err != nil {
return UnknownExitStatus, err return UnknownExitStatus, err
} }
if e.Type != tasktypes.Event_EXIT { if e.Type != tasktypes.Event_EXIT {
continue evloop continue
} }
if e.ID == t.containerID && e.Pid == t.pid { if e.ID == t.containerID && e.Pid == t.pid {
@ -170,7 +173,6 @@ evloop:
} }
} }
} }
}
// Delete deletes the task and its runtime state // Delete deletes the task and its runtime state
// it returns the exit status of the task and any errors that were encountered // it returns the exit status of the task and any errors that were encountered