diff options
| author | chrislu <chris.lu@gmail.com> | 2024-03-27 10:24:57 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-03-27 10:24:57 -0700 |
| commit | 17806cde2af54a0aa08642f6e5f381e703b84788 (patch) | |
| tree | 5725e4f9c40ec1d2c57a9ed26c9bb9a618c4840a | |
| parent | f67c8309d8ba1c775ac2653c49f933163a7621e6 (diff) | |
| download | seaweedfs-17806cde2af54a0aa08642f6e5f381e703b84788.tar.xz seaweedfs-17806cde2af54a0aa08642f6e5f381e703b84788.zip | |
separate context
If using the same context, the downstream grpc would be cancelled when the parent grpc is cancelled.
| -rw-r--r-- | weed/mq/broker/broker_grpc_pub.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/broker/broker_grpc_pub.go b/weed/mq/broker/broker_grpc_pub.go index 3937399bd..ab4320a9d 100644 --- a/weed/mq/broker/broker_grpc_pub.go +++ b/weed/mq/broker/broker_grpc_pub.go @@ -67,7 +67,7 @@ func (b *MessageQueueBroker) PublishMessage(stream mq_pb.SeaweedMessaging_Publis // connect to follower brokers if localTopicPartition.FollowerStream == nil && len(initMessage.FollowerBrokers) > 0 { follower := initMessage.FollowerBrokers[0] - ctx := stream.Context() + ctx := context.Background() localTopicPartition.FollowerGrpcConnection, err = pb.GrpcDial(ctx, follower, true, b.grpcDialOption) if err != nil { response.Error = fmt.Sprintf("fail to dial %s: %v", follower, err) |