connection is the implementation of Connection
| 33 | |
| 34 | // connection is the implementation of Connection |
| 35 | type 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 | |
| 57 | var ( |
| 58 | _ Connection = &connection{} |
nothing calls this directly
no outgoing calls
no test coverage detected