Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for LockedOpenFile (0.24 sec)

  1. internal/lock/lock_nix.go

    // it is similar to LockedOpenFile with with syscall.LOCK_EX
    // mode but along with syscall.LOCK_NB such that the function
    // doesn't wait forever but instead returns if it cannot
    // acquire a write lock.
    func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
    	return lockedOpenFile(path, flag, perm, syscall.LOCK_NB)
    }
    
    // LockedOpenFile - initializes a new lock and protects
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  2. internal/lock/lock_solaris.go

    // it is similar to LockedOpenFile with with syscall.LOCK_EX
    // mode but along with syscall.LOCK_NB such that the function
    // doesn't wait forever but instead returns if it cannot
    // acquire a write lock.
    func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
    	return lockedOpenFile(path, flag, perm, syscall.F_SETLK)
    }
    
    // LockedOpenFile - initializes a new lock and protects
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 2.8K bytes
    - Viewed (0)
  3. internal/lock/lock_test.go

    		err = os.Remove(f.Name())
    		if err != nil {
    			t.Fatal(err)
    		}
    	}()
    
    	_, err = LockedOpenFile(f.Name(), os.O_APPEND, 0o600)
    	if err == nil {
    		t.Fatal("Should fail here")
    	}
    }
    
    // Tests lock directory fail.
    func TestLockDirFail(t *testing.T) {
    	d := t.TempDir()
    
    	_, err := LockedOpenFile(d, os.O_APPEND, 0o600)
    	if err == nil {
    		t.Fatal("Should fail here")
    	}
    }
    
    // Tests rwlock methods.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.6K bytes
    - Viewed (0)
  4. internal/lock/lock_windows.go

    		//lint:ignore SA4016 Reasons
    		lockType = lockFileFailImmediately // Set this to enable shared lock and fail immediately.
    	}
    	return lockedOpenFile(path, flag, perm, lockType)
    }
    
    // LockedOpenFile - initializes a new lock and protects
    // the file from concurrent access.
    func LockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
    	var lockType uint32 = lockFileExclusiveLock
    	if flag == syscall.O_RDONLY {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 18 18:08:15 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  5. internal/lock/lock.go

    		refs:       1,
    	}, nil
    }
    
    // RLockedOpenFile - returns a wrapped read locked file, if the file
    // doesn't exist at path returns an error.
    func RLockedOpenFile(path string) (*RLockedFile, error) {
    	lkFile, err := LockedOpenFile(path, os.O_RDONLY, 0o666)
    	if err != nil {
    		return nil, err
    	}
    
    	return newRLockedFile(lkFile)
    }
    
    // LockedFile represents a locked file
    type LockedFile struct {
    	*os.File
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 2.5K bytes
    - Viewed (0)
Back to top