diff options
| author | chrislu <chris.lu@gmail.com> | 2024-03-31 00:19:16 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-03-31 00:19:16 -0700 |
| commit | c9df613b6bfb7e22e4e596151300aefc56ac909f (patch) | |
| tree | 52d6da7e9fd898eed8bbea513603673e363bacb9 /weed/mq/topic | |
| parent | ca4f89a6f60873849cecc760e9b9bdd5ae33d5f4 (diff) | |
| download | seaweedfs-c9df613b6bfb7e22e4e596151300aefc56ac909f.tar.xz seaweedfs-c9df613b6bfb7e22e4e596151300aefc56ac909f.zip | |
add publisher name for debugging
Diffstat (limited to 'weed/mq/topic')
| -rw-r--r-- | weed/mq/topic/local_partition.go | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/weed/mq/topic/local_partition.go b/weed/mq/topic/local_partition.go index bff0ec17a..0873d6bd7 100644 --- a/weed/mq/topic/local_partition.go +++ b/weed/mq/topic/local_partition.go @@ -8,6 +8,8 @@ import ( "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" "github.com/seaweedfs/seaweedfs/weed/util/log_buffer" "google.golang.org/grpc" + "google.golang.org/grpc/codes" + "google.golang.org/grpc/status" "sync" "sync/atomic" "time" @@ -171,7 +173,12 @@ func (p *LocalPartition) MaybeConnectToFollowers(initMessage *mq_pb.PublishMessa for { ack, err := p.followerStream.Recv() if err != nil { - glog.Errorf("Error receiving follower ack: %v", err) + e, _ := status.FromError(err) + if e.Code() == codes.Canceled { + glog.V(0).Infof("local partition %v follower %v stopped", p.Partition, p.follower) + return + } + glog.Errorf("Receiving local partition %v follower %s ack: %v", p.Partition, p.follower, err) return } atomic.StoreInt64(&p.AckTsNs, ack.AckTsNs) |