mirror of
https://gitea.com/Lydanne/buildx.git
synced 2025-07-09 21:17:09 +08:00
vendor: update buildkit to v0.15.1
Signed-off-by: CrazyMax <1951866+crazy-max@users.noreply.github.com>
This commit is contained in:
2
vendor/github.com/gofrs/flock/README.md
generated
vendored
2
vendor/github.com/gofrs/flock/README.md
generated
vendored
@ -1,7 +1,7 @@
|
||||
# flock
|
||||
|
||||
[](https://pkg.go.dev/github.com/gofrs/flock)
|
||||
[](https://github.com/gofrs/flock/blob/master/LICENSE)
|
||||
[](https://github.com/gofrs/flock/blob/main/LICENSE)
|
||||
[](https://goreportcard.com/report/github.com/gofrs/flock)
|
||||
|
||||
`flock` implements a thread-safe file lock.
|
||||
|
25
vendor/github.com/gofrs/flock/flock.go
generated
vendored
25
vendor/github.com/gofrs/flock/flock.go
generated
vendored
@ -163,9 +163,9 @@ func tryCtx(ctx context.Context, fn func() (bool, error), retryDelay time.Durati
|
||||
}
|
||||
}
|
||||
|
||||
func (f *Flock) setFh() error {
|
||||
func (f *Flock) setFh(flag int) error {
|
||||
// open a new os.File instance
|
||||
fh, err := os.OpenFile(f.path, f.flag, f.perm)
|
||||
fh, err := os.OpenFile(f.path, flag, f.perm)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
@ -176,9 +176,11 @@ func (f *Flock) setFh() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
// ensure the file handle is closed if no lock is held.
|
||||
func (f *Flock) ensureFhState() {
|
||||
if f.l || f.r || f.fh == nil {
|
||||
// resetFh resets file handle:
|
||||
// - tries to close the file (ignore errors)
|
||||
// - sets fh to nil.
|
||||
func (f *Flock) resetFh() {
|
||||
if f.fh == nil {
|
||||
return
|
||||
}
|
||||
|
||||
@ -187,11 +189,18 @@ func (f *Flock) ensureFhState() {
|
||||
f.fh = nil
|
||||
}
|
||||
|
||||
// ensure the file handle is closed if no lock is held.
|
||||
func (f *Flock) ensureFhState() {
|
||||
if f.l || f.r || f.fh == nil {
|
||||
return
|
||||
}
|
||||
|
||||
f.resetFh()
|
||||
}
|
||||
|
||||
func (f *Flock) reset() {
|
||||
f.l = false
|
||||
f.r = false
|
||||
|
||||
_ = f.fh.Close()
|
||||
|
||||
f.fh = nil
|
||||
f.resetFh()
|
||||
}
|
||||
|
12
vendor/github.com/gofrs/flock/flock_unix.go
generated
vendored
12
vendor/github.com/gofrs/flock/flock_unix.go
generated
vendored
@ -50,7 +50,7 @@ func (f *Flock) lock(locked *bool, flag int) error {
|
||||
}
|
||||
|
||||
if f.fh == nil {
|
||||
if err := f.setFh(); err != nil {
|
||||
if err := f.setFh(f.flag); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
@ -147,7 +147,7 @@ func (f *Flock) try(locked *bool, flag int) (bool, error) {
|
||||
}
|
||||
|
||||
if f.fh == nil {
|
||||
if err := f.setFh(); err != nil {
|
||||
if err := f.setFh(f.flag); err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
@ -183,6 +183,7 @@ retry:
|
||||
// This comes from `util-linux/sys-utils/flock.c`:
|
||||
// > Since Linux 3.4 (commit 55725513)
|
||||
// > Probably NFSv4 where flock() is emulated by fcntl().
|
||||
// > https://github.com/util-linux/util-linux/blob/198e920aa24743ef6ace4e07cf6237de527f9261/sys-utils/flock.c#L374-L390
|
||||
func (f *Flock) reopenFDOnError(err error) (bool, error) {
|
||||
if !errors.Is(err, unix.EIO) && !errors.Is(err, unix.EBADF) {
|
||||
return false, nil
|
||||
@ -197,16 +198,13 @@ func (f *Flock) reopenFDOnError(err error) (bool, error) {
|
||||
return false, nil
|
||||
}
|
||||
|
||||
_ = f.fh.Close()
|
||||
f.fh = nil
|
||||
f.resetFh()
|
||||
|
||||
// reopen in read-write mode and set the file handle
|
||||
fh, err := os.OpenFile(f.path, f.flag, f.perm)
|
||||
err = f.setFh(f.flag | os.O_RDWR)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
f.fh = fh
|
||||
|
||||
return true, nil
|
||||
}
|
||||
|
4
vendor/github.com/gofrs/flock/flock_unix_fcntl.go
generated
vendored
4
vendor/github.com/gofrs/flock/flock_unix_fcntl.go
generated
vendored
@ -112,7 +112,7 @@ func (f *Flock) lock(locked *bool, flag lockType) error {
|
||||
}
|
||||
|
||||
if f.fh == nil {
|
||||
if err := f.setFh(); err != nil {
|
||||
if err := f.setFh(f.flag); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
@ -359,7 +359,7 @@ func (f *Flock) try(locked *bool, flag lockType) (bool, error) {
|
||||
}
|
||||
|
||||
if f.fh == nil {
|
||||
if err := f.setFh(); err != nil {
|
||||
if err := f.setFh(f.flag); err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
|
4
vendor/github.com/gofrs/flock/flock_windows.go
generated
vendored
4
vendor/github.com/gofrs/flock/flock_windows.go
generated
vendored
@ -56,7 +56,7 @@ func (f *Flock) lock(locked *bool, flag uint32) error {
|
||||
}
|
||||
|
||||
if f.fh == nil {
|
||||
if err := f.setFh(); err != nil {
|
||||
if err := f.setFh(f.flag); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
@ -136,7 +136,7 @@ func (f *Flock) try(locked *bool, flag uint32) (bool, error) {
|
||||
}
|
||||
|
||||
if f.fh == nil {
|
||||
if err := f.setFh(); err != nil {
|
||||
if err := f.setFh(f.flag); err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user