Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
35631da799 |
@@ -91,7 +91,7 @@ func (l *Listener) Start() error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
l.packetOutboundClosed = make(chan struct{})
|
l.packetOutboundClosed = make(chan struct{})
|
||||||
l.packetOutbound = make(chan *N.PacketBuffer, 64)
|
l.packetOutbound = make(chan *N.PacketBuffer, 1024)
|
||||||
go l.loopUDPIn()
|
go l.loopUDPIn()
|
||||||
if !l.disablePacketOutput {
|
if !l.disablePacketOutput {
|
||||||
go l.loopUDPOut()
|
go l.loopUDPOut()
|
||||||
|
|||||||
@@ -198,7 +198,7 @@ func (w *packetWriter) WritePacket(buffer *buf.Buffer, destination M.Socksaddr)
|
|||||||
if w.shutdown.Load() {
|
if w.shutdown.Load() {
|
||||||
return os.ErrClosed
|
return os.ErrClosed
|
||||||
}
|
}
|
||||||
w.logger.Trace("dropped packet to ", destination)
|
w.logger.Debug("dropped packet to ", destination)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -30,6 +30,6 @@ var ProtocolTimeouts = map[string]time.Duration{
|
|||||||
ProtocolDNS: 10 * time.Second,
|
ProtocolDNS: 10 * time.Second,
|
||||||
ProtocolNTP: 10 * time.Second,
|
ProtocolNTP: 10 * time.Second,
|
||||||
ProtocolSTUN: 10 * time.Second,
|
ProtocolSTUN: 10 * time.Second,
|
||||||
ProtocolQUIC: 30 * time.Second,
|
ProtocolQUIC: 60 * time.Second,
|
||||||
ProtocolDTLS: 30 * time.Second,
|
ProtocolDTLS: 60 * time.Second,
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user