- Sort Score
- Num 10 results
- Language All
Results 81 - 90 of 200 for getSink (0.12 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)