Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 197 for fd (0.02 sec)

  1. src/internal/poll/fd_unix.go

    	// so this must be executed before CloseFunc.
    	fd.pd.close()
    
    	err := fd.SysFile.destroy(fd.Sysfd)
    
    	fd.Sysfd = -1
    	runtime_Semrelease(&fd.csema)
    	return err
    }
    
    // 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)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 04:09:44 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  2. src/internal/poll/fd_plan9.go

    }
    
    func setDeadlineImpl(fd *FD, t time.Time, mode int) error {
    	d := t.Sub(time.Now())
    	if mode == 'r' || mode == 'r'+'w' {
    		fd.rmu.Lock()
    		defer fd.rmu.Unlock()
    		if fd.rtimer != nil {
    			fd.rtimer.Stop()
    			fd.rtimer = nil
    		}
    		fd.rtimedout = false
    	}
    	if mode == 'w' || mode == 'r'+'w' {
    		fd.wmu.Lock()
    		defer fd.wmu.Unlock()
    		if fd.wtimer != nil {
    			fd.wtimer.Stop()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 06 14:00:54 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  3. src/internal/poll/fd_poll_runtime.go

    func (fd *FD) SetDeadline(t time.Time) error {
    	return setDeadlineImpl(fd, t, 'r'+'w')
    }
    
    // SetReadDeadline sets the read deadline associated with fd.
    func (fd *FD) SetReadDeadline(t time.Time) error {
    	return setDeadlineImpl(fd, t, 'r')
    }
    
    // SetWriteDeadline sets the write deadline associated with fd.
    func (fd *FD) SetWriteDeadline(t time.Time) error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:18:59 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. src/net/tcpsock_unix.go

    		return syscall.EINVAL
    	}
    
    	if err := setKeepAlive(c.fd, config.Enable); err != nil {
    		return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    	if err := setKeepAliveIdle(c.fd, config.Idle); err != nil {
    		return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    	if err := setKeepAliveInterval(c.fd, config.Interval); err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  5. src/net/tcpsock_solaris.go

    		}
    		if err := setKeepAliveCount(c.fd, config.Count); err != nil {
    			return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    		}
    	} else if err := setKeepAliveIdleAndIntervalAndCount(c.fd, config.Idle, config.Interval, config.Count); err != nil {
    		return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  6. src/syscall/fs_wasip1.go

    			pathLen,
    			oflags|OFLAG_DIRECTORY,
    			rights&dirRights,
    			fileRights,
    			fdflags,
    			unsafe.Pointer(&fd),
    		)
    	}
    	return int(fd), errnoErr(errno)
    }
    
    func Close(fd int) error {
    	errno := fd_close(int32(fd))
    	return errnoErr(errno)
    }
    
    func CloseOnExec(fd int) {
    	// nothing to do - no exec
    }
    
    func Mkdir(path string, perm uint32) error {
    	if path == "" {
    		return EINVAL
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  7. src/net/tcpconn_keepalive_illumos_test.go

    	"time"
    )
    
    func getCurrentKeepAliveSettings(fd fdType) (cfg KeepAliveConfig, err error) {
    	tcpKeepAlive, err := syscall.GetsockoptInt(fd, syscall.SOL_SOCKET, syscall.SO_KEEPALIVE)
    	if err != nil {
    		return
    	}
    	tcpKeepAliveIdle, err := syscall.GetsockoptInt(fd, syscall.IPPROTO_TCP, syscall_TCP_KEEPIDLE)
    	if err != nil {
    		return
    	}
    	tcpKeepAliveInterval, err := syscall.GetsockoptInt(fd, syscall.IPPROTO_TCP, syscall_TCP_KEEPINTVL)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:17:21 UTC 2024
    - 4K bytes
    - Viewed (0)
  8. src/internal/poll/fd_wasip1.go

    	return CloseFunc(fd)
    }
    
    // Copy creates a copy of the FD.
    //
    // The FD instance points to the same underlying file descriptor. The file
    // descriptor isn't closed until all FD instances that refer to it have been
    // closed/destroyed.
    func (fd *FD) Copy() FD {
    	return FD{
    		Sysfd:         fd.Sysfd,
    		SysFile:       fd.SysFile.ref(),
    		IsStream:      fd.IsStream,
    		ZeroReadIsEOF: fd.ZeroReadIsEOF,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 20:14:02 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  9. src/net/tcpsock_posix.go

    }
    
    func (ln *TCPListener) ok() bool { return ln != nil && ln.fd != nil }
    
    func (ln *TCPListener) accept() (*TCPConn, error) {
    	fd, err := ln.fd.accept()
    	if err != nil {
    		return nil, err
    	}
    	return newTCPConn(fd, ln.lc.KeepAlive, ln.lc.KeepAliveConfig, testPreHookSetKeepAlive, testHookSetKeepAlive), nil
    }
    
    func (ln *TCPListener) close() error {
    	return ln.fd.Close()
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  10. src/net/tcpconn_keepalive_solaris_test.go

    //go:build solaris && !illumos
    
    package net
    
    import (
    	"internal/syscall/unix"
    	"syscall"
    	"testing"
    	"time"
    )
    
    func getCurrentKeepAliveSettings(fd fdType) (cfg KeepAliveConfig, err error) {
    	tcpKeepAlive, err := syscall.GetsockoptInt(fd, syscall.SOL_SOCKET, syscall.SO_KEEPALIVE)
    	if err != nil {
    		return
    	}
    
    	var (
    		tcpKeepAliveIdle         int
    		tcpKeepAliveInterval     int
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 5.7K bytes
    - Viewed (0)
Back to top