diff options
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) |