Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 159 for fd (0.17 sec)

  1. okhttp/src/test/java/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: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  2. src/internal/poll/sendfile_windows.go

    package poll
    
    import (
    	"io"
    	"syscall"
    )
    
    // SendFile wraps the TransmitFile call.
    func SendFile(fd *FD, src syscall.Handle, n int64) (written int64, err error) {
    	defer func() {
    		TestHookDidSendFile(fd, 0, written, err, written > 0)
    	}()
    	if fd.kind == kindPipe {
    		// TransmitFile does not work with pipes
    		return 0, syscall.ESPIPE
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 18:12:56 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/netns.go

    import "io"
    
    type NetnsFd interface {
    	Fd() uintptr
    }
    
    type Netns interface {
    	NetnsFd
    	Inode() uint64
    }
    type NetnsCloser interface {
    	io.Closer
    	Netns
    }
    
    type NetnsWithFd struct {
    	netns io.Closer
    	fd    uintptr
    	inode uint64
    }
    
    func (n *NetnsWithFd) Close() error {
    	if n.netns == nil {
    		return nil
    	}
    
    	ret := n.netns.Close()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  4. src/net/unixsock_posix.go

    	return c.fd.writeTo(b, sa)
    }
    
    func (c *UnixConn) writeMsg(b, oob []byte, addr *UnixAddr) (n, oobn int, err error) {
    	if c.fd.sotype == syscall.SOCK_DGRAM && c.fd.isConnected {
    		return 0, 0, ErrWriteToConnected
    	}
    	var sa syscall.Sockaddr
    	if addr != nil {
    		if addr.Net != sotypeToNet(c.fd.sotype) {
    			return 0, 0, syscall.EAFNOSUPPORT
    		}
    		sa = &syscall.SockaddrUnix{Name: addr.Name}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. src/syscall/syscall_plan9.go

    	n, _ := readnum("#c/ppid")
    	return int(n)
    }
    
    func Read(fd int, p []byte) (n int, err error) {
    	return Pread(fd, p, -1)
    }
    
    func Write(fd int, p []byte) (n int, err error) {
    	if faketime && (fd == 1 || fd == 2) {
    		n = faketimeWrite(fd, p)
    		if n < 0 {
    			return 0, ErrorString("error")
    		}
    		return n, nil
    	}
    
    	return Pwrite(fd, p, -1)
    }
    
    var ioSync int64
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 21:03:59 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  6. src/internal/poll/fd_fsync_darwin.go

    // on OS X, SYS_FSYNC doesn't fully flush contents to disk.
    // See Issue #26650 as well as the man page for fsync on OS X.
    func (fd *FD) Fsync() error {
    	if err := fd.incref(); err != nil {
    		return err
    	}
    	defer fd.decref()
    	return ignoringEINTR(func() error {
    		_, err := unix.Fcntl(fd.Sysfd, syscall.F_FULLFSYNC, 0)
    
    		// There are scenarios such as SMB mounts where fcntl will fail
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 19:20:48 UTC 2024
    - 850 bytes
    - Viewed (0)
  7. src/syscall/exec_aix_test.go

    	pgrp = int(r0)
    	return
    }
    
    func Tcgetpgrp(fd int) (pgid int32, err error) {
    	if errno := ioctlPtr(uintptr(fd), TIOCGPGRP, unsafe.Pointer(&pgid)); errno != 0 {
    		return -1, errno
    	}
    	return pgid, nil
    }
    
    func Tcsetpgrp(fd int, pgid int32) (err error) {
    	return ioctlPtr(uintptr(fd), TIOCSPGRP, unsafe.Pointer(&pgid))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 22 04:41:27 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  8. src/net/tcpsockopt_stub.go

    package net
    
    import (
    	"syscall"
    	"time"
    )
    
    func setNoDelay(fd *netFD, noDelay bool) error {
    	return syscall.ENOPROTOOPT
    }
    
    func setKeepAliveIdle(fd *netFD, d time.Duration) error {
    	return syscall.ENOPROTOOPT
    }
    
    func setKeepAliveInterval(fd *netFD, d time.Duration) error {
    	return syscall.ENOPROTOOPT
    }
    
    func setKeepAliveCount(fd *netFD, n int) error {
    	return syscall.ENOPROTOOPT
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 570 bytes
    - Viewed (0)
  9. src/syscall/exec_solaris_test.go

    	pgrp = int(r0)
    	return
    }
    
    func Tcgetpgrp(fd int) (pgid int32, err error) {
    	if errno := ioctlPtr(uintptr(fd), TIOCGPGRP, unsafe.Pointer(&pgid)); errno != 0 {
    		return -1, errno
    	}
    	return pgid, nil
    }
    
    func Tcsetpgrp(fd int, pgid int32) (err error) {
    	return ioctlPtr(uintptr(fd), TIOCSPGRP, unsafe.Pointer(&pgid))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 22 04:41:27 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  10. src/syscall/export_bsd_test.go

    )
    
    // pgid should really be pid_t, however _C_int (aka int32) is generally
    // equivalent.
    
    func Tcgetpgrp(fd int) (pgid int32, err error) {
    	if err := ioctlPtr(fd, TIOCGPGRP, unsafe.Pointer(&pgid)); err != nil {
    		return -1, err
    	}
    	return pgid, nil
    }
    
    func Tcsetpgrp(fd int, pgid int32) (err error) {
    	return ioctlPtr(fd, TIOCSPGRP, unsafe.Pointer(&pgid))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 22 04:41:27 UTC 2024
    - 619 bytes
    - Viewed (0)
Back to top