diff options
| author | chrislu <chris.lu@gmail.com> | 2023-10-05 08:13:53 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-10-05 08:13:53 -0700 |
| commit | 4e493d596c4bf200e29b351b9ede7921d23e74e9 (patch) | |
| tree | b3b680320a9137f45b4ee0211af53313509daeda | |
| parent | 659133fb682b70146b65ebca56e8415e38f2dff4 (diff) | |
| download | seaweedfs-4e493d596c4bf200e29b351b9ede7921d23e74e9.tar.xz seaweedfs-4e493d596c4bf200e29b351b9ede7921d23e74e9.zip | |
minor
| -rw-r--r-- | weed/s3api/s3api_circuit_breaker.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/weed/s3api/s3api_circuit_breaker.go b/weed/s3api/s3api_circuit_breaker.go index 0cc0b08d2..9e197a2f9 100644 --- a/weed/s3api/s3api_circuit_breaker.go +++ b/weed/s3api/s3api_circuit_breaker.go @@ -30,6 +30,10 @@ func NewCircuitBreaker(option *S3ApiServerOption) *CircuitBreaker { err := pb.WithFilerClient(false, 0, option.Filer, option.GrpcDialOption, func(client filer_pb.SeaweedFilerClient) error { content, err := filer.ReadInsideFiler(client, s3_constants.CircuitBreakerConfigDir, s3_constants.CircuitBreakerConfigFile) + if err == filer_pb.ErrNotFound { + glog.Infof("s3 circuit breaker not configured") + return nil + } if err != nil { return fmt.Errorf("read S3 circuit breaker config: %v", err) } @@ -37,7 +41,7 @@ func NewCircuitBreaker(option *S3ApiServerOption) *CircuitBreaker { }) if err != nil { - glog.Infof("s3 circuit breaker not configured: %v", err) + glog.Infof("s3 circuit breaker not configured correctly: %v", err) } return cb |