- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,957 for closeFn (0.24 sec)
-
src/runtime/os_wasm.go
func sigignore(uint32) {} // Stubs so tests can link correctly. These should never be called. func open(name *byte, mode, perm int32) int32 { panic("not implemented") } func closefd(fd int32) int32 { panic("not implemented") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/filewatcher/filewatcher.go
newWatcher: fsnotify.NewWatcher, addWatcherPath: func(watcher *fsnotify.Watcher, path string) error { return watcher.Add(path) }, }, } } // Close releases all resources associated with the watcher func (fw *fileWatcher) Close() error { fw.mu.Lock() defer fw.mu.Unlock() for _, ws := range fw.workers { ws.worker.terminate() } fw.workers = nil return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
go func() { select { case <-stopCh: cancel() // stopCh closed, so cancel our context case <-ctx.Done(): } }() // start controllers if possible if controller, ok := s.ClientCA.(dynamiccertificates.ControllerRunner); ok { // runonce to try to prime data. If this fails, it's ok because we fail closed. // Files are required to be populated already, so this is for convenience.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0) -
platforms/core-runtime/io/src/test/groovy/org/gradle/internal/io/LinePerThreadBufferingOutputStreamTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:13 UTC 2024 - 3K bytes - Viewed (0) -
pkg/kube/portforwarder.go
return nil } } func (f *forwarder) Address() string { return net.JoinHostPort(f.localAddress, strconv.Itoa(f.localPort)) } func (f *forwarder) Close() { close(f.stopCh) // Closing the stop channel should close anything // opened by f.forwarder.ForwardPorts() } func (f *forwarder) ErrChan() <-chan error { return f.errCh } func (f *forwarder) WaitForStop() { <-f.stopCh
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 5.5K bytes - Viewed (0) -
src/net/http/serve_test.go
} t.Cleanup(func() { bresp.Body.Close() }) // Try to cause a race. Canceling the client request will cause the client // transport to close req2.Body. Returning from the server handler will // cause the server to close req.Body. Since they are the same underlying // ReadCloser, that will result in concurrent calls to Close (and possibly a // Read concurrent with a Close). if mode == http2Mode {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseCommonTest.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.6K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/instance.go
if p == nil { return nil, fmt.Errorf("no protocol handler found for scheme %s", cfg.scheme) } return p.ForwardEcho(ctx, cfg) } func (i *Instance) Close() error { i.e.Close() for _, p := range i.protocols { _ = p.Close() } return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 13 17:19:22 UTC 2022 - 2.3K bytes - Viewed (0) -
src/mime/multipart/formdata.go
type File interface { io.Reader io.ReaderAt io.Seeker io.Closer } // helper types to turn a []byte into a File type sectionReadCloser struct { *io.SectionReader io.Closer } func (rc sectionReadCloser) Close() error { if rc.Closer != nil { return rc.Closer.Close() } return nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/wasm/httpfetcher.go
err = resp.Body.Close() if err != nil { wasmLog.Infof("wasm server connection is not closed: %v", err) } time.Sleep(b.NextBackOff()) continue } err = resp.Body.Close() if err != nil { wasmLog.Infof("wasm server connection is not closed: %v", err) } break }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 5.5K bytes - Viewed (0)