- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 701 for seconden (0.04 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/AsyncRequestBody.kt
* limitations under the License. */ package okhttp3.internal.duplex import java.util.concurrent.BlockingQueue import java.util.concurrent.LinkedBlockingQueue import java.util.concurrent.TimeUnit.SECONDS import okhttp3.MediaType import okhttp3.RequestBody import okio.BufferedSink import org.junit.jupiter.api.Assertions.assertTrue /** A duplex request body that keeps the provided sinks so they can be written to later. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
createCacheBuilder().expireAfterWrite(99999, SECONDS), createCacheBuilder().maximumSize(SMALL_MAX_SIZE).expireAfterAccess(SMALL_MAX_SIZE, SECONDS), createCacheBuilder().maximumSize(SMALL_MAX_SIZE).expireAfterWrite(SMALL_MAX_SIZE, SECONDS)); } /** Returns an iterable containing all combinations weakKeys and weak/softValues. */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 110.5K bytes - Viewed (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(); } }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 11.6K bytes - Viewed (0) -
cmd/metrics-v3-scanner.go
scannerVersionsScannedMD = NewCounterMD(scannerVersionsScanned, "Total number of object versions scanned since server start") scannerLastActivitySecondsMD = NewGaugeMD(scannerLastActivitySeconds, "Time elapsed (in seconds) since last scan activity.") ) // loadClusterScannerMetrics - `MetricsLoaderFn` for cluster webhook // such as failed objects and directories scanned.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri May 24 19:29:25 UTC 2024 - 2.8K bytes - Viewed (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
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 05:35:01 UTC 2025 - 12.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
// stop it. blockingCallable.waitForStart(); // Give the second task a chance to (incorrectly) start up while the first task is running. assertThat(future2.isDone()).isFalse(); // Stop the first task. The second task should then run. blockingCallable.stop(); executor.shutdown(); assertThat(executor.awaitTermination(10, SECONDS)).isTrue(); assertThat(getDone(future2)).isFalse(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 20:58:01 UTC 2025 - 16.1K bytes - Viewed (0) -
cmd/storage-rest-server.go
c.done = nil } return c.rc.Close() } // keepHTTPReqResponseAlive can be used to avoid timeouts with long storage // operations, such as bitrot verification or data usage scanning. // Every 10 seconds a space character is sent. // keepHTTPReqResponseAlive will wait for the returned body to be read before starting the ticker. // The returned function should always be called to release resources.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 45.7K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/msrpc/srvsvc.java
*/ public int hunds; /** * The time zone offset from UTC in minutes. */ public int timezone; /** * The time interval for each tick of the clock in 0.0001 seconds. */ public int tinterval; /** * The current day of the month (1-31). */ public int day; /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 27K bytes - Viewed (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;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 31.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
import static com.google.common.util.concurrent.Runnables.doNothing; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.SECONDS; import com.google.common.base.Predicate; import com.google.common.base.Predicates; import com.google.common.collect.ImmutableList; import com.google.common.collect.Iterables; import java.util.ArrayList;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 9.9K bytes - Viewed (0)