- Sort Score
- Num 10 results
- Language All
Results 311 - 320 of 412 for locks (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/test/java/jcifs/SmbResourceTest.java
*/ private SmbResource createMockResource() { return mock(SmbResource.class); } @BeforeEach void setUp() { // Reset mocks to ensure clean state for each test reset(mockResource, mockLocator, mockContext); } @Nested @DisplayName("Interface Contract Tests") class InterfaceContractTests { @TestCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 35K bytes - Click Count (0) -
docs/en/docs/tutorial/bigger-applications.md
* and from it, import the function `get_token_header`. But that file doesn't exist, our dependencies are in a file at `app/dependencies.py`. Remember how our app/file structure looks like: <img src="/img/tutorial/bigger-applications/package.drawio.svg"> --- The two dots `..`, like in: ```Python from ..dependencies import get_token_header ``` mean:
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Sat Mar 07 09:29:03 GMT 2026 - 19.2K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbCopyUtil.java
} if (dfd == null || !dfd.isValid()) { // don't reopen the file for every round if it's not necessary, keep the lock dfd = openCopyTargetFile(dest, src.getAttributes(), !write); }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 16.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
case SATISFIED_BEFORE_WAITING: guard.setSatisfied(true); break; case SATISFIED_WHILE_WAITING: guard.setSatisfied(false); enterSatisfyGuardAndLeaveInAnotherThread(); // enter blocks until we call waitFor break; case UNSATISFIED_BEFORE_AND_WHILE_WAITING: guard.setSatisfied(false); break; case SATISFIED_AND_INTERRUPTED_BEFORE_WAITING:Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.7K bytes - Click Count (0) -
src/test/java/jcifs/internal/fscc/FileFsFullSizeInformationTest.java
@Test @DisplayName("Should handle typical Linux ext4 configuration") void shouldHandleTypicalExt4Configuration() throws SMBProtocolDecodingException { // Given - typical ext4: 4KB blocks long totalBlocks = 26214400L; // 100GB / 4KB long freeBlocks = 5242880L; // 20GB / 4KB ByteBuffer buffer = ByteBuffer.allocate(32); buffer.order(ByteOrder.LITTLE_ENDIAN);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 30.5K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbFileInputStream.java
response.adjustOffset(n); } } while (len > effectiveBlockSize && n == r); // Optimization: Continue reading if we have small remaining data and got full blocks // This reduces round trips for slightly larger reads if (len > 0 && len <= (effectiveBlockSize / 4) && n == r) { try { if (th.isSMB2()) {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 15.6K bytes - Click Count (0) -
src/test/java/jcifs/smb/SIDTest.java
void testStaticToByteArrayNull() { assertThrows(NullPointerException.class, () -> SID.toByteArray(null)); } } @Nested @DisplayName("Tests requiring mocks") @ExtendWith(MockitoExtension.class) class MockedTests { @Mock CIFSContext mockCtx; @Mock SidResolver mockResolver; @BeforeEach
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 15.8K bytes - Click Count (0) -
internal/ioutil/ioutil.go
MediumBlock = 128 * humanize.KiByte // Default r/w block size for medium sized objects. LargeBlock = 1 * humanize.MiByte // Default r/w block size for normal objects. ) // AlignedBytePool is a pool of fixed size aligned blocks type AlignedBytePool struct { size int p bpool.Pool[*[]byte] } // NewAlignedBytePool creates a new pool with the specified size. func NewAlignedBytePool(sz int) *AlignedBytePool {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 11.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/RateLimiter.java
import java.util.Locale; import java.util.concurrent.TimeUnit; import org.jspecify.annotations.Nullable; /** * A rate limiter. Conceptually, a rate limiter distributes permits at a configurable rate. Each * {@link #acquire()} blocks if necessary until a permit is available, and then takes it. Once * acquired, permits need not be released. * * <p>{@code RateLimiter} is safe for concurrent use: It will restrict the total rate of calls fromCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 26 20:05:27 GMT 2025 - 21.8K bytes - Click Count (0) -
okhttp/src/jvmMain/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.list
lifeinsurance lifestyle lig.it lighting liguria.it like likes-pie.com likescandy.com lillehammer.no lillesand.no lilly lima-city.at lima-city.ch lima-city.de lima-city.rocks lima.zone limanowa.pl limited limo lincoln lindas.no lindesnes.no lindås.no link linkyard-cloud.ch linkyard.cloud lipsy littlestar.jp live live-on.net
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue May 27 22:00:49 GMT 2025 - 129.6K bytes - Click Count (3)