diff options
| author | chrislu <chris.lu@gmail.com> | 2022-07-23 10:50:28 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-07-23 10:50:28 -0700 |
| commit | 64f3d6fb6e1acb007b3e4726962c7ea35bacc4c4 (patch) | |
| tree | 30903fa25af0bcf797f93e354f68fb41216dc602 /weed/s3api | |
| parent | 2c8818351f418e3584a6c5410c396f747aebd725 (diff) | |
| download | seaweedfs-64f3d6fb6e1acb007b3e4726962c7ea35bacc4c4.tar.xz seaweedfs-64f3d6fb6e1acb007b3e4726962c7ea35bacc4c4.zip | |
metadata subscription uses client epoch
Diffstat (limited to 'weed/s3api')
| -rw-r--r-- | weed/s3api/auth_credentials_subscribe.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/weed/s3api/auth_credentials_subscribe.go b/weed/s3api/auth_credentials_subscribe.go index f2bd94f56..55e63326d 100644 --- a/weed/s3api/auth_credentials_subscribe.go +++ b/weed/s3api/auth_credentials_subscribe.go @@ -32,8 +32,10 @@ func (s3a *S3ApiServer) subscribeMetaEvents(clientName string, prefix string, la return nil } + var clientEpoch int32 util.RetryForever("followIamChanges", func() error { - return pb.WithFilerClientFollowMetadata(s3a, clientName, s3a.randomClientId, prefix, &lastTsNs, 0, 0, processEventFn, pb.FatalOnError) + clientEpoch++ + return pb.WithFilerClientFollowMetadata(s3a, clientName, s3a.randomClientId, clientEpoch, prefix, &lastTsNs, 0, 0, processEventFn, pb.FatalOnError) }, func(err error) bool { glog.V(0).Infof("iam follow metadata changes: %v", err) return true |