Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for Fd (0.01 sec)

  1. 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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.6K bytes
    - Viewed (1)
  2. 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: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  3. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  4. lib/wasm/wasm_exec.js

    					return;
    				}
    				const n = this.writeSync(fd, buf);
    				callback(null, n);
    			},
    			chmod(path, mode, callback) { callback(enosys()); },
    			chown(path, uid, gid, callback) { callback(enosys()); },
    			close(fd, callback) { callback(enosys()); },
    			fchmod(fd, mode, callback) { callback(enosys()); },
    			fchown(fd, uid, gid, callback) { callback(enosys()); },
    			fstat(fd, callback) { callback(enosys()); },
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Sun Dec 08 15:34:47 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  5. 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: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  6. 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: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  7. 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: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  8. cmd/metacache-set.go

    			fdMu.Lock()
    			defer fdMu.Unlock()
    			if len(fds) == 0 {
    				return nil
    			}
    			fdsCopy := fds
    			for _, fd := range fdsCopy {
    				// Grab a fallback disk
    				fds = fds[1:]
    				if fd != nil && fd.IsOnline() {
    					return fd
    				}
    			}
    		}
    		// Either no more disks for fallback or
    		// not a storage error.
    		return nil
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.7K bytes
    - Viewed (0)
  9. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
  10. src/archive/zip/reader_test.go

    00001d0 92 7d 66 d8 08 8d a5 1f 54 2a af 09 cf 61 ff d2
    00001e0 85 9d 8f b6 d7 88 07 4a 86 03 db 64 f3 d9 92 73
    00001f0 df ec a7 fc 23 4c 8d 83 79 63 2a d9 fd 8d b3 c8
    0000200 8f 7e d4 19 85 e6 8d 1c 76 f0 8b 58 32 fd 9a d6
    0000210 85 e2 48 ad c3 d5 60 6f 7e 22 dd ef 09 49 7c 7f
    0000220 3a 45 c3 71 b7 df f3 4c 63 fb b5 d9 31 5f 6e d6
    0000230 24 1d a4 4a fe 32 a7 5c 16 48 5c 3e 08 6b 8a d3
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Mar 11 22:19:38 UTC 2025
    - 56.6K bytes
    - Viewed (0)
Back to top