- Sort Score
- Result 10 results
- Languages All
Results 271 - 280 of 481 for Timers (0.04 sec)
-
docs/en/docs/deployment/concepts.md
### Restart After Crash { #restart-after-crash } But in those cases with really bad errors that crash the running **process**, you would want an external component that is in charge of **restarting** the process, at least a couple of times... /// tipRegistered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 18.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt
val elapsedUntilPong3 = System.nanoTime() - startNanos assertThat(TimeUnit.NANOSECONDS.toMillis(elapsedUntilPong3).toDouble()) .isCloseTo(1500.0, 250.0) // The client pinged the server 3 times, and it has ponged back 3 times. assertThat(webSocket.sentPingCount()).isEqualTo(3) assertThat(server.receivedPingCount()).isEqualTo(3) assertThat(webSocket.receivedPongCount()).isEqualTo(3)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 35.5K bytes - Viewed (0) -
src/test/java/jcifs/SmbResourceTest.java
long lastAccess = currentTime; // When/Then assertDoesNotThrow(() -> mockResource.setFileTimes(createTime, lastModified, lastAccess), "Setting file times should not throw exception"); verify(mockResource).setFileTimes(createTime, lastModified, lastAccess); } @Test @DisplayName("individual time setters should work correctly")Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 35K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java
import java.util.concurrent.atomic.AtomicInteger; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /** * Tests relating to cache expiration: make sure entries expire at the right times, make sure * expired entries don't show up, etc. * * @author mike nonemacher */ @SuppressWarnings("deprecation") // tests of deprecated method @NullUnmarked public class CacheExpirationTest extends TestCase {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 18.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java
import org.codelibs.core.io.CopyUtil; import org.codelibs.core.io.FileUtil; import org.codelibs.core.io.InputStreamUtil; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.crawler.Constants; import org.codelibs.fess.crawler.builder.RequestDataBuilder; import org.codelibs.fess.crawler.client.AbstractCrawlerClient;
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 17.9K bytes - Viewed (2) -
android/guava/src/com/google/common/graph/ImmutableValueGraph.java
* .putEdgeValue(BERLIN, BRUSSELS, kilometers(764)) * .addNode(REYKJAVIK) * .build(); * } * * <p>Builder instances can be reused; it is safe to call {@link #build} multiple times to build * multiple graphs in series. Each new graph contains all the elements of the ones created before * it. * * @since 28.0 */ public static class Builder<N, V> {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 7.9K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/FileUtil.java
import java.nio.charset.Charset; import java.nio.file.Files; import org.codelibs.core.exception.IORuntimeException; import org.codelibs.core.net.URLUtil; import org.codelibs.core.nio.ChannelUtil; import org.codelibs.core.timer.TimeoutManager; /** * Utility class for handling {@link File}. * * @author higa */ public abstract class FileUtil { /** * Do not instantiate. */ protected FileUtil() {Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 8.8K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/info/Smb2SetInfoResponseTest.java
byte[] buffer = new byte[1024]; int bufferIndex = 0; // Set structure size to 2 SMBUtil.writeInt2(2, buffer, bufferIndex); // Call readBytesWireFormat multiple times for (int i = 0; i < 5; i++) { int result = response.readBytesWireFormat(buffer, bufferIndex); assertEquals(2, result, "Should consistently return 2 on call " + (i + 1)); } }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 10.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
if (errorCount > maxErrorCount) { throw e; } errorCount++; logger.warn("Failed to access data. Retry to access it {} times.", errorCount, e); } finally { if (systemHelper.isForceStop()) { finishCrawling = true; if (logger.isDebugEnabled()) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 32.7K bytes - Viewed (0) -
cmd/erasure-multipart.go
if err == nil { modTime = time.Unix(0, t) } } } // Fallback for older uploads without time in the ID. if modTime.IsZero() { wait := deleteMultipartCleanupSleeper.Timer(ctx) fi, err := disk.ReadVersion(ctx, "", minioMetaMultipartBucket, uploadIDPath, "", ReadOptions{}) if err != nil { return nil } modTime = fi.ModTime wait() }Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 47.3K bytes - Viewed (0)