Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 850 for Acquire (1.63 seconds)

  1. src/test/java/jcifs/smb/SimpleMemoryManagementTest.java

            assertTrue(session.isInUse(), "New session should be in use due to transport acquisition");
    
            // Test additional acquire
            session.acquire();
            assertTrue(session.isInUse(), "Session should still be in use after additional acquire");
    
            // Test release (still in use because of initial transport acquire)
            session.release();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  2. src/test/java/jcifs/smb/SmbTreeHandleImplTest.java

        }
    
        @Test
        @DisplayName("acquire after release reacquires underlying tree connection")
        void acquireAfterReleaseReacquires() {
            // After dropping to zero, acquire() should reacquire the underlying connection
            // Drop usage to zero
            handle.release();
            verify(treeConnection, times(1)).release();
    
            // Acquire from 0 -> 1 should acquire underlying
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 14.4K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        limiter.acquire(Integer.MAX_VALUE / 4);
        limiter.acquire(Integer.MAX_VALUE / 2);
        limiter.acquire(Integer.MAX_VALUE);
        assertEvents("R0.00", "R0.00", "R0.00"); // no wait, infinite rate!
    
        limiter.setRate(2.0);
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        assertEvents(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 22K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        limiter.acquire(Integer.MAX_VALUE / 4);
        limiter.acquire(Integer.MAX_VALUE / 2);
        limiter.acquire(Integer.MAX_VALUE);
        assertEvents("R0.00", "R0.00", "R0.00"); // no wait, infinite rate!
    
        limiter.setRate(2.0);
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        assertEvents(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 22K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

       */
      @CanIgnoreReturnValue
      public double acquire() {
        return acquire(1);
      }
    
      /**
       * Acquires the given number of permits from this {@code RateLimiter}, blocking until the request
       * can be granted. Tells the amount of time slept, if any.
       *
       * @param permits the number of permits to acquire
       * @return time spent sleeping to enforce rate, in seconds; 0.0 if not rate-limited
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 20:05:27 GMT 2025
    - 21.8K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * evaluate the integral of the function from 7.0 to 10.0.
       *
       * Using integrals guarantees that the effect of a single acquire(3) is equivalent to {
       * acquire(1); acquire(1); acquire(1); }, or { acquire(2); acquire(1); }, etc, since the integral
       * of the function in [7.0, 10.0] is equivalent to the sum of the integrals of [7.0, 8.0], [8.0,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 19.3K bytes
    - Click Count (0)
  7. src/test/java/jcifs/smb/SmbSessionImplSecurityTest.java

            // Acquire session multiple times
            for (int i = 0; i < threadCount - 1; i++) {
                session.acquire();
            }
    
            // When - Multiple threads try to release/acquire concurrently
            for (int t = 0; t < threadCount; t++) {
                final boolean shouldRelease = (t < 3); // First 3 threads release, others acquire
    
                executor.submit(() -> {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 11K bytes
    - Click Count (0)
  8. src/test/java/jcifs/smb/SmbSessionImplTest.java

        }
    
        @Test
        @DisplayName("acquire after release reacquires transport")
        void testAcquireReacquiresTransport() {
            SmbSessionImpl session = newSession();
    
            // Drop usage to zero which releases transport and flips transportAcquired=false
            session.release();
            clearInvocations(transport);
    
            // Re-acquire should reacquire transport
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  9. src/test/java/jcifs/smb/SmbTreeConnectionTraceTest.java

            // Act: create wrapper using delegate, then acquire and release once
            SmbTreeConnectionTrace wrapper = new SmbTreeConnectionTrace(delegate);
            wrapper.acquire();
            wrapper.release();
    
            // Assert: delegate interactions occur when usage transitions happen
            verify(delegate, times(1)).acquire();
            verify(delegate, times(1)).release();
        }
    
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  10. src/test/java/jcifs/smb/SmbTreeConnectionTest.java

            c.acquire();
            verify(tree, times(1)).acquire();
    
            // Act: second acquire does not call tree.acquire again
            c.acquire();
            verify(tree, times(1)).acquire();
    
            // Act: first release does not release yet (usage -> 1)
            c.release();
            verify(tree, never()).release();
    
            // Act: second release (usage -> 0) releases the tree
            c.release();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 13K bytes
    - Click Count (0)
Back to Top