Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 334 for canceler (0.04 sec)

  1. cmd/server-main.go

    			if errors.As(err, &cerr) {
    				logger.FatalIf(err, "Unable to initialize the server")
    			}
    
    			// If context was canceled
    			if errors.Is(err, context.Canceled) {
    				logger.FatalIf(err, "Server startup canceled upon user request")
    			}
    
    			bootLogIf(GlobalContext, err)
    		}
    
    		if !globalServerCtxt.StrictS3Compat {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  2. src/test/java/jcifs/SmbWatchHandleTest.java

                // Verify timeout occurs
                assertThrows(TimeoutException.class, () -> {
                    future.get(100, TimeUnit.MILLISECONDS);
                });
    
                // Cancel the future
                future.cancel(true);
            } finally {
                executor.shutdownNow();
            }
        }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 13.2K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/processor/impl/DefaultResponseProcessor.java

                } else if (crawlerContext.getMaxDepth() < 0 || urlQueue.getDepth() <= crawlerContext.getMaxDepth()) {
                    if (logger.isDebugEnabled()) {
                        logger.debug("Canceled urlQueue: {}", urlQueue);
                    }
                    // cancel crawling
                    crawlerContext.decrementAndGetAccessCount();
                    final List<UrlQueue<?>> newUrlQueueList = new ArrayList<>();
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  4. .github/workflows/contributor-pr.yml

      pull_request:
        branches:
          - master
    
    concurrency:
      # On master/release, we don't want any jobs cancelled so the sha is used to name the group
      group: ${{ (github.ref == 'refs/heads/master' || github.ref == 'refs/heads/release' ) && format('contributor-pr-base-{0}', github.sha) || format('contributor-pr-{0}', github.ref) }}
      cancel-in-progress: false
    
    env:
      # Set the DEVELOCITY_ACCESS_KEY so that a Build Scan is generated
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Thu Sep 04 22:13:34 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

       * inbound data and send an early 400 before the request body completes.
       *
       * This test sends a slow request that is canceled by the server. It expects the response to still
       * be readable after the request stream is canceled.
       */
      @Disabled
      @Test
      fun serverCancelsRequestBodyAndSendsResponseBody() {
        client =
          client
            .newBuilder()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 24.8K bytes
    - Viewed (0)
  6. docs/recipes.md

            val startNanos = System.nanoTime()
            val call = client.newCall(request)
    
            // Schedule a job to cancel the call in 1 second.
            executor.schedule({
              System.out.printf("%.2f Canceling call.%n", (System.nanoTime() - startNanos) / 1e9f)
              call.cancel()
              System.out.printf("%.2f Canceled call.%n", (System.nanoTime() - startNanos) / 1e9f)
            }, 1, TimeUnit.SECONDS)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 47.8K bytes
    - Viewed (0)
  7. docs/changelogs/changelog_2x.md

        requests couldn't be canceled by tag. This update avoids crashing when
        `onResponse()` throws an `IOException`. That failure will now be logged
        instead of notifying the thread's uncaught exception handler. We've added a
        new API, `Call.isCanceled()` to check if a call has been canceled.
    
     *  New: Update `MultipartBuilder` to support content length.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 26.6K bytes
    - Viewed (0)
  8. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt

              |
              """.trimMargin(),
            ).setHeader("content-type", "text/event-stream")
            .build(),
        )
        listener.enqueueCancel() // Will cancel in onOpen().
        newEventSource()
        listener.assertOpen()
        listener.assertFailure("canceled")
      }
    
      @Test
      fun badContentType() {
        server.enqueue(
          MockResponse
            .Builder()
            .body(
              """
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:47:47 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

        inFinished: Boolean,
      ) {
        pushQueue.execute("$connectionName[$streamId] onHeaders") {
          val cancel = pushObserver.onHeaders(streamId, requestHeaders, inFinished)
          ignoreIoExceptions {
            if (cancel) writer.rstStream(streamId, ErrorCode.CANCEL)
            if (cancel || inFinished) {
              withLock {
                currentPushRequests.remove(streamId)
              }
            }
          }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  10. docs/features/connections.md

     * Prefer to alternate IP addresses from different address families, (IPv6 / IPv4), starting with IPv6.
     * Don't start a new attempt until 250 ms after the most recent attempt was started.
     * Keep whichever TCP connection succeeds first and cancel all the others.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
Back to top