From f2a123e4ae5a8a33f0235be9b1067690e7e6631b Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Thu, 26 Oct 2023 12:17:36 +0800 Subject: [PATCH] chore: update pkg github.com/openimsdk/tools --- pkg/common/chatrpcstart/start.go | 2 +- pkg/common/config/parse.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/common/chatrpcstart/start.go b/pkg/common/chatrpcstart/start.go index 882487da5..a89da7c51 100644 --- a/pkg/common/chatrpcstart/start.go +++ b/pkg/common/chatrpcstart/start.go @@ -42,7 +42,7 @@ func Start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(c if err != nil { return errs.Wrap(err) } - defer zkClient.CloseZK() + //defer zkClient.CloseZK() zkClient.AddOption(chatMw.AddUserType(), mw.GrpcClient(), grpc.WithTransportCredentials(insecure.NewCredentials())) registerIP, err := network.GetRpcRegisterIP(config.Config.Rpc.RegisterIP) if err != nil { diff --git a/pkg/common/config/parse.go b/pkg/common/config/parse.go index a5f38e341..4e929d61e 100644 --- a/pkg/common/config/parse.go +++ b/pkg/common/config/parse.go @@ -72,7 +72,7 @@ func InitConfig(configFile string) error { if err != nil { return utils.Wrap(err, "conn zk error ") } - defer zk.CloseZK() + //defer zk.CloseZK() var openIMConfigData []byte for i := 0; i < 100; i++ { var err error