- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for closerFunc (0.28 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 12:22:41 UTC 2023 - 18.7K bytes - Viewed (0) -
src/internal/poll/fd_windows.go
return syscall.EINVAL } // Poller may want to unregister fd in readiness notification mechanism, // so this must be executed before fd.CloseFunc. fd.pd.close() var err error switch fd.kind { case kindNet: // The net package uses the CloseFunc variable for testing. err = CloseFunc(fd.Sysfd) default: err = syscall.CloseHandle(fd.Sysfd) } fd.Sysfd = syscall.InvalidHandle runtime_Semrelease(&fd.csema)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 31 16:50:42 UTC 2024 - 34.1K bytes - Viewed (0) -
src/internal/poll/fd_unix.go
// no remaining references. func (fd *FD) destroy() error { // Poller may want to unregister fd in readiness notification mechanism, // so this must be executed before CloseFunc. fd.pd.close() err := fd.SysFile.destroy(fd.Sysfd) fd.Sysfd = -1 runtime_Semrelease(&fd.csema) return err } // Close closes the FD. The underlying file descriptor is closed by the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 04:09:44 UTC 2024 - 17.9K bytes - Viewed (0) -
src/net/http/clientserver_test.go
cst.tr.CloseIdleConnections() a2 := get() if a1 == a2 { t.Errorf("didn't close connection") } } type noteCloseConn struct { net.Conn closeFunc func() } func (x noteCloseConn) Close() error { x.closeFunc() return x.Conn.Close() } type testErrorReader struct{ t *testing.T } func (r testErrorReader) Read(p []byte) (n int, err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 46.6K bytes - Viewed (0)