Revert v2 dropped events

Partial revert of #2748

Signed-off-by: Michael Crosby <crosbymichael@gmail.com>
This commit is contained in:
Michael Crosby 2018-11-16 11:34:15 -05:00
parent 44b90df286
commit 956e49a36b

View File

@ -26,7 +26,6 @@ import (
"github.com/containerd/containerd/sys" "github.com/containerd/containerd/sys"
runc "github.com/containerd/go-runc" runc "github.com/containerd/go-runc"
"github.com/pkg/errors" "github.com/pkg/errors"
"github.com/sirupsen/logrus"
) )
// ErrNoSuchProcess is returned when the process no longer exists // ErrNoSuchProcess is returned when the process no longer exists
@ -42,18 +41,10 @@ func Reap() error {
Default.Lock() Default.Lock()
for c := range Default.subscribers { for c := range Default.subscribers {
for _, e := range exits { for _, e := range exits {
select { c <- runc.Exit{
case c <- runc.Exit{
Timestamp: now, Timestamp: now,
Pid: e.Pid, Pid: e.Pid,
Status: e.Status, Status: e.Status,
}:
default:
logrus.WithFields(logrus.Fields{
"subscriber": c,
"pid": e.Pid,
"status": e.Status,
}).Warn("failed to send exit to subscriber")
} }
} }
} }