TCP stream
| 98 | // TCP stream |
| 99 | |
| 100 | type tcpStream struct { |
| 101 | subprocess AddrPort // address from which we originally intercepted packets generated by subprocess |
| 102 | world AddrPort // address to which the intercepted packets were addressed |
| 103 | fromSubprocess chan []byte // the stack sends packets here, we receive |
| 104 | toSubprocess chan []byte // we send packets here, the stack receives |
| 105 | serializeBuf gopacket.SerializeBuffer // used to serialize gopacket structs to wire format |
| 106 | state TCPState // state of the connection |
| 107 | seq uint32 // sequence number for packets going to the subprocess |
| 108 | ack uint32 // the next acknowledgement number to send |
| 109 | } |
| 110 | |
| 111 | func newTCPStream(world AddrPort, subprocess AddrPort, out chan []byte) *tcpStream { |
| 112 | return &tcpStream{ |
nothing calls this directly
no outgoing calls
no test coverage detected