- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 850 for Acquire (0.06 seconds)
-
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) -
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 underlyingCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 14.4K bytes - Click Count (0) -
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) -
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) -
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-limitedCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 26 20:05:27 GMT 2025 - 21.8K bytes - Click Count (0) -
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) -
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) -
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 transportCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 12.5K bytes - Click Count (0) -
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(); } @TestCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 8.7K bytes - Click Count (0) -
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)