Fix Range() iteration

The function passed into the Range function of sync.Map will stop the
iteration if false is returned. This commit makes sure we iterate
through all elements in the map.

Signed-off-by: Gabriel Adrian Samfira <[email protected]>

cmd/containerd-shim-runhcs-v1/pod.go

@@ -380,8 +380,9 @@ func (p *pod) KillTask(ctx context.Context, tid, eid string, signal uint32, all
  return wt.KillExec(ctx, eid, signal, all)
  })
 
- // iterate all
- return false
+ // Iterate all. Returning false stops the iteration. See:
+ // https://pkg.go.dev/sync#Map.Range
+ return true
  })
  }
  eg.Go(func() error {

cmd/containerd-shim-runhcs-v1/task_hcs.go

@@ -536,8 +536,9 @@ func (ht *hcsTask) KillExec(ctx context.Context, eid string, signal uint32, all
  }).Warn("failed to kill exec in task")
  }
 
- // iterate all
- return false
+ // Iterate all. Returning false stops the iteration. See:
+ // https://pkg.go.dev/sync#Map.Range
+ return true
  })
  }
  if signal == 0x9 && eid == "" && ht.host != nil {
@@ -578,8 +579,9 @@ func (ht *hcsTask) DeleteExec(ctx context.Context, eid string) (int, uint32, tim
  ex.ForceExit(ctx, 1)
  }
 
- // iterate next
- return false
+ // Iterate all. Returning false stops the iteration. See:
+ // https://pkg.go.dev/sync#Map.Range
+ return true
  })
  }
  switch state := e.State(); state {
@@ -617,8 +619,9 @@ func (ht *hcsTask) Pids(ctx context.Context) ([]runhcsopts.ProcessDetails, error
  ex := value.(shimExec)
  pidMap[ex.Pid()] = ex.ID()
 
- // Iterate all
- return false
+ // Iterate all. Returning false stops the iteration. See:
+ // https://pkg.go.dev/sync#Map.Range
+ return true
  })
  pidMap[ht.init.Pid()] = ht.init.ID()
 
@@ -699,8 +702,9 @@ func (ht *hcsTask) waitForHostExit() {
  ex := value.(shimExec)
  ex.ForceExit(ctx, 1)
 
- // iterate all
- return false
+ // Iterate all. Returning false stops the iteration. See:
+ // https://pkg.go.dev/sync#Map.Range
+ return true
  })
  ht.init.ForceExit(ctx, 1)
  ht.closeHost(ctx)