- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for SetWriteDeadline (0.06 sec)
-
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) -
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)