- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 34 for LOCKED (0.06 seconds)
-
internal/lsync/lrwmutex_test.go
} } func TestSimpleWriteLockTimedOut(t *testing.T) { locked := testSimpleWriteLock(t, time.Second) expected := false if locked != expected { t.Errorf("TestSimpleWriteLockTimedOut(): \nexpected %#v\ngot %#v", expected, locked) } } func testDualWriteLock(t *testing.T, duration time.Duration) (locked bool) { ctx := t.Context() lrwm := NewLRWMutex()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7.8K bytes - Click Count (0) -
internal/dsync/drwmutex_test.go
expected := true if locked != expected { t.Errorf("TestSimpleWriteLockAcquired(): \nexpected %#v\ngot %#v", expected, locked) } } func TestSimpleWriteLockTimedOut(t *testing.T) { locked := testSimpleWriteLock(t, testDrwMutexAcquireTimeout) expected := false if locked != expected { t.Errorf("TestSimpleWriteLockTimedOut(): \nexpected %#v\ngot %#v", expected, locked) } }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.4K bytes - Click Count (0) -
internal/lock/lock.go
// open file descriptor. package lock import ( "errors" "os" "sync" ) // ErrAlreadyLocked is returned if the underlying fd is already locked. var ErrAlreadyLocked = errors.New("file already locked") // RLockedFile represents a read locked file, implements a special // closer which only closes the associated *os.File when the ref count. // has reached zero, i.e when all the readers have given up their locks.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.5K bytes - Click Count (0) -
internal/lsync/lrwmutex.go
lm.ref = 1 lm.isWriteLock = true locked = true } } else { if !lm.isWriteLock { lm.ref++ locked = true } } return locked } const ( lockRetryInterval = 50 * time.Millisecond ) // lockLoop will acquire either a read or a write lock // // The call will block until the lock is granted using a built-in // timing randomized back-off algorithm to try again until successfulCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Click Count (0) -
internal/dsync/lock-args.go
type LockArgs struct { // Unique ID of lock/unlock request. UID string // Resources contains single or multiple entries to be locked/unlocked. Resources []string // Owner represents unique ID for this instance, an owner who originally requested // the locked resource, useful primarily in figuring out stale locks. Owner string // Source contains the line number, function and file name of the codeCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Jul 24 10:24:01 GMT 2024 - 1.8K bytes - Click Count (0) -
cmd/namespace-lock.go
} nsLk.ref++ n.lockMap[resource] = nsLk n.lockMapMutex.Unlock() // Locking here will block (until timeout). if readLock { locked = nsLk.GetRLock(ctx, opsID, lockSource, timeout) } else { locked = nsLk.GetLock(ctx, opsID, lockSource, timeout) } if !locked { // We failed to get the lock // Decrement ref count since we failed to get the lock n.lockMapMutex.Lock() n.lockMap[resource].ref--
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.2K bytes - Click Count (0) -
internal/lock/lock_test.go
} // blocking on locked file locked := make(chan struct{}, 1) go func() { bl, blerr := LockedOpenFile(f.Name(), os.O_WRONLY, 0o600) if blerr != nil { t.Error(blerr) return } locked <- struct{}{} if blerr = bl.Close(); blerr != nil { t.Error(blerr) return } }() select { case <-locked: t.Error("unexpected unblocking")
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 3.7K bytes - Click Count (0) -
.github/workflows/build-docs.yml
uses: astral-sh/setup-uv@v7 with: enable-cache: true cache-dependency-glob: | pyproject.toml uv.lock - name: Install docs extras run: uv sync --locked --no-dev --group docs - name: Export Language Codes id: show-langs run: | echo "langs=$(uv run ./scripts/docs.py langs-json)" >> $GITHUB_OUTPUT build-docs: needs:Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Sat Mar 14 15:01:34 GMT 2026 - 3.3K bytes - Click Count (0) -
src/packaging/common/systemd/fess.service
SuccessExitStatus=143 # Specifies the maximum file descriptor number that can be opened by this process LimitNOFILE=${packaging.os.max.open.files} # Specifies the maximum number of bytes of memory that may be locked into RAM # Set to "infinity" if you use the 'bootstrap.mlockall: true' option # in fess.yml and 'MAX_LOCKED_MEMORY=unlimited' in ${packaging.env.file} #LimitMEMLOCK=infinityCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 15 06:32:15 GMT 2023 - 1.1K bytes - Click Count (0) -
.github/workflows/translate.yml
- name: Setup uv uses: astral-sh/setup-uv@v7 with: cache-dependency-glob: | pyproject.toml uv.lock - name: Install Dependencies run: uv sync --locked --no-dev --group github-actions --group translations - name: Export Language Codes id: show-langs run: | echo "langs=$(uv run ./scripts/translate.py llm-translatable-json)" >> $GITHUB_OUTPUTCreated: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Wed Mar 18 15:36:56 GMT 2026 - 4K bytes - Click Count (0)