- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,629 for closeFn (0.31 sec)
-
src/runtime/stubs2.go
"unsafe" ) // read calls the read system call. // It returns a non-negative number of bytes written or a negative errno value. func read(fd int32, p unsafe.Pointer, n int32) int32 func closefd(fd int32) int32 func exit(code int32) func usleep(usec uint32) //go:nosplit func usleep_no_g(usec uint32) { usleep(usec) } // write1 calls the write system call.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 1.1K bytes - Viewed (0) -
src/net/http/transport_internal_test.go
t.Errorf("roundTrip = %#v, %v; want errServerClosedIdle, transportReadFromServerError, or nothingWrittenError", err, err) } <-pc.closech err = pc.closed if !isNothingWrittenError(err) && !isTransportReadFromServerError(err) && err != errServerClosedIdle { t.Errorf("pc.closed = %#v, %v; want errServerClosedIdle or transportReadFromServerError, or nothingWrittenError", err, err) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 15:57:17 UTC 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
if (civilizedFileSystem) return fileSource lockingSourceCount++ return object : ForwardingSource(fileSource) { private var closed = false override fun close() { super.close() if (!closed) { closed = true synchronized(this@DiskLruCache) { lockingSourceCount-- if (lockingSourceCount == 0 && zombie) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 34.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go
t.Errorf("Until did not return immediately when the stop chan was closed inside the func") } } func TestJitterUntil(t *testing.T) { ch := make(chan struct{}) // if a channel is closed JitterUntil never calls function f // and returns immediately close(ch) JitterUntil(func() { t.Fatal("should not have been invoked") }, 0, 1.0, true, ch) ch = make(chan struct{}) called := make(chan struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 41.1K bytes - Viewed (0) -
src/internal/poll/fd_unix.go
} // Close closes the FD. The underlying file descriptor is closed by the // destroy method when there are no remaining references. func (fd *FD) Close() error { if !fd.fdmu.increfAndClose() { return errClosing(fd.isFile) } // Unblock any I/O. Once it all unblocks and returns, // so that it cannot be referring to fd.sysfd anymore, // the final decref will close fd.sysfd. This should happen
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 04:09:44 UTC 2024 - 17.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/TransformReplacer.java
} @Override public void close() { if (closed) { // Already closed. return; } closed = true; for (Loader value : loaders.values()) { IoActions.closeQuietly(value); } } private void ensureOpened() { if (closed) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 12.7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/AbstractFileLockManagerTest.groovy
thrown(IllegalStateException) } def "can close a lock multiple times"() { given: def lock = createLock(Exclusive) lock.close() expect: lock.close() } def "cannot read from file after lock has been closed"() { given: def lock = createLock(Exclusive) lock.close() when: lock.readFile({} as Supplier)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 13.6K bytes - Viewed (0) -
src/net/listen_test.go
}() if ln, err := Listen("tcp", ""); err == nil { ln.Close() } if ln, err := ListenPacket("udp", ""); err == nil { ln.Close() } if ln, err := ListenTCP("tcp", nil); err == nil { ln.Close() } if ln, err := ListenUDP("udp", nil); err == nil { ln.Close() } if ln, err := ListenIP("ip:icmp", nil); err == nil { ln.Close() } } var ipv4MulticastListenerTests = []struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 20.5K bytes - Viewed (0) -
src/net/packetconn_test.go
skipOrFatalFn() continue } c1, err := ListenPacket(tt.net, tt.addr1) if err != nil { t.Fatal(err) } defer closer(c1, tt.net, tt.addr1, tt.addr2) c1.LocalAddr() c2, err := ListenPacket(tt.net, tt.addr2) if err != nil { t.Fatal(err) } defer closer(c2, tt.net, tt.addr1, tt.addr2) c2.LocalAddr() rb2 := make([]byte, 128) if _, err := c1.WriteTo(wb, c2.LocalAddr()); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 3K bytes - Viewed (0) -
src/syscall/exec_libc.go
if err1 != 0 { goto childerror } } // By convention, we don't close-on-exec the fds we are // started with, so if len(fd) < 3, close 0, 1, 2 as needed. // Programs that know they inherit fds >= 3 will need // to set them close-on-exec. for i = len(fd); i < 3; i++ { closeFD(uintptr(i)) } // Detach fd 0 from tty if sys.Noctty { err1 = ioctl(0, uintptr(TIOCNOTTY), 0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 29 18:51:35 UTC 2023 - 8.2K bytes - Viewed (0)