- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 50 for fclose (0.49 sec)
-
cni/pkg/pluginlistener/listener_test.go
f := filepath.Join(t.TempDir(), "test") l, err := NewListener(f) if err != nil { t.Fatalf("unexpected error %v", err) } defer l.Close() conn, err := connect(f) if err != nil { t.Fatalf("failed to connect %v", err) } conn.Close() } func connect(socket string) (*grpc.ClientConn, error) { var opts []grpc.DialOption
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 21:58:32 GMT 2024 - 1.4K bytes - Viewed (0) -
manifests/charts/istiod-remote/templates/crd-all.gen.yaml
failStrategy: description: |- Specifies the failure behavior for the plugin due to fatal errors. Valid Options: FAIL_CLOSE, FAIL_OPEN enum: - FAIL_CLOSE - FAIL_OPEN type: string imagePullPolicy: description: |-
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:47 GMT 2024 - 606.1K 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 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
cni/pkg/nodeagent/netns_linux.go
) type NetnsWrapper struct { innerNetns netns.NetNS inode uint64 } func (n *NetnsWrapper) Inode() uint64 { return n.inode } func (n *NetnsWrapper) Close() error { return n.innerNetns.Close() } func (n *NetnsWrapper) Fd() uintptr { return n.innerNetns.Fd() } func inodeForFd(n NetnsFd) (uint64, error) { stats := &unix.Stat_t{} err := unix.Fstat(int(n.Fd()), stats)
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_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/ztunnelserver_test.go
panic("expected snapshot sent") } sendAck(ztunClient) ztunClient.Close() // this will retry for a bit, so shouldn't flake mt.Assert(ztunnelConnected.Name(), nil, monitortest.Exactly(0)) } func podAndNetns() (*v1.Pod, *fakeNs) { devNull, err := os.Open(os.DevNull) if err != nil { panic(err) } // we can't close this now, because we need to pass it from the ztunnel server to the client
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger() pluginLog.SetOutputLevel(log.DebugLevel) // this will be configured by global.logging.level stop := make(chan struct{}) defer close(stop) assert.NoError(t, logger.StartUDSLogServer(udsSock, stop)) // Configure log to tee to UDS server stdout := os.Stdout r, w, _ := os.Pipe() os.Stdout = w loggingOptions := log.DefaultOptions()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
} req, err := http.NewRequest(http.MethodPut, c.baseURL.String()+"/"+scope.Name, &jsonScopeInfo) if err != nil { return err } defer req.Body.Close() resp, err := c.httpClient.Do(req) if err != nil { return err } defer resp.Body.Close() if resp.StatusCode != http.StatusAccepted { return fmt.Errorf("cannot update resource %s, got status %s", scope.Name, resp.Status) } return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
} } warning, err := v.validateFile(path, istioNamespace, defaultNamespace, reader, writer) if err != nil { errs = multierror.Append(errs, err) } err = reader.Close() if err != nil { log.Infof("file: %s is not closed: %v", path, err) } warningsByFilename[path] = warning } processDirectory := func(directory string, processFile func(string)) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
} else { var in *os.File if in, err = os.Open(inFilename); err != nil { return err } reader = in defer func() { if errClose := in.Close(); errClose != nil { log.Errorf("Error: close file from %s, %s", inFilename, errClose) // don't overwrite the previous error if err == nil { err = errClose } } }() }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0)