Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 541 for fd (0.06 sec)

  1. src/internal/poll/fd_mutex.go

    	if fd.fdmu.rwunlock(true) {
    		fd.destroy()
    	}
    }
    
    // writeLock adds a reference to fd and locks fd for writing.
    // It returns an error when fd cannot be used for writing.
    func (fd *FD) writeLock() error {
    	if !fd.fdmu.rwlock(false) {
    		return errClosing(fd.isFile)
    	}
    	return nil
    }
    
    // writeUnlock removes a reference from fd and unlocks fd for writing.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 20 16:55:30 UTC 2018
    - 6.4K bytes
    - Viewed (0)
  2. src/net/sockoptip_posix.go

    	var v int
    	if ifi != nil {
    		v = ifi.Index
    	}
    	err := fd.pfd.SetsockoptInt(syscall.IPPROTO_IPV6, syscall.IPV6_MULTICAST_IF, v)
    	runtime.KeepAlive(fd)
    	return wrapSyscallError("setsockopt", err)
    }
    
    func setIPv6MulticastLoopback(fd *netFD, v bool) error {
    	err := fd.pfd.SetsockoptInt(syscall.IPPROTO_IPV6, syscall.IPV6_MULTICAST_LOOP, boolint(v))
    	runtime.KeepAlive(fd)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 29 16:24:51 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  3. pkg/proto/merge/merge.go

    	}
    
    	src.Range(func(fd protoreflect.FieldDescriptor, v protoreflect.Value) bool {
    		switch {
    		case fd.IsList():
    			o.mergeList(dst.Mutable(fd).List(), v.List(), fd)
    		case fd.IsMap():
    			o.mergeMap(dst.Mutable(fd).Map(), v.Map(), fd.MapValue())
    		case fd.Message() != nil:
    			mergeFn, exists := o.customMergeFn[fd.Message().FullName()]
    			if exists {
    				mergeFn(dst.Mutable(fd).Message(), v.Message())
    			} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Dec 21 17:31:22 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  4. src/internal/poll/fd_poll_js.go

    // SetDeadline sets the read and write deadlines associated with fd.
    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 25 00:12:40 UTC 2023
    - 2.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/internal/poll/fd_posix.go

    // Fchown wraps syscall.Fchown.
    func (fd *FD) Fchown(uid, gid int) error {
    	if err := fd.incref(); err != nil {
    		return err
    	}
    	defer fd.decref()
    	return ignoringEINTR(func() error {
    		return syscall.Fchown(fd.Sysfd, uid, gid)
    	})
    }
    
    // Ftruncate wraps syscall.Ftruncate.
    func (fd *FD) Ftruncate(size int64) error {
    	if err := fd.incref(); err != nil {
    		return err
    	}
    	defer fd.decref()
    	return ignoringEINTR(func() error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 07 23:34:17 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  8. src/net/fd_plan9.go

    	return ret, nil
    }
    
    func (fd *netFD) init() error {
    	// stub for future fd.pd.Init(fd)
    	return nil
    }
    
    func (fd *netFD) name() string {
    	var ls, rs string
    	if fd.laddr != nil {
    		ls = fd.laddr.String()
    	}
    	if fd.raddr != nil {
    		rs = fd.raddr.String()
    	}
    	return fd.net + ":" + ls + "->" + rs
    }
    
    func (fd *netFD) ok() bool { return fd != nil && fd.ctl != nil }
    
    func (fd *netFD) destroy() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 04 16:01:50 UTC 2018
    - 3.6K bytes
    - Viewed (0)
  9. 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)
  10. src/net/sockopt_posix.go

    	}
    	return nil
    }
    
    func setReadBuffer(fd *netFD, bytes int) error {
    	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)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Aug 25 15:06:47 UTC 2023
    - 2.1K bytes
    - Viewed (0)
Back to top