Some minor changes

listener/raw_tcp_listener.go

@@ -28,9 +28,9 @@ type RAWTCPListener struct {
 func RAWTCPListen(addr string, port int) (listener *RAWTCPListener) {
 	listener = &RAWTCPListener{}
 
-	listener.c_packets = make(chan *TCPPacket, 100)
-	listener.c_messages = make(chan *TCPMessage, 50)
-	listener.c_del_message = make(chan *TCPMessage, 10)
+	listener.c_packets = make(chan *TCPPacket, 1000)
+	listener.c_messages = make(chan *TCPMessage, 1000)
+	listener.c_del_message = make(chan *TCPMessage, 1000)
 
 	listener.addr = addr
 	listener.port = port
@@ -112,8 +112,7 @@ func (t *RAWTCPListener) parsePacket(buf []byte) {
 		new_buf := make([]byte, len(buf))
 		copy(new_buf, buf)
 
-		packet := NewTCPPacket(new_buf)
-		t.c_packets <- packet
+		t.c_packets <- ParseTCPPacket(new_buf)
 	}
 }
 

listener/raw_tcp_listener_test.go

@@ -70,7 +70,7 @@ func TestRawTCPListener(t *testing.T) {
 		}
 	}()
 
-	for i := 0; i < 100000; i++ {
+	for i := 0; i < 10000; i++ {
 		wg.Add(1)
 
 		packets := getPackets(port)

listener/tcp_packet.go

@@ -36,7 +36,7 @@ type TCPPacket struct {
 	Data []byte
 }
 
-func NewTCPPacket(b []byte) (p *TCPPacket) {
+func ParseTCPPacket(b []byte) (p *TCPPacket) {
 	p = &TCPPacket{Data: b}
 	p.ParseFast()