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

Send container events with nil PodSandboxStatus

Browse Source 
Signed-off-by: ruiwen-zhao <ruiwen@google.com>
This commit is contained in:
ruiwen-zhao 2023-02-03 20:09:50 +00:00
parent 27c8f4085c
commit 51a8db233d
2 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/cri/sbserver/helpers.go
View File

@ -525,10 +525,8 @@ func copyResourcesToStatus(spec *runtimespec.Spec, status containerstore.Status)
func (c *criService) generateAndSendContainerEvent(ctx context.Context, containerID string, sandboxID string, eventType runtime.ContainerEventType) { func (c *criService) generateAndSendContainerEvent(ctx context.Context, containerID string, sandboxID string, eventType runtime.ContainerEventType) {
podSandboxStatus, err := c.getPodSandboxStatus(ctx, sandboxID) podSandboxStatus, err := c.getPodSandboxStatus(ctx, sandboxID)
if err != nil { if err != nil {
// TODO(https://github.com/containerd/containerd/issues/7785): logrus.Warnf("Failed to get podSandbox status for container event for sandboxID %q: %v. Sending the event with nil podSandboxStatus.", sandboxID, err)
// Do not skip events with nil PodSandboxStatus. podSandboxStatus = nil
logrus.Errorf("Failed to get podSandbox status for container event for sandboxID %q: %v. Skipping sending the event.", sandboxID, err)
return
} }
containerStatuses, err := c.getContainerStatuses(ctx, sandboxID) containerStatuses, err := c.getContainerStatuses(ctx, sandboxID)
if err != nil { if err != nil {

6
pkg/cri/server/helpers.go
View File

@ -523,10 +523,8 @@ func copyResourcesToStatus(spec *runtimespec.Spec, status containerstore.Status)
func (c *criService) generateAndSendContainerEvent(ctx context.Context, containerID string, sandboxID string, eventType runtime.ContainerEventType) { func (c *criService) generateAndSendContainerEvent(ctx context.Context, containerID string, sandboxID string, eventType runtime.ContainerEventType) {
podSandboxStatus, err := c.getPodSandboxStatus(ctx, sandboxID) podSandboxStatus, err := c.getPodSandboxStatus(ctx, sandboxID)
if err != nil { if err != nil {
// TODO(https://github.com/containerd/containerd/issues/7785): logrus.Warnf("Failed to get podSandbox status for container event for sandboxID %q: %v. Sending the event with nil podSandboxStatus.", sandboxID, err)
// Do not skip events with nil PodSandboxStatus. podSandboxStatus = nil
logrus.Errorf("Failed to get podSandbox status for container event for sandboxID %q: %v. Skipping sending the event.", sandboxID, err)
return
} }
containerStatuses, err := c.getContainerStatuses(ctx, sandboxID) containerStatuses, err := c.getContainerStatuses(ctx, sandboxID)
if err != nil { if err != nil {