- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 49 for Closed (0.21 sec)
-
cni/pkg/nodeagent/net_test.go
// and it is flake-prone to check for closure after calling it, this retries for a bit to make // sure the netns is closed eventually. func assertNSClosed(t *testing.T, closed *atomic.Bool) { for i := 0; i < 5; i++ { if closed.Load() { return } time.Sleep(1 * time.Second) } t.Fatal("NS not closed")
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
pods: pods, }, nil } func (z *ztunnelServer) Close() error { return z.listener.Close() } func (z *ztunnelServer) Run(ctx context.Context) { context.AfterFunc(ctx, func() { _ = z.Close() }) for { log.Debug("accepting conn") conn, err := z.accept() if err != nil { if errors.Is(err, net.ErrClosed) { log.Debug("listener closed - returning") return }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/nodeagent/fakes_test.go
return &fakeNs{closed: &atomic.Bool{}, fd: fd, inode: inode} } // Fd returns the file descriptor func (f *fakeNs) Fd() uintptr { return f.fd } func (f *fakeNs) Inode() uint64 { return f.inode } // Close simulates closing the file descriptor and returns nil for no error func (f *fakeNs) Close() error { f.closed.Store(true) return nil } func fakeFs() fs.FS {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0) -
common-protos/k8s.io/api/core/v1/generated.proto
// first client attaches to stdin, and then remains open and accepts data until the client disconnects, // at which time stdin is closed and remains closed until the container is restarted. If this // flag is false, a container processes that reads from stdin will never receive an EOF. // Default is false // +optional optional bool stdinOnce = 17;
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 255.8K bytes - Viewed (0) -
cni/pkg/log/uds.go
}() go func() { <-stop if err := l.loggingServer.Close(); err != nil { log.Errorf("CNI log server terminated with error: %v", err) } else { log.Debug("CNI log server terminated") } }() return nil } func (l *UDSLogger) handleLog(w http.ResponseWriter, req *http.Request) { if req.Body == nil { return } defer req.Body.Close() data, err := io.ReadAll(req.Body) if err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
istioctl/pkg/kubeinject/testdata/mesh-config.yaml
# has no effect on outbound traffic: iptables REDIRECT is always used for # outbound connections. # If "REDIRECT", use iptables REDIRECT to NAT and redirect to Envoy. # The "REDIRECT" mode loses source addresses during redirection. # If "TPROXY", use iptables TPROXY to redirect to Envoy. # The "TPROXY" mode preserves both the source and destination IP
Others - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 2.2K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
if err != nil { return fmt.Errorf("could not build port forwarder for %s: %v", flavor, err) } if err = fw.Start(); err != nil { fw.Close() // Try the next port continue } // Close the port forwarder when the command is terminated. ClosePortForwarderOnInterrupt(fw) log.Debugf(fmt.Sprintf("port-forward to %s pod ready", flavor))
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
} return filepath.Join(cfg.mountedCNINetDir, filename), nil } watcher, err := util.CreateFileWatcher(cfg.mountedCNINetDir) if err != nil { return "", err } defer watcher.Close() for len(filename) == 0 { filename, err = getDefaultCNINetwork(cfg.mountedCNINetDir) if err == nil { break }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
res.Write([]byte("server not happy")) return } res.WriteHeader(http.StatusOK) res.Write([]byte("server happy")) })) return testServer.URL, func() bool { testServer.Close() return cniAddServerCalled } } func buildCmdArgs(stdinData, podName, podNamespace string) *skel.CmdArgs { return &skel.CmdArgs{ ContainerID: "testContainerID", Netns: testSandboxDirectory,
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
} func closeNetns(netns NetnsCloser) { netns.Close() } func (p *podNetnsCache) ReadCurrentPodSnapshot() map[string]WorkloadInfo { p.mu.RLock() defer p.mu.RUnlock() // snapshot the cache to avoid long locking return maps.Clone(p.currentPodCache) } // Remove and return the Netns for the given uid // No need to return NetnsCloser here it will be closed automatically on GC.
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0)