github/goreplay
4
0
Fork 0
mirror of https://github.com/buger/goreplay.git synced 2026-10-21 04:26:29 +00:00
Code Issues Releases Wiki Activity

Don't block socket reading

Browse Source
This commit is contained in:
Leonid Bugaev
2013-06-19 13:34:01 +06:00
parent cad13f4233
commit 6ba587e82e
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
listener/raw_tcp_listener.go
+4 -2
View File
@@ -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)
}
}
}