diff --git a/client.go b/client.go index 0c1fb43..393173c 100644 --- a/client.go +++ b/client.go @@ -276,7 +276,7 @@ func (p *Client) AcceptTcpConn(conn *net.TCPConn, targetAddr string) { tcpsrcaddr := conn.RemoteAddr().(*net.TCPAddr) - if p.localIdToConnMapSize >= p.maxconn { + if p.maxconn > 0 && p.localIdToConnMapSize >= p.maxconn { loggo.Info("too many connections %d, client accept new local tcp fail %s", p.localIdToConnMapSize, tcpsrcaddr.String()) return } @@ -492,7 +492,7 @@ func (p *Client) Accept() error { now := time.Now() clientConn := p.getClientConnByAddr(srcaddr.String()) if clientConn == nil { - if p.localIdToConnMapSize >= p.maxconn { + if p.maxconn > 0 && p.localIdToConnMapSize >= p.maxconn { loggo.Info("too many connections %d, client accept new local udp fail %s", p.localIdToConnMapSize, srcaddr.String()) continue } diff --git a/server.go b/server.go index 1fcb7f3..2db9b82 100644 --- a/server.go +++ b/server.go @@ -121,7 +121,7 @@ func (p *Server) processPacket(packet *Packet) { localConn := p.getServerConnById(id) if localConn == nil { - if p.localConnMapSize >= p.maxconn { + if p.maxconn > 0 && p.localConnMapSize >= p.maxconn { loggo.Info("too many connections %d, server connected target fail %s", p.localConnMapSize, packet.my.Target) return }