diff options
| author | Chris Lu <chris.lu@gmail.com> | 2024-02-05 17:47:34 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2024-02-05 17:47:34 -0800 |
| commit | 90fcde0e26cb4dc3c64359451e36b7b26da87169 (patch) | |
| tree | a6ac0725c51d67c304238eeaf82e585128350b3c | |
| parent | 07028a48648a98e00d1d9990dc30293dcc6835c7 (diff) | |
| download | seaweedfs-90fcde0e26cb4dc3c64359451e36b7b26da87169.tar.xz seaweedfs-90fcde0e26cb4dc3c64359451e36b7b26da87169.zip | |
report EOF error
| -rw-r--r-- | weed/mq/client/pub_client/scheduler.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/mq/client/pub_client/scheduler.go b/weed/mq/client/pub_client/scheduler.go index 39a659635..a766814e6 100644 --- a/weed/mq/client/pub_client/scheduler.go +++ b/weed/mq/client/pub_client/scheduler.go @@ -161,8 +161,8 @@ func (p *TopicPublisher) doPublishToPartition(job *EachPartitionPublishJob) erro for { ackResp, err := publishClient.Recv() if err != nil { - e, ok := status.FromError(err) - if ok && e.Code() == codes.Unknown && e.Message() == "EOF" { + e, _ := status.FromError(err) + if e.Code() == codes.Unknown && e.Message() == "EOF" { return } publishClient.Err = err |