- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for SetWriteDeadline (0.45 sec)
-
internal/deadlineconn/deadlineconn.go
// Sets read deadline func (c *DeadlineConn) setReadDeadline() { if c.readDeadline > 0 { c.SetReadDeadline(time.Now().UTC().Add(c.readDeadline)) } } func (c *DeadlineConn) setWriteDeadline() { if c.writeDeadline > 0 { c.SetWriteDeadline(time.Now().UTC().Add(c.writeDeadline)) } } // Read - reads data from the connection using wrapped buffered reader. func (c *DeadlineConn) Read(b []byte) (n int, err error) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 2.3K 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)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
internal/grid/connection.go
if err != nil { gridLogIf(ctx, fmt.Errorf("ws writeMessage: %w", err)) return } PutByteBuffer(toSend) err = conn.SetWriteDeadline(time.Now().Add(connWriteTimeout)) if err != nil { gridLogIf(ctx, fmt.Errorf("conn.SetWriteDeadline: %w", err)) return } _, err = buf.WriteTo(conn) if err != nil { gridLogIf(ctx, fmt.Errorf("ws write: %w", err)) return
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
} func (z *ZtunnelConnection) sendDataAndWaitForAck(data []byte, fd *int) (*zdsapi.WorkloadResponse, error) { var rights []byte if fd != nil { rights = unix.UnixRights(*fd) } err := z.u.SetWriteDeadline(time.Now().Add(readWriteDeadline)) if err != nil { return nil, err } _, _, err = z.u.WriteMsgUnix(data, rights, nil) if err != nil { return nil, err } // wait for ack
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
api/go1.10.txt
pkg net/smtp, method (*Client) Noop() error pkg os, func IsTimeout(error) bool pkg os, method (*File) SetDeadline(time.Time) error pkg os, method (*File) SetReadDeadline(time.Time) error pkg os, method (*File) SetWriteDeadline(time.Time) error pkg os, method (*PathError) Timeout() bool pkg os, method (*SyscallError) Timeout() bool pkg os, var ErrNoDeadline error pkg strings, method (*Builder) Grow(int)
Plain Text - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Tue Feb 06 05:00:01 GMT 2018 - 30.1K bytes - Viewed (0) -
api/go1.txt
pkg crypto/tls, method (*Conn) RemoteAddr() net.Addr pkg crypto/tls, method (*Conn) SetDeadline(time.Time) error pkg crypto/tls, method (*Conn) SetReadDeadline(time.Time) error pkg crypto/tls, method (*Conn) SetWriteDeadline(time.Time) error pkg crypto/tls, method (*Conn) VerifyHostname(string) error pkg crypto/tls, method (*Conn) Write([]uint8) (int, error) pkg crypto/tls, type Certificate struct
Plain Text - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Wed Aug 14 18:58:28 GMT 2013 - 1.7M bytes - Viewed (1) -
api/go1.20.txt
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 pkg net/http, type Server struct, DisableGeneralOptionsHandler bool #41773
Plain Text - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Feb 17 21:23:32 GMT 2023 - 602.6K bytes - Viewed (0)