Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 70 for rlocked (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/main/java/jcifs/util/AuthenticationRateLimiter.java

                recentAttempts.set(0);
                blocked.set(false);
                blockExpiry = null;
                windowStart = Instant.now();
            }
    
            void block(Duration duration) {
                blocked.set(true);
                blockExpiry = Instant.now().plus(duration);
            }
    
            boolean isBlocked() {
                return blocked.get();
            }
    
            int getRecentAttempts() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  2. src/test/java/jcifs/util/AuthenticationRateLimiterTest.java

            rateLimiter.recordFailure(username, ip);
    
            // After 3 failures, account should be locked
            try {
                rateLimiter.checkAttempt(username, ip);
                fail("Should throw SmbException for locked account");
            } catch (SmbException e) {
                assertTrue(e.getMessage().contains("locked out"), "Should indicate account lockout");
            }
        }
    
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 10K bytes
    - Click Count (0)
  4. apache-maven/src/assembly/maven/conf/settings.xml

          <url>http://my.repository.com/repo/path</url>
        </mirror>
        -->
        <mirror>
          <id>maven-default-http-blocker</id>
          <mirrorOf>external:http:*</mirrorOf>
          <name>Pseudo repository to mirror external repositories initially using HTTP.</name>
          <url>http://0.0.0.0/</url>
          <blocked>true</blocked>
        </mirror>
      </mirrors>
    
      <!-- repositories
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jan 22 07:44:50 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  5. 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 Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  6. internal/dsync/dsync_test.go

    	// non-profitable and allows to confirm that spinning does not do harm.
    	// To achieve this we create excess of goroutines most of which do local work.
    	// These goroutines yield during local work, so that switching from
    	// a blocked goroutine to other goroutines is profitable.
    	// As a matter of fact, this benchmark still triggers some spinning in the mutex.
    	m := NewDRWMutex(ds, "")
    	var acc0, acc1 uint64
    	b.SetParallelism(4)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  7. cmd/erasure.go

    	// some may be local and some remote.
    	getEndpointStrings func() []string
    
    	// Locker mutex map.
    	nsMutex *nsLockMap
    }
    
    // NewNSLock - initialize a new namespace RWLocker instance.
    func (er erasureObjects) NewNSLock(bucket string, objects ...string) RWLocker {
    	return er.nsMutex.NewNSLock(er.getLockers, bucket, objects...)
    }
    
    // Shutdown function for object storage interface.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.1K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        ReentrantLock lockD = otherFactory.newReentrantLock("LockD");
    
        // lockA -> lockD
        lockA.lock();
        lockD.lock();
        lockA.unlock();
        lockD.unlock();
    
        // lockD -> lockA should fail even though lockD is from a different factory.
        lockD.lock();
        PotentialDeadlockException expected =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        ReentrantLock lockD = otherFactory.newReentrantLock("LockD");
    
        // lockA -> lockD
        lockA.lock();
        lockD.lock();
        lockA.unlock();
        lockD.unlock();
    
        // lockD -> lockA should fail even though lockD is from a different factory.
        lockD.lock();
        PotentialDeadlockException expected =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  10. src/test/java/jcifs/dcerpc/msrpc/samrTest.java

            }
    
            @Test
            @DisplayName("Should decode output parameters correctly")
            void testDecodeOut() throws NdrException {
                // Given: Close handle message with mocked return value
                samr.SamrCloseHandle message = new samr.SamrCloseHandle(mockPolicyHandle);
                when(mockNdrBuffer.dec_ndr_long()).thenReturn(0);
    
                // When: Decoding output
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 33.7K bytes
    - Click Count (0)
Back to Top