tun2: continue sooner in pingloop
This commit is contained in:
parent
10f51ef10a
commit
ed00bc4232
|
@ -166,21 +166,22 @@ func (s *Server) ListenAndServe() error {
|
||||||
stream, err := c.session.OpenStream()
|
stream, err := c.session.OpenStream()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ln.Error(err, c.F())
|
ln.Error(err, c.F())
|
||||||
|
|
||||||
c.cancel()
|
c.cancel()
|
||||||
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
err = req.Write(stream)
|
err = req.Write(stream)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ln.Error(err, c.F())
|
ln.Error(err, c.F())
|
||||||
|
|
||||||
c.cancel()
|
c.cancel()
|
||||||
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
_, err = stream.Read(make([]byte, 30))
|
_, err = stream.Read(make([]byte, 30))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ln.Error(err, c.F())
|
ln.Error(err, c.F())
|
||||||
c.cancel()
|
c.cancel()
|
||||||
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
stream.Close()
|
stream.Close()
|
||||||
|
|
Loading…
Reference in New Issue