Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 776 for Cock (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  2. 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
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Click Count (0)
  3. 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;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 04:51:33 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        MockExecutor mock = new MockExecutor();
        TestExecutor testExecutor = new TestExecutor(mock);
        assertFalse(testExecutor.awaitTermination(10, MILLISECONDS));
        mock.assertLastMethodCalled("awaitTermination");
        assertFalse(testExecutor.isTerminated());
        mock.assertLastMethodCalled("isTerminated");
        assertFalse(testExecutor.isShutdown());
        mock.assertLastMethodCalled("isShutdown");
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 10.1K bytes
    - Click Count (0)
  5. src/test/java/jcifs/smb/SmbPipeHandleImplTest.java

    @ExtendWith(MockitoExtension.class)
    @MockitoSettings(strictness = Strictness.LENIENT)
    class SmbPipeHandleImplTest {
    
        @Mock
        SmbNamedPipe pipe;
    
        @Mock
        SmbTreeHandleImpl tree;
    
        @Mock
        SmbFileHandleImpl fileHandle;
    
        @Mock
        Configuration config;
    
        private SmbPipeHandleImpl target;
    
        @BeforeEach
        void setUp() throws SmbException {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  6. src/test/java/org/codelibs/fess/helper/SuggestHelperTest.java

                // Mock implementation
            }
    
            public void deleteElevateWord(String word, boolean apply) {
                // Mock implementation
            }
    
            public void addElevateWord(org.codelibs.fess.suggest.entity.ElevateWord elevateWord, boolean apply) {
                // Mock implementation
            }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  7. src/test/java/jcifs/smb/SmbTransportImplTest.java

    import jcifs.util.transport.Request;
    
    @ExtendWith(MockitoExtension.class)
    @MockitoSettings(strictness = Strictness.LENIENT)
    class SmbTransportImplTest {
    
        @Mock
        private CIFSContext ctx;
        @Mock
        private Configuration cfg;
        @Mock
        private Address address;
    
        private SmbTransportImpl transport;
    
        @BeforeEach
        void setUp() throws Exception {
            when(ctx.getConfig()).thenReturn(cfg);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 17.6K bytes
    - Click Count (0)
  8. internal/lsync/lrwmutex.go

    }
    
    // RLock holds a read lock on lm.
    //
    // If one or more read lock are already in use, it will grant another lock.
    // Otherwise the calling go routine blocks until the mutex is available.
    func (lm *LRWMutex) RLock() {
    	const isWriteLock = false
    	lm.lockLoop(context.Background(), lm.id, lm.source, 1<<63-1, isWriteLock)
    }
    
    // GetRLock tries to get a read lock on lm before the timeout occurs.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.8K bytes
    - Click Count (0)
  9. src/test/java/jcifs/pac/kerberos/KerberosCredentialsTest.java

    import org.junit.jupiter.api.Test;
    import org.mockito.Mock;
    import org.mockito.MockedConstruction;
    import org.mockito.Mockito;
    import org.mockito.MockitoAnnotations;
    
    /**
     * Test class for KerberosCredentials.
     */
    class KerberosCredentialsTest {
    
        @Mock
        private LoginContext loginContext;
    
        @Mock
        private Subject subject;
    
        @Mock
        private KerberosKey key1;
    
        @Mock
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 7K bytes
    - Click Count (0)
  10. internal/dsync/dsync_test.go

    	dm1st := NewDRWMutex(ds, "aap")
    	dm2nd := NewDRWMutex(ds, "aap")
    
    	dm1st.Lock(id, source)
    
    	// Release lock after 10 seconds
    	go func() {
    		time.Sleep(5 * testDrwMutexAcquireTimeout)
    		// fmt.Println("Unlocking dm1")
    
    		dm1st.Unlock(t.Context())
    	}()
    
    	dm2nd.Lock(id, source)
    
    	// fmt.Printf("2nd lock obtained after 1st lock is released\n")
    	time.Sleep(testDrwMutexRefreshCallTimeout * 2)
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.8K bytes
    - Click Count (0)
Back to Top