Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 301 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_windows.go

    		err := syscall.WSAIoctl(fd.Sysfd, syscall.SIO_UDP_CONNRESET, (*byte)(unsafe.Pointer(&flag)), size, nil, 0, &ret, nil, 0)
    		if err != nil {
    			return "wsaioctl", err
    		}
    	}
    	fd.rop.mode = 'r'
    	fd.wop.mode = 'w'
    	fd.rop.fd = fd
    	fd.wop.fd = fd
    	fd.rop.runtimeCtx = fd.pd.runtimeCtx
    	fd.wop.runtimeCtx = fd.pd.runtimeCtx
    	return "", nil
    }
    
    func (fd *FD) destroy() error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 31 16:50:42 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  4. src/net/tcpsock_windows.go

    			return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    		}
    	} else if err := setKeepAliveIdleAndInterval(c.fd, config.Idle, config.Interval); err != nil {
    		return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    	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}
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 21 11:49:35 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  5. 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)
  6. src/net/file_plan9.go

    	if err != nil {
    		return nil, err
    	}
    
    	switch fd.laddr.(type) {
    	case *TCPAddr:
    		return newTCPConn(fd, defaultTCPKeepAliveIdle, KeepAliveConfig{}, testPreHookSetKeepAlive, testHookSetKeepAlive), nil
    	case *UDPAddr:
    		return newUDPConn(fd), nil
    	}
    	return nil, syscall.EPLAN9
    }
    
    func fileListener(f *os.File) (Listener, error) {
    	fd, err := newFileFD(f)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  7. src/net/rawconn.go

    	if !c.ok() {
    		return syscall.EINVAL
    	}
    	err := c.fd.pfd.RawRead(f)
    	runtime.KeepAlive(c.fd)
    	if err != nil {
    		err = &OpError{Op: "raw-read", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    	return err
    }
    
    func (c *rawConn) Write(f func(uintptr) bool) error {
    	if !c.ok() {
    		return syscall.EINVAL
    	}
    	err := c.fd.pfd.RawWrite(f)
    	runtime.KeepAlive(c.fd)
    	if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  8. 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)
  9. src/net/unixsock.go

    		return nil, syscall.EINVAL
    	}
    	return newRawConn(c.fd), nil
    }
    
    // CloseRead shuts down the reading side of the Unix domain connection.
    // Most callers should just use Close.
    func (c *UnixConn) CloseRead() error {
    	if !c.ok() {
    		return syscall.EINVAL
    	}
    	if err := c.fd.closeRead(); err != nil {
    		return &OpError{Op: "close", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    	return nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  10. src/internal/poll/writev.go

    	"runtime"
    	"syscall"
    )
    
    // Writev wraps the writev system call.
    func (fd *FD) Writev(v *[][]byte) (int64, error) {
    	if err := fd.writeLock(); err != nil {
    		return 0, err
    	}
    	defer fd.writeUnlock()
    	if err := fd.pd.prepareWrite(fd.isFile); err != nil {
    		return 0, err
    	}
    
    	var iovecs []syscall.Iovec
    	if fd.iovecs != nil {
    		iovecs = *fd.iovecs
    	}
    	// TODO: read from sysconf(_SC_IOV_MAX)? The Linux default is
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 27 18:23:49 UTC 2024
    - 1.8K bytes
    - Viewed (0)
Back to top