- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 177 for Done (4.38 sec)
-
cni/pkg/nodeagent/server_test.go
} func (wg *WaitGroup) Add(i int32) { select { case <-wg.done: panic("use of an already closed WaitGroup") default: } atomic.AddInt32(&wg.count, i) } func (wg *WaitGroup) Done() { i := atomic.AddInt32(&wg.count, -1) if i == 0 { close(wg.done) } } func (wg *WaitGroup) C() <-chan struct{} { return wg.done
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
if util.PodRedirectionEnabled(ns, pod) { return pod, nil } return nil, nil } func (s *InformerHandlers) Start() { kube.WaitForCacheSync("informer", s.ctx.Done(), s.pods.HasSynced, s.namespaces.HasSynced) go s.queue.Run(s.ctx.Done()) } func (s *InformerHandlers) GetAmbientPods() []*corev1.Pod { var pods []*corev1.Pod for _, pod := range s.pods.List(metav1.NamespaceAll, klabels.Everything()) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cni/pkg/nodeagent/netns_linux.go
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() return innerError
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/repair/netns.go
// There should be 1 or 2 processes that match: the pause container should always be there, and the istio-validation *might*. // We want the pause container, as the istio-validation one may exit before we are done. // We do this by detecting the longest running process. We could look at `cmdline`, but is likely more reliable to weird platforms. for _, p := range procs { ns := getPidNamespace(p.PID)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
if err != nil { return probeSet, err } probeSet.Flush() return probeSet, nil } func (s *Server) Start() { log.Info("CNI ambient server starting") s.kubeClient.RunAndWait(s.ctx.Done()) log.Info("CNI ambient server kubeclient started") pods := s.handlers.GetAmbientPods() err := s.dataplane.ConstructInitialSnapshot(pods) if err != nil { log.Warnf("failed to construct initial snapshot: %v", err)
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) -
common-protos/k8s.io/apimachinery/pkg/runtime/generated.proto
// +k8s:openapi-gen=true message Unknown { optional TypeMeta typeMeta = 1; // Raw will hold the complete serialized object which couldn't be matched // with a registered type. Most likely, nothing should be done with this // except for passing it through the system. optional bytes raw = 2; // ContentEncoding is encoding used to encode 'Raw' data. // Unspecified means no encoding.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 4.2K bytes - Viewed (0) -
manifests/charts/default/files/profile-compatibility-version-1.21.yaml
# The original version of this file is located at /manifests/helm-profiles directory. # If you want to make a change in this file, edit the original one and run "make gen". pilot: env: # 1.22 behavioral changes ENABLE_RESOLUTION_NONE_TARGET_PORT: "false" meshConfig: # 1.22 behavioral changes proxyMetadata: ISTIO_DELTA_XDS: "false" defaultConfig: tracing: zipkin:
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 03 02:25:06 GMT 2024 - 483 bytes - Viewed (0) -
manifests/charts/ztunnel/files/profile-compatibility-version-1.21.yaml
# The original version of this file is located at /manifests/helm-profiles directory. # If you want to make a change in this file, edit the original one and run "make gen". pilot: env: # 1.22 behavioral changes ENABLE_RESOLUTION_NONE_TARGET_PORT: "false" meshConfig: # 1.22 behavioral changes proxyMetadata: ISTIO_DELTA_XDS: "false" defaultConfig: tracing: zipkin:
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 03 02:25:06 GMT 2024 - 483 bytes - Viewed (0) -
manifests/charts/istio-cni/files/profile-compatibility-version-1.20.yaml
# If you want to make a change in this file, edit the original one and run "make gen". pilot: env: # 1.21 behavioral changes ENABLE_EXTERNAL_NAME_ALIAS: "false" PERSIST_OLDEST_FIRST_HEURISTIC_FOR_VIRTUAL_SERVICE_HOST_MATCHING: "true" VERIFY_CERTIFICATE_AT_CLIENT: "false" ENABLE_AUTO_SNI: "false" # 1.22 behavioral changes ENABLE_RESOLUTION_NONE_TARGET_PORT: "false" meshConfig:
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 03 02:25:06 GMT 2024 - 707 bytes - Viewed (0) -
manifests/charts/istio-operator/files/profile-compatibility-version-1.20.yaml
# If you want to make a change in this file, edit the original one and run "make gen". pilot: env: # 1.21 behavioral changes ENABLE_EXTERNAL_NAME_ALIAS: "false" PERSIST_OLDEST_FIRST_HEURISTIC_FOR_VIRTUAL_SERVICE_HOST_MATCHING: "true" VERIFY_CERTIFICATE_AT_CLIENT: "false" ENABLE_AUTO_SNI: "false" # 1.22 behavioral changes ENABLE_RESOLUTION_NONE_TARGET_PORT: "false" meshConfig:
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 03 02:25:06 GMT 2024 - 707 bytes - Viewed (0)