Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 797 for rock (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top