- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 67 for wlocked (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/jcifs/util/AuthenticationRateLimiter.java
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 15.1K bytes - Click Count (0) -
internal/dsync/drwmutex.go
} // Granted - represents a structure of a granted lock. type Granted struct { index int lockUID string // Locked if set with UID string, unlocked if empty } func (g *Granted) isLocked() bool { return isLocked(g.lockUID) } func isLocked(uid string) bool { return len(uid) > 0 } // NewDRWMutex - initializes a new dsync RW mutex.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.3K bytes - Click Count (0) -
cmd/local-locker.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 10K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/artifact/repository/MavenArtifactRepository.java
this.mirroredRepositories = Collections.emptyList(); } } @Override public boolean isBlocked() { return blocked; } @Override public void setBlocked(boolean blocked) { this.blocked = blocked; }
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 12.1K bytes - Click Count (0) -
cmd/local-locker_test.go
} // A UID is added for every resource. // We removed Add Rlocked entries if len(l.lockUID) != len(wResources)*m { t.Fatalf("lockUID len, got %d, want %d + %d", len(l.lockUID), 0, len(wResources)*m) } // Remove write locked for i, names := range wResources { arg := dsync.LockArgs{ UID: wUIDs[i], Resources: names[:],
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 11.8K bytes - Click Count (0) -
src/test/java/org/codelibs/core/io/FileUtilTest.java
final Path baseDir = tempFolder.getRoot().toPath(); final Path traversalPath = baseDir.resolve("../../../etc/passwd"); assertFalse("Path traversal should be blocked", FileUtil.isPathSafe(traversalPath, baseDir)); } /** * Test isPathSafe with File objects * * @throws Exception */ @Test
Created: Sat Dec 20 08:55:33 GMT 2025 - Last Modified: Sat Nov 22 11:21:59 GMT 2025 - 10.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
private static final long SMALL_TIMEOUT_MILLIS = 10; /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */ private static final long EXPECTED_HANG_DELAY_MILLIS = 75; /** * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked. */ private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000; /**
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 21:00:51 GMT 2025 - 27.1K bytes - Click Count (0) -
src/test/java/jcifs/util/PathValidatorTest.java
@Test public void testClearBlacklist() throws Exception { validator.addToBlacklist("\\share\\blocked"); validator.clearBlacklist(); // Should allow previously blacklisted path String allowed = validator.validatePath("\\share\\blocked\\file.txt"); assertEquals("\\share\\blocked\\file.txt", allowed); } @Test public void testClearWhitelist() throws Exception {Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 14.6K bytes - Click Count (0) -
internal/ringbuffer/ring_buffer.go
func (r *RingBuffer) WithCancel(ctx context.Context) *RingBuffer { go func() { <-ctx.Done() r.CloseWithError(ctx.Err()) }() return r } func (r *RingBuffer) setErr(err error, locked bool) error { if !locked { r.mu.Lock() defer r.mu.Unlock() } if r.err != nil && r.err != io.EOF { return r.err } switch err { // Internal errors are transient
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.3K bytes - Click Count (0)