Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for SetWriteDeadline (0.06 sec)

  1. internal/deadlineconn/deadlineconn.go

    			c.Conn.SetReadDeadline(now.Add(c.readDeadline + updateInterval))
    			c.readSetAt = now
    		}
    	}
    }
    
    func (c *DeadlineConn) setWriteDeadline() {
    	if c.writeDeadline > 0 {
    		now := time.Now()
    		if now.Sub(c.writeSetAt) > updateInterval {
    			c.Conn.SetWriteDeadline(now.Add(c.writeDeadline + updateInterval))
    			c.writeSetAt = now
    		}
    	}
    }
    
    // Read - reads data from the connection using wrapped buffered reader.
    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_test.go

    	if err != nil {
    		panic(err)
    	}
    	err = c.SetWriteDeadline(time.Now().Add(time.Second))
    	if err != nil {
    		panic(err)
    	}
    	c.Write(data)
    }
    
    func sendHello(c *net.UnixConn) {
    	ack := &zdsapi.ZdsHello{
    		Version: zdsapi.Version_V1,
    	}
    	data, err := proto.Marshal(ack)
    	if err != nil {
    		panic(err)
    	}
    	err = c.SetWriteDeadline(time.Now().Add(time.Second))
    	if err != nil {
    		panic(err)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
Back to top