Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. src/internal/poll/fd.go

    // exported APIs (now we've got some in net.rawConn) which are only used
    // internally and are not intended to be used outside the standard libraries,
    // Therefore, we make those APIs use internal types like poll.FD or poll.String
    // in their function signatures to disable the usability of these APIs from
    // external codebase.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Nov 17 23:16:28 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. src/net/fd_fake.go

    	}
    	return netfd, nil
    }
    
    func (fd *netFD) setAddr(laddr, raddr Addr) {
    	fd.laddr = laddr
    	fd.raddr = raddr
    	runtime.SetFinalizer(fd, (*netFD).Close)
    }
    
    func (fd *netFD) Close() error {
    	if fd.fakeNetFD != nil {
    		return fd.fakeNetFD.Close()
    	}
    	runtime.SetFinalizer(fd, nil)
    	return fd.pfd.Close()
    }
    
    func (fd *netFD) shutdown(how int) error {
    	if fd.fakeNetFD != nil {
    		return nil
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Nov 20 15:56:08 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  5. 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)
  6. src/net/sock_posix.go

    	}
    	return fd, nil
    }
    
    func (fd *netFD) ctrlNetwork() string {
    	switch fd.net {
    	case "unix", "unixgram", "unixpacket":
    		return fd.net
    	}
    	switch fd.net[len(fd.net)-1] {
    	case '4', '6':
    		return fd.net
    	}
    	if fd.family == syscall.AF_INET {
    		return fd.net + "4"
    	}
    	return fd.net + "6"
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  7. src/net/fd_posix.go

    	return fd.pfd.Close()
    }
    
    func (fd *netFD) shutdown(how int) error {
    	err := fd.pfd.Shutdown(how)
    	runtime.KeepAlive(fd)
    	return wrapSyscallError("shutdown", err)
    }
    
    func (fd *netFD) closeRead() error {
    	return fd.shutdown(syscall.SHUT_RD)
    }
    
    func (fd *netFD) closeWrite() error {
    	return fd.shutdown(syscall.SHUT_WR)
    }
    
    func (fd *netFD) Read(p []byte) (n int, err error) {
    	n, err = fd.pfd.Read(p)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 29 16:24:51 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  8. src/syscall/net_wasip1.go

    	return ENOSYS
    }
    
    func Accept(fd int) (int, Sockaddr, error) {
    	var newfd int32
    	errno := sock_accept(int32(fd), 0, unsafe.Pointer(&newfd))
    	return int(newfd), nil, errnoErr(errno)
    }
    
    func Connect(fd int, sa Sockaddr) error {
    	return ENOSYS
    }
    
    func Recvfrom(fd int, p []byte, flags int) (n int, from Sockaddr, err error) {
    	return 0, nil, ENOSYS
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 25 00:12:41 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  9. src/cmd/vendor/golang.org/x/sys/unix/fdset.go

    package unix
    
    // Set adds fd to the set fds.
    func (fds *FdSet) Set(fd int) {
    	fds.Bits[fd/NFDBITS] |= (1 << (uintptr(fd) % NFDBITS))
    }
    
    // Clear removes fd from the set fds.
    func (fds *FdSet) Clear(fd int) {
    	fds.Bits[fd/NFDBITS] &^= (1 << (uintptr(fd) % NFDBITS))
    }
    
    // IsSet returns whether fd is in the set fds.
    func (fds *FdSet) IsSet(fd int) bool {
    	return fds.Bits[fd/NFDBITS]&(1<<(uintptr(fd)%NFDBITS)) != 0
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 781 bytes
    - Viewed (0)
  10. 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)
Back to top