Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 435 for cancel (0.07 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java

            } finally {
                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (!accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
        protected String[] parsePath(final String path) {
            if (StringUtil.isNotEmpty(path)) {
                final String[] values = path.split("/", 2);
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  2. docs/changelogs/changelog_4x.md

    
    ## Version 4.2.2
    
    _2019-10-06_
    
     *  Fix: When closing a canceled HTTP/2 stream, don't send the `END_STREAM` flag. This could cause
        the server to incorrectly interpret the stream as having completed normally. This is most useful
        when a request body needs to cancel its own call.
    
    
    ## Version 4.2.1
    
    _2019-10-02_
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/collect/QueuesTest.java

          assertThat(timer.elapsed(MILLISECONDS)).isAtLeast(10L);
    
          // If even the first one wasn't there, clean up so that the next test doesn't see an element.
          producerThread.cancel(true);
          producer.doneProducing.await();
          if (drained == 0) {
            q.poll(); // not necessarily there if producer was interrupted
          }
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  4. CHANGELOG.md

     *  Fix: Attempt to read the response body even if the server canceled the request. This will cause
        some calls to return nice error codes like `HTTP/1.1 429 Too Many Requests` instead of transport
        errors like `SocketException: Connection reset` and `StreamResetException: stream was reset:
        CANCEL`.
     *  New: Support OSGi metadata.
     *  Upgrade: [Okio 2.9.0][okio_2_9_0].
    
        ```kotlin
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:31:39 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  5. docs/changelogs/changelog_3x.md

     *  **Canceling batches of calls is now the application's responsibility.**
        The API to cancel calls by tag has been removed and replaced with a more
        general mechanism. The dispatcher now exposes all in-flight calls via its
        `runningCalls()` and `queuedCalls()` methods. You can write code that
        selects calls by tag, host, or whatever, and invokes `Call.cancel()` on the
        ones that are no longer necessary.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/job/CrawlJob.java

                throw new JobProcessingException("Failed to execute a crawl job.", e);
            } finally {
                if (timeoutTask != null && !timeoutTask.isCanceled()) {
                    timeoutTask.cancel();
                }
            }
    
            return resultBuf.toString();
    
        }
    
        protected int getRunningJobCount() {
            final AtomicInteger counter = new AtomicInteger(0);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jun 23 04:13:47 UTC 2024
    - 15.1K 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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 26.6K bytes
    - Viewed (0)
  8. cmd/admin-handlers-pools.go

    	if objectAPI == nil {
    		return
    	}
    
    	pools, ok := objectAPI.(*erasureServerPools)
    	if !ok {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    		return
    	}
    
    	// Cancel any ongoing rebalance operation
    	globalNotificationSys.StopRebalance(r.Context())
    	writeSuccessResponseHeadersOnly(w)
    	adminLogIf(ctx, pools.saveRebalanceStats(GlobalContext, 0, rebalSaveStoppedAt))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 00:22:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java

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

       * canceled. For example, happy-path events like [requestHeadersStart] and [requestHeadersEnd] may
       * occur after a call is canceled. Typically cancellation takes effect when an expensive I/O
       * operation is required.
       *
       * This is invoked at most once, even if [Call.cancel] is invoked multiple times. It may be
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 15.2K bytes
    - Viewed (0)
Back to top