Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SetReadDeadline (0.09 sec)

  1. internal/deadlineconn/deadlineconn.go

    	writeDeadline time.Duration // sets the write deadline on a connection.
    	writeSetAt    time.Time
    }
    
    // Sets read deadline
    func (c *DeadlineConn) setReadDeadline() {
    	if c.readDeadline > 0 {
    		now := time.Now()
    		if now.Sub(c.readSetAt) > updateInterval {
    			c.Conn.SetReadDeadline(now.Add(c.readDeadline + updateInterval))
    			c.readSetAt = now
    		}
    	}
    }
    
    func (c *DeadlineConn) setWriteDeadline() {
    	if c.writeDeadline > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 17:40:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/ztunnelserver.go

    	return m, err
    }
    
    func readProto[T any, PT interface {
    	proto.Message
    	*T
    }](c *net.UnixConn, timeout time.Duration, oob []byte) (PT, int, error) {
    	var buf [1024]byte
    	err := c.SetReadDeadline(time.Now().Add(timeout))
    	if err != nil {
    		return nil, 0, err
    	}
    	n, oobn, flags, _, err := c.ReadMsgUnix(buf[:], oob)
    	if err != nil {
    		return nil, 0, err
    	}
    	if flags&unix.MSG_TRUNC != 0 {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  3. api/go1.20.txt

    pkg net/http, method (*ResponseController) Flush() error #54136
    pkg net/http, method (*ResponseController) Hijack() (net.Conn, *bufio.ReadWriter, error) #54136
    pkg net/http, method (*ResponseController) SetReadDeadline(time.Time) error #54136
    pkg net/http, method (*ResponseController) SetWriteDeadline(time.Time) error #54136
    pkg net/http, type ResponseController struct #54136
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Feb 17 21:23:32 UTC 2023
    - 602.6K bytes
    - Viewed (0)
Back to top