Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions internal/pool/conn.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,8 @@ var noDeadline = time.Time{}
// Global atomic counter for connection IDs
var connIDCounter uint64

var errUnexpectedRead = errors.New("unexpected read from socket")

// HandoffState represents the atomic state for connection handoffs
// This struct is stored atomically to prevent race conditions between
// checking handoff status and reading handoff parameters
Expand Down
3 changes: 0 additions & 3 deletions internal/pool/conn_check.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,15 +3,12 @@
package pool

import (
"errors"
"io"
"net"
"syscall"
"time"
)

var errUnexpectedRead = errors.New("unexpected read from socket")

// connCheck checks if the connection is still alive and if there is data in the socket
// it will try to peek at the next byte without consuming it since we may want to work with it
// later on (e.g. push notifications)
Expand Down
Loading