diff --git a/net/gtcp/gtcp_server.go b/net/gtcp/gtcp_server.go index 87c263447..9607a53fe 100644 --- a/net/gtcp/gtcp_server.go +++ b/net/gtcp/gtcp_server.go @@ -52,7 +52,7 @@ func NewServer(address string, handler func(*Conn), name ...string) *Server { address: address, handler: handler, } - if len(name) > 0 { + if len(name) > 0 && name[0] != "" { serverMapping.Set(name[0], s) } return s diff --git a/net/gtcp/gtcp_unit_pool_test.go b/net/gtcp/gtcp_unit_pool_test.go index 08840457d..3cbaea6fe 100644 --- a/net/gtcp/gtcp_unit_pool_test.go +++ b/net/gtcp/gtcp_unit_pool_test.go @@ -27,7 +27,9 @@ func Test_Pool_Basic1(t *testing.T) { } }) go s.Run() - defer s.Close() + defer func() { + s.Close() + }() time.Sleep(100 * time.Millisecond) gtest.Case(t, func() { conn, err := gtcp.NewPoolConn(fmt.Sprintf("127.0.0.1:%d", p)) @@ -47,7 +49,9 @@ func Test_Pool_Basic2(t *testing.T) { conn.Close() }) go s.Run() - defer s.Close() + defer func() { + s.Close() + }() time.Sleep(100 * time.Millisecond) gtest.Case(t, func() { conn, err := gtcp.NewPoolConn(fmt.Sprintf("127.0.0.1:%d", p)) diff --git a/net/gudp/gudp_conn.go b/net/gudp/gudp_conn.go index cfc276655..31b1534a6 100644 --- a/net/gudp/gudp_conn.go +++ b/net/gudp/gudp_conn.go @@ -154,7 +154,7 @@ func (c *Conn) Recv(length int, retry ...Retry) ([]byte, error) { if retry[0].Interval == 0 { retry[0].Interval = gDEFAULT_RETRY_INTERVAL } - time.Sleep(time.Duration(retry[0].Interval) * time.Millisecond) + time.Sleep(retry[0].Interval) continue } break diff --git a/net/gudp/gudp_server.go b/net/gudp/gudp_server.go index 921ea3f87..2ecb28a76 100644 --- a/net/gudp/gudp_server.go +++ b/net/gudp/gudp_server.go @@ -53,7 +53,7 @@ func NewServer(address string, handler func(*Conn), name ...string) *Server { address: address, handler: handler, } - if len(name) > 0 { + if len(name) > 0 && name[0] != "" { serverMapping.Set(name[0], s) } return s