diff --git a/listener/raw_tcp_listener.go b/listener/raw_tcp_listener.go index 56aa4f8..8e2aa60 100644 --- a/listener/raw_tcp_listener.go +++ b/listener/raw_tcp_listener.go @@ -104,8 +104,10 @@ func (t *RAWTCPListener) readTCPPackets() { new_buf := make([]byte, n) copy(new_buf, buf[:n]) - packet := NewTCPPacket(new_buf) - t.c_packets <- packet + go func(buf []byte) { + packet := NewTCPPacket(new_buf) + t.c_packets <- packet + }(new_buf) } } }