- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,754 for closeFn (0.14 sec)
-
src/cmd/cgo/internal/testcarchive/testdata/libgo2/libgo2.go
int fds[2]; if (pipe(fds) == -1) { perror("pipe"); exit(EXIT_FAILURE); } // Close the reader end close(fds[0]); // Write to the writer end to provoke a SIGPIPE if (write(fds[1], "some data", 9) != -1) { fprintf(stderr, "write to a closed pipe succeeded\n"); exit(EXIT_FAILURE); } close(fds[1]); } */ import "C" import ( "fmt" "os" "runtime" )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 1.6K bytes - Viewed (0) -
src/net/http/server.go
listenerGroup sync.WaitGroup } // Close immediately closes all active net.Listeners and any // connections in state [StateNew], [StateActive], or [StateIdle]. For a // graceful shutdown, use [Server.Shutdown]. // // Close does not attempt to close (and does not even know about) // any hijacked connections, such as WebSockets. // // Close returns any error returned from closing the [Server]'s
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
src/net/internal/socktest/switch.go
Accepted uint64 // number of sockets accepted Closed uint64 // number of sockets closed OpenFailed uint64 // number of sockets open failed ConnectFailed uint64 // number of sockets connect failed ListenFailed uint64 // number of sockets listen failed AcceptFailed uint64 // number of sockets accept failed CloseFailed uint64 // number of sockets close failed } func (st Stat) String() string {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4.8K bytes - Viewed (0) -
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)