blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-12-02 18:34:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: operation id invalid

Browse Source
This commit is contained in:
AndrewZuo01 2024-01-16 10:09:47 +08:00
parent f36c941adf
commit 3015d54c17
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/common/discoveryregister/direct/directconn.go
View File

@ -95,7 +95,7 @@ func (cm *ConnManager) GetConn(ctx context.Context, serviceName string, opts ...
return nil, errs.Wrap(errors.New("unknown service name"), "serviceName", serviceName) return nil, errs.Wrap(errors.New("unknown service name"), "serviceName", serviceName)
} }
conn, err := dialService(address, append(cm.additionalOpts, opts...)...) conn, err := dialService(ctx, address, append(cm.additionalOpts, opts...)...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -117,9 +117,9 @@ func (cm *ConnManager) CloseConn(conn *grpc.ClientConn) {
} }
} }
func dialService(address string, opts ...grpc.DialOption) (*grpc.ClientConn, error) { func dialService(ctx context.Context, address string, opts ...grpc.DialOption) (*grpc.ClientConn, error) {
options := append(opts, grpc.WithInsecure()) // Replace WithInsecure with proper security options options := append(opts, grpc.WithInsecure()) // Replace WithInsecure with proper security options
conn, err := grpc.DialContext(context.Background(), address, options...) conn, err := grpc.DialContext(ctx, address, options...)
if err != nil { if err != nil {
return nil, err return nil, err
} }