Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 200 for getSink (0.12 seconds)

  1. CONTRIBUTING.md

    If you are not getting cache hits from the build cache, you may be using the wrong version of Java. A fixed version (Java 11) is required to get remote cache hits.
    
    ### Building a distribution from source
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Nov 25 06:57:22 GMT 2025
    - 19K bytes
    - Click Count (0)
  2. src/test/java/jcifs/internal/smb1/com/SmbComLockingAndXTest.java

                f.setAccessible(true);
                f.set(target, value);
            } catch (Exception e) {
                fail("Failed to set field '" + name + "'", e);
            }
        }
    
        /**
         * Helper for getting a field via reflection.
         */
        private static Object getField(Object target, String name) {
            try {
                Field f = target.getClass().getDeclaredField(name);
                f.setAccessible(true);
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  3. internal/dsync/drwmutex_test.go

    	}
    }
    
    func testDualWriteLock(t *testing.T, duration time.Duration) (locked bool) {
    	drwm1 := NewDRWMutex(ds, "duallock")
    
    	// fmt.Println("Getting initial write lock")
    	ctx1, cancel1 := context.WithCancel(t.Context())
    	if !drwm1.GetLock(ctx1, cancel1, id, source, Options{Timeout: time.Second}) {
    		panic("Failed to acquire initial write lock")
    	}
    
    	go func() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  4. impl/maven-core/src/site/apt/configuration-management.apt

     Unified source directory structure that is analogous to the repository
     itself. This way locations of intermediary artifacts of a build would be
     in a known location. This would also help with developer setup i.e. getting
     new developers up and running. They could run a maven command and have all
     their source trees set up in the same way as their colleagues.
    
     here's what I do currently in the netbeans part of the mavenide project to
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 5.8K bytes
    - Click Count (0)
  5. android/guava-testlib/src/com/google/common/collect/testing/FeatureSpecificTestSuiteBuilder.java

        TestSuite suite = new TestSuite(name);
        for (@SuppressWarnings("rawtypes") // class literals
        Class<? extends AbstractTester> testerClass : testers) {
          @SuppressWarnings("unchecked") // getting rid of the raw type, for better or for worse
          TestSuite testerSuite =
              makeSuiteForTesterClass((Class<? extends AbstractTester<?>>) testerClass);
          if (testerSuite.countTestCases() > 0) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.4K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb1/smb1/SmbSession.java

        private static final int LOOKUP_RESP_LIMIT = Config.getInt("jcifs.smb1.netbios.lookupRespLimit", 3);
        private static final String DOMAIN = Config.getProperty("jcifs.smb1.smb.client.domain", null);
        private static final String USERNAME = Config.getProperty("jcifs.smb1.smb.client.username", null);
        private static final int CACHE_POLICY = Config.getInt("jcifs.smb1.netbios.cachePolicy", 60 * 10) * 60; /* 10 hours */
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 20.7K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb1/smb1/SmbComSessionSetupAndX.java

     */
    
    package jcifs.smb1.smb1;
    
    import jcifs.smb1.Config;
    
    class SmbComSessionSetupAndX extends AndXServerMessageBlock {
    
        private static final int BATCH_LIMIT = Config.getInt("jcifs.smb1.smb.client.SessionSetupAndX.TreeConnectAndX", 1);
        private static final boolean DISABLE_PLAIN_TEXT_PASSWORDS = Config.getBoolean("jcifs.smb1.smb.client.disablePlainTextPasswords", true);
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  8. cmd/erasure-healing_test.go

    	setDisks := func(newDisks ...StorageAPI) {
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Lock()
    		copy(disks, newDisks)
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    	}
    	getDisk := func(n int) StorageAPI {
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Lock()
    		disk := disks[n]
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    		return disk
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 48.5K bytes
    - Click Count (0)
  9. src/test/java/jcifs/internal/smb1/trans/SmbComTransactionTest.java

            transaction.setBuffer(buffer);
    
            byte[] released = transaction.releaseBuffer();
            assertSame(buffer, released);
            assertEquals(0x42, released[0]);
    
            // After release, getting buffer again should return null
            assertNull(transaction.releaseBuffer());
        }
    
        @Test
        @DisplayName("Test subCommand getter and setter")
        void testSubCommand() {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 10.7K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

          if (!executed) {
            runnables = new RunnableExecutorPair(runnable, executor, runnables);
            return;
          }
        }
        // Execute the runnable immediately. Because of scheduling this may end up getting called before
        // some of the previously added runnables, but we're OK with that. If we want to change the
        // contract to guarantee ordering among runnables we'd have to modify the logic here to allow
        // it.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 6.9K bytes
    - Click Count (0)
Back to Top