Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 481 for Timers (0.04 sec)

  1. 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...
    
    /// tip
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top