Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for wrapSyscallError (0.97 sec)

  1. src/net/tcpsockopt_solaris.go

    	}
    	// The kernel expects seconds so round to next highest second.
    	secs := int(roundDurationUp(d, time.Second))
    	err := fd.pfd.SetsockoptInt(syscall.IPPROTO_TCP, sysTCP_KEEPIDLE, secs)
    	runtime.KeepAlive(fd)
    	return wrapSyscallError("setsockopt", err)
    }
    
    func setKeepAliveInterval(fd *netFD, d time.Duration) error {
    	if !unix.SupportTCPKeepAliveIdleIntvlCNT() {
    		return syscall.EPROTOTYPE
    	}
    
    	if d == 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. src/net/tcpsockopt_darwin.go

    	runtime.KeepAlive(fd)
    	return wrapSyscallError("setsockopt", err)
    }
    
    func setKeepAliveCount(fd *netFD, n int) error {
    	if n == 0 {
    		n = defaultTCPKeepAliveCount
    	} else if n < 0 {
    		return nil
    	}
    
    	err := fd.pfd.SetsockoptInt(syscall.IPPROTO_TCP, sysTCP_KEEPCNT, n)
    	runtime.KeepAlive(fd)
    	return wrapSyscallError("setsockopt", err)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  3. src/net/sockopt_posix.go

    	err := fd.pfd.SetsockoptInt(syscall.SOL_SOCKET, syscall.SO_RCVBUF, bytes)
    	runtime.KeepAlive(fd)
    	return wrapSyscallError("setsockopt", err)
    }
    
    func setWriteBuffer(fd *netFD, bytes int) error {
    	err := fd.pfd.SetsockoptInt(syscall.SOL_SOCKET, syscall.SO_SNDBUF, bytes)
    	runtime.KeepAlive(fd)
    	return wrapSyscallError("setsockopt", err)
    }
    
    func setKeepAlive(fd *netFD, keepalive bool) error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Aug 25 15:06:47 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  4. src/net/sockoptip_windows.go

    	err = fd.pfd.SetsockoptInet4Addr(syscall.IPPROTO_IP, syscall.IP_MULTICAST_IF, a)
    	runtime.KeepAlive(fd)
    	return wrapSyscallError("setsockopt", err)
    }
    
    func setIPv4MulticastLoopback(fd *netFD, v bool) error {
    	err := fd.pfd.SetsockoptInt(syscall.IPPROTO_IP, syscall.IP_MULTICAST_LOOP, boolint(v))
    	runtime.KeepAlive(fd)
    	return wrapSyscallError("setsockopt", err)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Aug 30 19:09:46 UTC 2023
    - 786 bytes
    - Viewed (0)
  5. src/net/tcpsockopt_unix.go

    	runtime.KeepAlive(fd)
    	return wrapSyscallError("setsockopt", err)
    }
    
    func setKeepAliveCount(fd *netFD, n int) error {
    	if n == 0 {
    		n = defaultTCPKeepAliveCount
    	} else if n < 0 {
    		return nil
    	}
    
    	err := fd.pfd.SetsockoptInt(syscall.IPPROTO_TCP, syscall.TCP_KEEPCNT, n)
    	runtime.KeepAlive(fd)
    	return wrapSyscallError("setsockopt", err)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:17:21 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  6. src/net/fd_fake.go

    		return nil
    	}
    	err := fd.pfd.Shutdown(how)
    	runtime.KeepAlive(fd)
    	return wrapSyscallError("shutdown", err)
    }
    
    func (fd *netFD) Read(p []byte) (n int, err error) {
    	if fd.fakeNetFD != nil {
    		return fd.fakeNetFD.Read(p)
    	}
    	n, err = fd.pfd.Read(p)
    	runtime.KeepAlive(fd)
    	return n, wrapSyscallError(readSyscallName, err)
    }
    
    func (fd *netFD) Write(p []byte) (nn int, err error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Nov 20 15:56:08 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  7. src/os/zero_copy_linux.go

    	"internal/poll"
    	"io"
    	"syscall"
    )
    
    var (
    	pollCopyFileRange = poll.CopyFileRange
    	pollSplice        = poll.Splice
    )
    
    // wrapSyscallError takes an error and a syscall name. If the error is
    // a syscall.Errno, it wraps it in an os.SyscallError using the syscall name.
    func wrapSyscallError(name string, err error) error {
    	if _, ok := err.(syscall.Errno); ok {
    		err = NewSyscallError(name, err)
    	}
    	return err
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 18:12:56 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. src/net/error_posix.go

    //go:build unix || js || wasip1 || windows
    
    package net
    
    import (
    	"os"
    	"syscall"
    )
    
    // wrapSyscallError takes an error and a syscall name. If the error is
    // a syscall.Errno, it wraps it in an os.SyscallError using the syscall name.
    func wrapSyscallError(name string, err error) error {
    	if _, ok := err.(syscall.Errno); ok {
    		err = os.NewSyscallError(name, err)
    	}
    	return err
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 543 bytes
    - Viewed (0)
  9. src/net/splice_linux.go

    			return 0, nil, false
    		}
    		s = v.fd
    	default:
    		return 0, nil, false
    	}
    
    	written, handled, err = pollSplice(&c.pfd, &s.pfd, remain)
    	if lr != nil {
    		lr.N -= written
    	}
    	return written, wrapSyscallError("splice", err), handled
    }
    
    // spliceTo transfers data from c to w using the splice system call to minimize
    // copies from and to userspace. c must be a TCP connection.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:49:26 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  10. src/net/writev_unix.go

    	}
    	return n, nil
    }
    
    func (fd *netFD) writeBuffers(v *Buffers) (n int64, err error) {
    	n, err = fd.pfd.Writev((*[][]byte)(v))
    	runtime.KeepAlive(fd)
    	return n, wrapSyscallError("writev", err)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Oct 07 16:48:35 UTC 2022
    - 666 bytes
    - Viewed (0)
Back to top