aboutsummaryrefslogtreecommitdiff
path: root/weed/s3api
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-06-03 08:45:32 -0700
committerchrislu <chris.lu@gmail.com>2022-06-03 08:45:32 -0700
commit39c3cb04af277268e7d8ef5b8ce6d8ffcb48105f (patch)
tree3b67a6f1962b2d3e567a0549f1e46445161ce70f /weed/s3api
parentf97acdd4891b7b318f3fb67b1d8c2b11c809b158 (diff)
parentff5b96f0be266b3abbcede387d665865274a67ab (diff)
downloadseaweedfs-39c3cb04af277268e7d8ef5b8ce6d8ffcb48105f.tar.xz
seaweedfs-39c3cb04af277268e7d8ef5b8ce6d8ffcb48105f.zip
Merge branch 'master' of https://github.com/chrislusf/seaweedfs
Diffstat (limited to 'weed/s3api')
-rw-r--r--weed/s3api/auth_credentials_subscribe.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/s3api/auth_credentials_subscribe.go b/weed/s3api/auth_credentials_subscribe.go
index 48c4e35c8..91fd5d830 100644
--- a/weed/s3api/auth_credentials_subscribe.go
+++ b/weed/s3api/auth_credentials_subscribe.go
@@ -33,7 +33,7 @@ func (s3a *S3ApiServer) subscribeMetaEvents(clientName string, prefix string, la
}
util.RetryForever("followIamChanges", func() error {
- return pb.WithFilerClientFollowMetadata(s3a, clientName, s3a.randomClientId, prefix, &lastTsNs, 0, 0, processEventFn, true)
+ return pb.WithFilerClientFollowMetadata(s3a, clientName, s3a.randomClientId, prefix, &lastTsNs, 0, 0, processEventFn, pb.FatalOnError)
}, func(err error) bool {
glog.V(0).Infof("iam follow metadata changes: %v", err)
return true