mirror of
https://github.com/versity/versitygw.git
synced 2026-09-23 16:34:18 +00:00
Ben McClelland
9a73e222ca
Fail closed on unexpected advisory-lock errors instead of silently reducing cross-process exclusion to a local mutex. Make local publish-slot waits honor request cancellation. Move version snapshots under the publish lock so concurrent versioned PUTs preserve publication order. Add regression coverage for canceled lock waiters. Also add an option to disable flock files and only rely on in process locking.
58 lines
1.6 KiB
Go
58 lines
1.6 KiB
Go
// Copyright 2026 Versity Software
|
|
// This file is licensed under the Apache License, Version 2.0
|
|
// (the "License"); you may not use this file except in compliance
|
|
// with the License. You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing,
|
|
// software distributed under the License is distributed on an
|
|
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
// KIND, either express or implied. See the License for the
|
|
// specific language governing permissions and limitations
|
|
// under the License.
|
|
|
|
//go:build windows
|
|
|
|
package posix
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"os"
|
|
"time"
|
|
|
|
"golang.org/x/sys/windows"
|
|
)
|
|
|
|
// lockFileExclusive takes an exclusive lock on f via LockFileEx, polling with
|
|
// backoff so that context cancellation is honored while waiting. The lock is
|
|
// released when f is closed or the process exits.
|
|
func lockFileExclusive(ctx context.Context, f *os.File) error {
|
|
backoff := objLockInitialBackoff
|
|
for {
|
|
ol := new(windows.Overlapped)
|
|
err := windows.LockFileEx(windows.Handle(f.Fd()),
|
|
windows.LOCKFILE_EXCLUSIVE_LOCK|windows.LOCKFILE_FAIL_IMMEDIATELY,
|
|
0, 1, 0, ol)
|
|
if err == nil {
|
|
return nil
|
|
}
|
|
if !errors.Is(err, windows.ERROR_LOCK_VIOLATION) {
|
|
return err
|
|
}
|
|
|
|
select {
|
|
case <-ctx.Done():
|
|
return ctx.Err()
|
|
case <-time.After(backoff):
|
|
}
|
|
backoff = min(backoff*2, objLockMaxBackoff)
|
|
}
|
|
}
|
|
|
|
func isAdvisoryLockUnsupported(err error) bool {
|
|
return errors.Is(err, windows.ERROR_INVALID_FUNCTION) ||
|
|
errors.Is(err, windows.ERROR_NOT_SUPPORTED)
|
|
}
|