- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 797 for rock (0.02 sec)
-
src/main/java/jcifs/internal/smb2/lock/Smb2Lock.java
*/ package jcifs.internal.smb2.lock; import jcifs.Encodable; import jcifs.internal.util.SMBUtil; /** * SMB2 Lock data structure. * * This class represents a single lock element used in * SMB2 Lock requests for byte-range locking. * * @author mbechler */ public class Smb2Lock implements Encodable { /** * Flag indicating a shared lock that allows concurrent read access. */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.8K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/SmbRandomAccessFileTest.java
// Mock the transport layer smbTransport = mock(SmbTransport.class); smbTransport.rcv_buf_size = 4096; smbTransport.snd_buf_size = 4096; // Mock the session layer smbSession = mock(SmbSession.class); smbSession.transport = smbTransport; // Mock the tree layer smbTree = mock(SmbTree.class); smbTree.session = smbSession;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 9.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/fscc/FileInformationTest.java
} } } /** * Test mock implementation of FileInformation interface */ @Test @DisplayName("Test FileInformation interface mock implementation") void testFileInformationMockImplementation() { // Create mock FileInformation mockFileInfo = mock(FileInformation.class); // Define behavior
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 11.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
}; public void testSchedule() { MockExecutor mock = new MockExecutor(); TestExecutor testExecutor = new TestExecutor(mock); Future<?> unused1 = testExecutor.schedule(DO_NOTHING, 10, MINUTES); mock.assertLastMethodCalled("scheduleRunnable", 10, MINUTES); Future<?> unused2 = testExecutor.schedule(callable(DO_NOTHING), 5, SECONDS); mock.assertLastMethodCalled("scheduleCallable", 5, SECONDS); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 7.4K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbTransportPoolImplTest.java
class SmbTransportPoolImplTest { private SmbTransportPoolImpl pool; @Mock private CIFSContext ctx; @Mock private Configuration config; @Mock private NameServiceClient nameSvc; @Mock private Credentials creds; @Mock private Address address; @Mock private SmbNegotiationResponse negotiationResponse; @BeforeEach void setUp() {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 19.2K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbCopyUtilTest.java
void copyFile_serverSide_zeroLength_happyPath() throws Exception { // Arrange SmbFile src = mock(SmbFile.class); SmbFile dest = mock(SmbFile.class); SmbTreeHandleImpl sh = mock(SmbTreeHandleImpl.class); SmbTreeHandleImpl dh = mock(SmbTreeHandleImpl.class); when(sh.isSMB2()).thenReturn(true); when(dh.isSMB2()).thenReturn(true);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 12.1K bytes - Viewed (0) -
docs/contribute/concurrency.md
### Locks We have 3 different things that we synchronize on. #### Http2Connection This lock guards internal state of each connection. This lock is never held for blocking operations. That means that we acquire the lock, read or write a few fields and release the lock. No I/O and no application-layer callbacks. #### Http2Stream
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
src/test/java/jcifs/http/NetworkExplorerTest.java
private NetworkExplorer networkExplorer; @Mock private ServletConfig servletConfig; @Mock private ServletContext servletContext; @Mock private HttpServletRequest request; @Mock private HttpServletResponse response; @Mock private HttpSession session; @Mock private SmbFile smbFile; @Mock private SmbResourceLocator locator;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 04:51:33 UTC 2025 - 21.2K bytes - Viewed (0) -
internal/lru/lru.go
c.mu.Lock() bucketIdx := c.nextCleanupBucket timeToExpire := time.Until(c.buckets[bucketIdx].newestEntry) // wait for newest entry to expire before cleanup without holding lock if timeToExpire > 0 { c.mu.Unlock() time.Sleep(timeToExpire) c.mu.Lock() } for _, ent := range c.buckets[bucketIdx].entries { c.removeElement(ent) } c.nextCleanupBucket = (c.nextCleanupBucket + 1) % numBuckets
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Fri Apr 25 08:22:26 UTC 2025 - 12.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/witness/MockWitnessService.java
serverThread = new Thread(this::runServer, "MockWitnessService"); serverThread.setDaemon(true); serverThread.start(); log.info("Mock witness service started on port {}", serverSocket.getLocalPort()); } /** * Stop the mock witness service */ public void stop() { running.set(false); if (serverSocket != null && !serverSocket.isClosed()) { try {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 09:06:40 UTC 2025 - 8.2K bytes - Viewed (0)