- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for die (0.11 sec)
-
cni/pkg/nodeagent/netns_linux.go
} var wg sync.WaitGroup wg.Add(1) // Start the callback in a new green thread so that if we later fail // to switch the namespace back to the original one, we can safely // leave the thread locked to die without a risk of the current thread // left lingering with incorrect namespace. var innerError error go func() { defer wg.Done() runtime.LockOSThread() innerError = containedCall() }() wg.Wait()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 31 10:05:36 GMT 2024 - 2.7K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
if err != nil { log.Errorf("failed to annotate pod unenrollment: %v", err) } return err } // Delete pod from mesh: pod is deleted. iptables rules will die with it, we just need to update ztunnel func (s *meshDataplane) DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error { log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) err := s.netServer.DelPodFromMesh(ctx, pod)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
if err := s.ztunnelServer.PodDeleted(ctx, string(pod.UID)); err != nil { log.Errorf("failed to delete pod from ztunnel: %v", err) } return nil } // Delete pod from mesh: pod is deleted. iptables rules will die with it, we just need to update ztunnel func (s *NetServer) DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error { log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) log.Debug("Pod is now stopped... cleaning up.")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1)