Skip to content

G
getty
Commit 5e60dbdd authored by georgehao's avatar georgehao
Browse files
Options

feat: format

parent 389e30dd
Show whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
connection.go
View file @ 5e60dbdd
...@@ -269,7 +269,7 @@ func (t *gettyTCPConn) send(pkg interface{}) (int, error) { ...@@ -269,7 +269,7 @@ func (t *gettyTCPConn) send(pkg interface{}) (int, error) {
// of the last write deadline exceeded. // of the last write deadline exceeded.
// See https://github.com/golang/go/issues/15133 for details. // See https://github.com/golang/go/issues/15133 for details.
currentTime = time.Now() currentTime = time.Now()
if currentTime.Unix() - t.wLastDeadline > int64(t.wTimeout >> 2) { if currentTime.Unix()-t.wLastDeadline > int64(t.wTimeout>>2) {
if err = t.conn.SetWriteDeadline(currentTime.Add(t.wTimeout)); err != nil { if err = t.conn.SetWriteDeadline(currentTime.Add(t.wTimeout)); err != nil {
return 0, perrors.WithStack(err) return 0, perrors.WithStack(err)
} }
...@@ -390,7 +390,7 @@ func (u *gettyUDPConn) recv(p []byte) (int, *net.UDPAddr, error) { ...@@ -390,7 +390,7 @@ func (u *gettyUDPConn) recv(p []byte) (int, *net.UDPAddr, error) {
// of the last read deadline exceeded. // of the last read deadline exceeded.
// See https://github.com/golang/go/issues/15133 for details. // See https://github.com/golang/go/issues/15133 for details.
currentTime = time.Now() currentTime = time.Now()
if currentTime.Unix() - u.rLastDeadline > int64(u.rTimeout >> 2) { if currentTime.Unix()-u.rLastDeadline > int64(u.rTimeout>>2) {
if err = u.conn.SetReadDeadline(currentTime.Add(u.rTimeout)); err != nil { if err = u.conn.SetReadDeadline(currentTime.Add(u.rTimeout)); err != nil {
return 0, nil, perrors.WithStack(err) return 0, nil, perrors.WithStack(err)
} }
...@@ -437,7 +437,7 @@ func (u *gettyUDPConn) send(udpCtx interface{}) (int, error) { ...@@ -437,7 +437,7 @@ func (u *gettyUDPConn) send(udpCtx interface{}) (int, error) {
// of the last write deadline exceeded. // of the last write deadline exceeded.
// See https://github.com/golang/go/issues/15133 for details. // See https://github.com/golang/go/issues/15133 for details.
currentTime = time.Now() currentTime = time.Now()
if currentTime.Unix() - u.wLastDeadline > int64(u.wTimeout >> 2) { if currentTime.Unix()-u.wLastDeadline > int64(u.wTimeout>>2) {
if err = u.conn.SetWriteDeadline(currentTime.Add(u.wTimeout)); err != nil { if err = u.conn.SetWriteDeadline(currentTime.Add(u.wTimeout)); err != nil {
return 0, perrors.WithStack(err) return 0, perrors.WithStack(err)
} }
...@@ -562,7 +562,7 @@ func (w *gettyWSConn) updateWriteDeadline() error { ...@@ -562,7 +562,7 @@ func (w *gettyWSConn) updateWriteDeadline() error {
// of the last write deadline exceeded. // of the last write deadline exceeded.
// See https://github.com/golang/go/issues/15133 for details. // See https://github.com/golang/go/issues/15133 for details.
currentTime = time.Now() currentTime = time.Now()
if currentTime.Unix() - w.wLastDeadline > int64(w.wTimeout >> 2) { if currentTime.Unix()-w.wLastDeadline > int64(w.wTimeout>>2) {
if err = w.conn.SetWriteDeadline(currentTime.Add(w.wTimeout)); err != nil { if err = w.conn.SetWriteDeadline(currentTime.Add(w.wTimeout)); err != nil {
return perrors.WithStack(err) return perrors.WithStack(err)
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment