- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for currentTask (0.09 seconds)
-
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
override fun start() { taskRunner.assertLockHeld() require(currentTask == this) activeThreads++ tasksExecutor.execute { taskRunner.assertLockNotHeld() require(currentTask == this) try { runnable.run() require(currentTask == this) { "unexpected current task: $currentTask" } } finally { taskRunner.withLock {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 11.9K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 10.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 10.5K bytes - Click Count (0) -
src/main/java/jcifs/smb/PreauthIntegrityService.java
public byte[] getCurrentHash() { synchronized (hashLock) { return currentHash.clone(); } } public void updateHash(byte[] newHash) { synchronized (hashLock) { if (newHash != null && newHash.length == currentHash.length) { this.currentHash = newHash.clone(); } } }
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 12.1K bytes - Click Count (0) -
cmd/xl-storage_unix_test.go
t.Fatalf("Stat failed with %s expected to pass.", err) } // Get umask of the bits stored. currentUmask := 0o777 - uint32(st.Mode().Perm()) // Verify if umask is correct. if int(currentUmask) != testCase.expectedUmask { t.Fatalf("Umask check failed expected %d, got %d", testCase.expectedUmask, currentUmask) } } // Tests if the file creations happen with proper umask. func TestIsValidUmaskFile(t *testing.T) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 3.4K bytes - Click Count (0) -
cmd/erasure-sets.go
s.erasureDisksMu.Unlock() return } if currentDisk := s.erasureDisks[setIndex][diskIndex]; currentDisk != nil { if !reflect.DeepEqual(currentDisk.Endpoint(), disk.Endpoint()) { err = fmt.Errorf("Detected unexpected drive ordering refusing to use the drive: expecting %s, found %s, refusing to use the drive", currentDisk.Endpoint(), disk.Endpoint()) printEndpointError(endpoint, err, false)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 37K bytes - Click Count (1)