mirrors/dae
1
0
Fork 0
mirror of https://github.com/daeuniverse/dae.git synced 2025-03-10 04:47:25 +07:00
Code Issues Packages Projects Releases Wiki Activity

revert: optimize(sniffer): wait data for 300ms instead of 100ms

Browse Source
This commit is contained in:
mzz2017 2023-04-12 23:46:19 +08:00
parent d6ff71fda4
commit bd2fa98809
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
component/sniffing/sniffer.go
View File

@ -12,7 +12,7 @@ import (
)
const (
DataWaitingTimeout = 300 * time.Millisecond
DataWaitingTimeout = 100 * time.Millisecond
)
type Sniffer struct {
@ -30,9 +30,9 @@ type Sniffer struct {
func NewStreamSniffer(r io.Reader, bufSize int) *Sniffer {
s := &Sniffer{
stream: true,
r: r,
buf: make([]byte, bufSize),
stream: true,
dataReady: make(chan struct{}),
}
return s
@ -40,8 +40,10 @@ func NewStreamSniffer(r io.Reader, bufSize int) *Sniffer {
func NewPacketSniffer(data []byte) *Sniffer {
s := &Sniffer{
buf: data,
stream: false,
stream: false,
r: nil,
buf: data,
dataReady: make(chan struct{}),
}
return s
}
@ -74,7 +76,7 @@ func (s *Sniffer) SniffTcp() (d string, err error) {
close(s.dataReady)
}()
// Waiting 300ms for data.
// Waiting 100ms for data.
select {
case <-s.dataReady:
if s.dataError != nil {