mirror of
https://github.com/daeuniverse/dae.git
synced 2025-07-14 01:40:32 +07:00
chore: fix sniffTcp
This commit is contained in:
@ -82,10 +82,14 @@ func (s *Sniffer) SniffTcp() (d string, err error) {
|
||||
defer s.readMu.Unlock()
|
||||
if s.stream {
|
||||
go func() {
|
||||
_, err := s.buf.ReadFrom(s.r)
|
||||
// Read once.
|
||||
s.buf.Reset()
|
||||
s.buf.Grow(max(0, 4096-s.buf.Available()))
|
||||
n, err := s.r.Read(s.buf.AvailableBuffer())
|
||||
if err != nil {
|
||||
s.dataError = err
|
||||
}
|
||||
s.buf.Truncate(n)
|
||||
close(s.dataReady)
|
||||
}()
|
||||
|
||||
|
Reference in New Issue
Block a user