diff --git a/transport/internet/grpc/dial.go b/transport/internet/grpc/dial.go index 2d5be743e..a07b206bc 100644 --- a/transport/internet/grpc/dial.go +++ b/transport/internet/grpc/dial.go @@ -54,7 +54,7 @@ func dialgRPC(ctx context.Context, dest net.Destination, streamSettings *interne dialOption = grpc.WithTransportCredentials(credentials.NewTLS(config.GetTLSConfig())) } - conn, canceller, err := getGrpcClient(ctx, dest, dialOption) + conn, canceller, err := getGrpcClient(ctx, dest, dialOption, streamSettings) if err != nil { return nil, newError("Cannot dial grpc").Base(err) } @@ -67,7 +67,7 @@ func dialgRPC(ctx context.Context, dest net.Destination, streamSettings *interne return encoding.NewGunConn(gunService, nil), nil } -func getGrpcClient(ctx context.Context, dest net.Destination, dialOption grpc.DialOption) (*grpc.ClientConn, dialerCanceller, error) { +func getGrpcClient(ctx context.Context, dest net.Destination, dialOption grpc.DialOption, streamSettings *internet.MemoryStreamConfig) (*grpc.ClientConn, dialerCanceller, error) { globalDialerAccess.Lock() defer globalDialerAccess.Unlock() @@ -112,7 +112,7 @@ func getGrpcClient(ctx context.Context, dest net.Destination, dialOption grpc.Di } address := net.ParseAddress(rawHost) detachedContext := core.ToBackgroundDetachedContext(ctx) - return internet.DialSystem(detachedContext, net.TCPDestination(address, port), nil) + return internet.DialSystem(detachedContext, net.TCPDestination(address, port), streamSettings.SocketSettings) }), ) globalDialerMap[dest] = conn