- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for Fd (0.02 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/RequestBodyTest.kt
@Test fun testFileDescriptor() { assertOnFileDescriptor { fd -> val requestBody = fd.toRequestBody() assertThat(requestBody.contentLength()).isEqualTo(-1L) assertThat(requestBody.isOneShot()).isEqualTo(true) } } @Test fun testFileDescriptorRead() { assertOnFileDescriptor(content = "Hello") { fd -> val requestBody = fd.toRequestBody() val buffer = Buffer()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Oct 07 14:16:29 UTC 2025 - 3.8K bytes - Viewed (1) -
cmd/os_unix.go
} return nil } // openFileWithFD return 'fd' based file descriptor func openFileWithFD(name string, flag int, perm os.FileMode) (fd int, err error) { switch flag & writeMode { case writeMode: defer updateOSMetrics(osMetricOpenFileWFd, name)(err) default: defer updateOSMetrics(osMetricOpenFileRFd, name)(err) } var e error fd, e = syscall.Open(name, flag|syscall.O_CLOEXEC, uint32(perm)) if e != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 9.3K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbPipeInputStreamTest.java
InOrder inOrder = inOrder(handle, fd, tree); inOrder.verify(handle, times(1)).ensureOpen(); inOrder.verify(fd, times(1)).getTree(); inOrder.verify(tree, times(1)).send(any(Smb2IoctlRequest.class), eq(RequestParam.NO_RETRY)); verify(fd, times(1)).close(); verify(tree, times(1)).close(); } @ParameterizedTest
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 9.9K bytes - Viewed (0) -
internal/lock/lock_windows.go
fd, err := syscall.CreateFile(pathp, access, shareflag, nil, createflag, accessAttr, 0) if err != nil { return nil, err } return os.NewFile(uintptr(fd), path), nil } func lockFile(fd syscall.Handle, flags uint32) error { // https://msdn.microsoft.com/en-us/library/windows/desktop/aa365203(v=vs.85).aspx if fd == syscall.InvalidHandle { return nil }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 7.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbPipeInputStream.java
*/ @Override public int available() throws IOException { try (SmbFileHandleImpl fd = this.handle.ensureOpen(); SmbTreeHandleImpl th = fd.getTree()) { if (th.isSMB2()) { final Smb2IoctlRequest req = new Smb2IoctlRequest(th.getConfig(), Smb2IoctlRequest.FSCTL_PIPE_PEEK, fd.getFileId()); req.setMaxOutputResponse(16);Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 3.8K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileInputStream.java
throw new IOException("Bad file descriptor"); } // ensure file is open try (SmbFileHandleImpl fd = ensureOpen(); SmbTreeHandleImpl th = fd.getTree()) { if (log.isTraceEnabled()) { log.trace("read: fid=" + fd + ",off=" + off + ",len=" + len); } final int type = this.file.getType(); int r, n;
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 15.6K bytes - Viewed (0) -
src/main/java/jcifs/SmbPipeHandle.java
/** * Tests whether this file descriptor is open and valid. * * @return whether the FD is open and valid */ boolean isOpen(); /** * Tests whether this file descriptor was previously open but has become invalid. * * @return whether the FD was previously open but became invalid */ boolean isStale(); /**Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.4K bytes - Viewed (0) -
src/cmd/asm/internal/lex/input.go
} in.expectNewline("#include") // Push tokenizer for file onto stack. fd, err := os.Open(name) if err != nil { for _, dir := range in.includes { fd, err = os.Open(filepath.Join(dir, name)) if err == nil { break } } if err != nil { in.Error("#include:", err) } } in.Push(NewTokenizer(name, fd, fd)) } // #line processing. func (in *Input) line() {
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Wed Nov 12 03:59:40 UTC 2025 - 12.4K bytes - Viewed (0) -
cmd/metacache-set.go
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 30.7K bytes - Viewed (0) -
cmd/common-main.go
currentReleaseTime time.Time orchestrated = IsKubernetes() || IsDocker() ) func init() { if !term.IsTerminal(int(os.Stdout.Fd())) || !term.IsTerminal(int(os.Stderr.Fd())) { color.TurnOff() } if env.Get("NO_COLOR", "") != "" || env.Get("TERM", "") == "dumb" { color.TurnOff() } if runtime.GOOS == "windows" { if mousetrap.StartedByExplorer() {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 32.5K bytes - Viewed (3)