MCPcopy Create free account
hub / github.com/cloudwego/netpoll / connection

Struct connection

connection_impl.go:35–55  ·  view source on GitHub ↗

connection is the implementation of Connection

Source from the content-addressed store, hash-verified

33
34// connection is the implementation of Connection
35type connection struct {
36 netFD
37 onEvent
38 locker
39 operator *FDOperator
40 readTimeout time.Duration
41 readDeadline int64 // UnixNano(). it overwrites readTimeout. 0 if not set.
42 readTimer *time.Timer
43 readTrigger chan error
44 waitReadSize int64
45 writeTimeout time.Duration
46 writeDeadline int64 // UnixNano(). it overwrites writeTimeout. 0 if not set.
47 writeTimer *time.Timer
48 writeTrigger chan error
49 inputBuffer *LinkBuffer
50 outputBuffer *LinkBuffer
51 outputBarrier *barrier
52 maxSize int // The maximum size of data between two Release().
53 bookSize int // The size of data that can be read at once.
54 state connState // Connection state should be changed sequentially.
55}
56
57var (
58 _ Connection = &connection{}

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected