- Sort Score
- Num 10 results
- Language All
Results 431 - 440 of 570 for Records (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt
get() { if (executorServiceOrNull == null) { executorServiceOrNull = ThreadPoolExecutor( 0, Int.MAX_VALUE, 60, TimeUnit.SECONDS, SynchronousQueue(), threadFactory("$okHttpName Dispatcher", false), ) } return executorServiceOrNull!! }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 14:16:22 GMT 2025 - 9.9K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
} } /** * Shutdown the failover handler */ public void shutdown() { executor.shutdown(); try { if (!executor.awaitTermination(10, TimeUnit.SECONDS)) { executor.shutdownNow(); } } catch (InterruptedException e) { executor.shutdownNow(); Thread.currentThread().interrupt(); } }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 11.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/hash/BloomFilterTest.java
import static com.google.common.truth.Truth.assertThat; import static com.google.common.truth.Truth.assertWithMessage; import static java.nio.charset.StandardCharsets.UTF_8; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import com.google.common.base.Stopwatch; import com.google.common.collect.ImmutableSet; import com.google.common.hash.BloomFilterStrategies.LockFreeBitArray;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 19 18:53:45 GMT 2026 - 23K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaErrorHandler.java
public class RdmaErrorHandler { private static final Logger log = LoggerFactory.getLogger(RdmaErrorHandler.class); // Retry and timing constants (in ms) private static final long MAX_RETRY_DELAY = 10000; // 10 seconds maximum delay private static final int MAX_BACKOFF_SHIFT = 4; // Maximum 16x multiplier private final RdmaStatistics statistics; private final int maxRetries; private final long retryDelayMs; /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 10.5K bytes - Click Count (0) -
internal/kms/kes.go
for _, api := range APIs { list = append(list, madmin.KMSAPI{ Method: api.Method, Path: api.Path, MaxBody: api.MaxBody, Timeout: int64(api.Timeout.Truncate(time.Second).Seconds()), }) } return list, nil } // Stat returns the current KES status containing a // list of KES endpoints and the default key ID.Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Aug 18 06:43:03 GMT 2024 - 7.3K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb1/com/SmbComQueryInformationResponseTest.java
assertEquals(fileSize, response.getSize()); // Verify time was read correctly (accounting for UTime conversion) long readTime = (Long) getFieldValue(response, "lastWriteTime"); // UTime is seconds since 1970, so we need to compare at second precision assertEquals(lastWriteTime / 1000, readTime / 1000); } @Test void testReadParameterWordsWireFormatWithZeroWordCount() {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 11.9K bytes - Click Count (0) -
src/main/java/jcifs/internal/witness/WitnessRegisterMessage.java
/** * Gets the registration flags. * * @return the registration flags */ public int getFlags() { return flags; } /** * Sets the timeout value in seconds. * * @param timeout the timeout value */ public void setTimeout(int timeout) { this.timeout = timeout; } /** * Gets the timeout value. *Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 09:06:40 GMT 2025 - 8.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/DataIndexHelperTest.java
} catch (Exception e) { // Expected } long duration = System.currentTimeMillis() - startTime; // Test should complete in under 1 second (much less than the original 25+ seconds) assertTrue("Test should complete quickly (duration: " + duration + "ms)", duration < 1000); } // Fast mock implementations to minimize overhead
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 12.9K bytes - Click Count (0) -
android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java
import static com.google.common.truth.Truth.assertThat; import static com.google.common.truth.Truth.assertWithMessage; import static java.nio.charset.StandardCharsets.UTF_8; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import com.google.common.base.CharMatcher; import com.google.common.base.Equivalence; import com.google.common.base.Joiner; import com.google.common.base.Predicate;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 22.4K bytes - Click Count (0) -
docs/smb3-features/02-persistent-handles-design.md
// Load persisted handles on startup loadPersistedHandles(); // Schedule periodic persistence scheduler.scheduleAtFixedRate(this::persistHandles, 30, 30, TimeUnit.SECONDS); } public static class HandleInfo implements Serializable { private static final long serialVersionUID = 1L; private final String path;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 31.6K bytes - Click Count (0)