Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 236 for Retry (0.03 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

       * Returns true if there's more route plans to try.
       *
       * @param failedConnection an optional connection that was resulted in a failure. If the failure
       *     is recoverable, the connection's route may be recovered for the retry.
       */
      fun hasNext(failedConnection: RealConnection? = null): Boolean
    
      /**
       * Returns true if the host and port are unchanged from when this was created. This is used to
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue May 27 14:58:02 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FailedPlan.kt

      override fun connectTlsEtc() = result
    
      override fun handleSuccess() = error("unexpected call")
    
      override fun cancel() = error("unexpected cancel")
    
      override fun retry() = error("unexpected retry")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  3. src/main/java/jcifs/smb/SmbTreeConnection.java

                }
    
                try (SmbTreeHandle th = connectWrapException(loc)) {
                    log.debug("Have new tree connection for retry");
                } catch (final SmbException e) {
                    log.debug("Failed to connect tree on retry", e);
                    last = e;
                }
            }
    
            if (last != null) {
                log.debug("All attempts have failed, last exception", last);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 30.4K bytes
    - Click Count (1)
  4. src/test/java/jcifs/internal/smb2/multichannel/ChannelFailoverTest.java

            // Should allow retries up to limit
            assertTrue(state.shouldRetry());
    
            state.incrementRetry(); // Retry 1
            assertTrue(state.shouldRetry());
    
            state.incrementRetry(); // Retry 2
            assertTrue(state.shouldRetry());
    
            state.incrementRetry(); // Retry 3
            assertFalse(state.shouldRetry()); // Max retries reached
        }
    
        @Test
        void testFailoverStateBackoff() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  5. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

        }
    
        /**
         * Sets the retry interval in milliseconds.
         *
         * @param retryInterval The retry interval.
         */
        public void setRetryInterval(final long retryInterval) {
            this.retryInterval = retryInterval;
        }
    
        /**
         * Sets the maximum retry count.
         *
         * @param maxRetryCount The maximum retry count.
         */
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sun Nov 23 02:01:26 GMT 2025
    - 26.2K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

     *    we must send a `CONNECT` request, and handle authorization challenges from the proxy.
     *  * Optional [TLS handshake][connectTls].
     *
     * Each step may fail. If a retry is possible, a new instance is created with the next plan, which
     * will be configured differently.
     */
    class ConnectPlan internal constructor(
      private val taskRunner: TaskRunner,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 19.3K bytes
    - Click Count (2)
  7. okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

       * already had a healthy connection. It sets up a deferred connection by stalling the IPv6
       * connect, and it sets up a same-connection retry with [ErrorCode.REFUSED_STREAM].
       *
       * https://github.com/square/okhttp/pull/7190
       */
      @Test
      fun preferCallConnectionOverDeferredConnection() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 10.6K bytes
    - Click Count (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/EventListenerAdapter.kt

        cachedResponse: Response,
      ) = onEvent(CacheConditionalHit(System.nanoTime(), call))
    
      override fun retryDecision(
        call: Call,
        exception: IOException,
        retry: Boolean,
      ) = onEvent(RetryDecision(System.nanoTime(), call, exception, retry))
    
      override fun followUpDecision(
        call: Call,
        networkResponse: Response,
        nextRequest: Request?,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb/SmbCopyUtil.java

                                final Smb2IoctlResponse response = copy.getResponse();
                                if (!retry && response.isReceived() && !response.isError()
                                        && response.getStatus() == NtStatus.NT_STATUS_INVALID_PARAMETER) {
                                    retry = true;
                                    final SrvCopyChunkCopyResponse outputData = response.getOutputData(SrvCopyChunkCopyResponse.class);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 16.6K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

        return result
      }
    
      private fun cancelInFlightConnects() {
        for (plan in tcpConnectsInFlight) {
          plan.cancel()
          val retry = plan.retry() ?: continue
          routePlanner.deferredPlans.addLast(retry)
        }
        tcpConnectsInFlight.clear()
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.8K bytes
    - Click Count (0)
Back to Top