Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for isCanceled (0.13 sec)

  1. okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt

        call.timeout().timeout(250, TimeUnit.MILLISECONDS)
        assertFailsWith<IOException> {
          call.execute()
        }.also { expected ->
          assertThat(expected.message).isEqualTo("timeout")
          assertThat(call.isCanceled()).isTrue()
        }
      }
    
      @Test
      fun timeoutWritingRequestWithEnqueue() {
        server.enqueue(MockResponse())
        val request =
          Request.Builder()
            .url(server.url("/"))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/DispatcherTest.kt

        assertThat(a1.isExecuted()).isTrue()
        assertThat(a1.isCanceled()).isFalse()
        assertThat(a2.isExecuted()).isTrue()
        assertThat(a2.isCanceled()).isTrue()
        assertThat(a3.isExecuted()).isFalse()
        assertThat(a3.isCanceled()).isTrue()
        assertThat(a4.isExecuted()).isFalse()
        assertThat(a4.isCanceled()).isFalse()
      }
    
      @Test
      fun idleCallbackInvokedWhenIdle() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Apr 05 03:30:42 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

      private var routeSelector: RouteSelector? = null
      private var nextRouteToTry: Route? = null
    
      override val deferredPlans = ArrayDeque<Plan>()
    
      override fun isCanceled(): Boolean = connectionUser.isCanceled()
    
      @Throws(IOException::class)
      override fun plan(): Plan {
        val reuseCallConnection = planReuseCallConnection()
        if (reuseCallConnection != null) return reuseCallConnection
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 12K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

        canceled = true
        exchange?.cancel()
        for (plan in plansToCancel) {
          plan.cancel()
        }
    
        eventListener.canceled(this)
      }
    
      override fun isCanceled(): Boolean = canceled
    
      override fun execute(): Response {
        check(executed.compareAndSet(false, true)) { "Already Executed" }
    
        timeout.enter()
        callStart()
        try {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractor.java

                throw new ExtractException(e);
            } finally {
                if (accessTimeout != null) {
                    accessTimeoutTarget.stop();
                    if (!accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
            return data;
        }
    
        public void setUrl(final String url) {
            this.url = url;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/InterceptorTest.kt

        val interceptor =
          Interceptor { chain: Interceptor.Chain ->
            val call = chain.call()
            callRef.set(call)
            assertThat(call.isCanceled()).isFalse()
            call.cancel()
            assertThat(call.isCanceled()).isTrue()
            chain.proceed(chain.request())
          }
        client =
          client.newBuilder()
            .addInterceptor(interceptor)
            .build()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java

                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (!accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
        protected ResponseData getResponseData(final String uri, final boolean includeContent) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt

        while (true) {
          call.enterNetworkInterceptorExchange(request, newRoutePlanner, chain)
    
          var response: Response
          var closeActiveExchange = true
          try {
            if (call.isCanceled()) {
              throw IOException("Canceled")
            }
    
            try {
              response = realChain.proceed(request)
              newRoutePlanner = true
            } catch (e: IOException) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:24:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

                logger.warn("Failed to generate thumbnails.", e);
                resultBuf.append(e.getMessage()).append("\n");
            } finally {
                if (timeoutTask != null && !timeoutTask.isCanceled()) {
                    timeoutTask.cancel();
                }
            }
    
            return resultBuf.toString();
    
        }
    
        protected void executeThumbnailGenerator() {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/job/SuggestJob.java

                logger.warn("Failed to create suggest data.", e);
                resultBuf.append(e.getMessage()).append("\n");
            } finally {
                if (timeoutTask != null && !timeoutTask.isCanceled()) {
                    timeoutTask.cancel();
                }
            }
    
            return resultBuf.toString();
    
        }
    
        protected void executeSuggestCreator() {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jun 23 04:13:47 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top