extern/rclone
1
0
Fork 0
mirror of https://github.com/rclone/rclone.git synced 2025-01-25 15:49:33 +01:00
Code Issues Packages Projects Releases Wiki Activity

union: use atomic types

Browse Source
This commit is contained in:
Roberto Ricci 2023-08-21 00:20:23 +02:00 committed by Nick Craig-Wood
parent de147b6e54
commit 45458f2cdb
1 changed files with 13 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
backend/union/upstream/upstream.go
View File

@ -25,10 +25,6 @@ var (
// Fs is a wrap of any fs and its configs // Fs is a wrap of any fs and its configs
type Fs struct { type Fs struct {
// In order to ensure memory alignment on 32-bit architectures
// when this field is accessed through sync/atomic functions,
// it must be the first entry in the struct
cacheExpiry int64 // usage cache expiry time
fs.Fs fs.Fs
RootFs fs.Fs RootFs fs.Fs
RootPath string RootPath string
@ -37,6 +33,7 @@ type Fs struct {
creatable bool creatable bool
usage *fs.Usage // Cache the usage usage *fs.Usage // Cache the usage
cacheTime time.Duration // cache duration cacheTime time.Duration // cache duration
cacheExpiry atomic.Int64 // usage cache expiry time
cacheMutex sync.RWMutex cacheMutex sync.RWMutex
cacheOnce sync.Once cacheOnce sync.Once
cacheUpdate bool // if the cache is updating cacheUpdate bool // if the cache is updating
@ -77,10 +74,10 @@ func New(ctx context.Context, remote, root string, opt *common.Options) (*Fs, er
Opt: opt, Opt: opt,
writable: true, writable: true,
creatable: true, creatable: true,
cacheExpiry: time.Now().Unix(),
cacheTime: time.Duration(opt.CacheTime) * time.Second, cacheTime: time.Duration(opt.CacheTime) * time.Second,
usage: &fs.Usage{}, usage: &fs.Usage{},
} }
f.cacheExpiry.Store(time.Now().Unix())
if strings.HasSuffix(fsPath, ":ro") { if strings.HasSuffix(fsPath, ":ro") {
f.writable = false f.writable = false
f.creatable = false f.creatable = false
@ -298,7 +295,7 @@ func (o *Object) Metadata(ctx context.Context) (fs.Metadata, error) {
// About gets quota information from the Fs // About gets quota information from the Fs
func (f *Fs) About(ctx context.Context) (*fs.Usage, error) { func (f *Fs) About(ctx context.Context) (*fs.Usage, error) {
if atomic.LoadInt64(&f.cacheExpiry) <= time.Now().Unix() { if f.cacheExpiry.Load() <= time.Now().Unix() {
err := f.updateUsage() err := f.updateUsage()
if err != nil { if err != nil {
return nil, ErrUsageFieldNotSupported return nil, ErrUsageFieldNotSupported
@ -313,7 +310,7 @@ func (f *Fs) About(ctx context.Context) (*fs.Usage, error) {
// //
// This is returned as 0..math.MaxInt64-1 leaving math.MaxInt64 as a sentinel // This is returned as 0..math.MaxInt64-1 leaving math.MaxInt64 as a sentinel
func (f *Fs) GetFreeSpace() (int64, error) { func (f *Fs) GetFreeSpace() (int64, error) {
if atomic.LoadInt64(&f.cacheExpiry) <= time.Now().Unix() { if f.cacheExpiry.Load() <= time.Now().Unix() {
err := f.updateUsage() err := f.updateUsage()
if err != nil { if err != nil {
return math.MaxInt64 - 1, ErrUsageFieldNotSupported return math.MaxInt64 - 1, ErrUsageFieldNotSupported
@ -331,7 +328,7 @@ func (f *Fs) GetFreeSpace() (int64, error) {
// //
// This is returned as 0..math.MaxInt64-1 leaving math.MaxInt64 as a sentinel // This is returned as 0..math.MaxInt64-1 leaving math.MaxInt64 as a sentinel
func (f *Fs) GetUsedSpace() (int64, error) { func (f *Fs) GetUsedSpace() (int64, error) {
if atomic.LoadInt64(&f.cacheExpiry) <= time.Now().Unix() { if f.cacheExpiry.Load() <= time.Now().Unix() {
err := f.updateUsage() err := f.updateUsage()
if err != nil { if err != nil {
return 0, ErrUsageFieldNotSupported return 0, ErrUsageFieldNotSupported
@ -347,7 +344,7 @@ func (f *Fs) GetUsedSpace() (int64, error) {
// GetNumObjects get the number of objects of the fs // GetNumObjects get the number of objects of the fs
func (f *Fs) GetNumObjects() (int64, error) { func (f *Fs) GetNumObjects() (int64, error) {
if atomic.LoadInt64(&f.cacheExpiry) <= time.Now().Unix() { if f.cacheExpiry.Load() <= time.Now().Unix() {
err := f.updateUsage() err := f.updateUsage()
if err != nil { if err != nil {
return 0, ErrUsageFieldNotSupported return 0, ErrUsageFieldNotSupported
@ -402,7 +399,7 @@ func (f *Fs) updateUsageCore(lock bool) error {
defer f.cacheMutex.Unlock() defer f.cacheMutex.Unlock()
} }
// Store usage // Store usage
atomic.StoreInt64(&f.cacheExpiry, time.Now().Add(f.cacheTime).Unix()) f.cacheExpiry.Store(time.Now().Add(f.cacheTime).Unix())
f.usage = usage f.usage = usage
return nil return nil
} }