- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 79 for isCancelled (1.31 sec)
-
src/main/java/org/codelibs/fess/job/PythonJob.java
logger.warn("Failed to run python command.", e); resultBuf.append(e.getMessage()).append("\n"); } finally { if (timeoutTask != null && !timeoutTask.isCanceled()) { timeoutTask.cancel(); } } return resultBuf.toString(); } protected void executePython() {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectionUser.kt
fun connectionConnectionClosed(connection: RealConnection) fun noNewExchanges(connection: RealConnection) fun doExtensiveHealthChecks(): Boolean fun isCanceled(): Boolean fun candidateConnection(): RealConnection? fun proxySelectStart(url: HttpUrl) fun proxySelectEnd( url: HttpUrl, proxies: List<Proxy>, )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 2.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
override fun find(): RealConnection { var firstException: IOException? = null try { while (tcpConnectsInFlight.isNotEmpty() || routePlanner.hasNext()) { if (routePlanner.isCanceled()) throw IOException("Canceled") // Launch a new connection if we're ready to. val now = taskRunner.backend.nanoTime() var awaitTimeoutNanos = nextTcpConnectAtNanos - now
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Call.kt
fun cancel() /** * Returns true if this call has been either [executed][execute] or [enqueued][enqueue]. It is an * error to execute a call more than once. */ fun isExecuted(): Boolean fun isCanceled(): Boolean /** * Returns a timeout that spans the entire call: resolving DNS, connecting, writing the request * body, server processing, and reading the response body. If the call requires redirects or
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 3.6K bytes - Viewed (0) -
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()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 27.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* thread executing the call. */ interface RoutePlanner { val address: Address /** Follow-ups for failed plans and plans that lost a race. */ val deferredPlans: ArrayDeque<Plan> fun isCanceled(): Boolean /** Returns a plan to attempt. */ @Throws(IOException::class) fun plan(): Plan /** * Returns true if there's more route plans to try. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
override val address = factory.newAddress("example.com") fun addPlan(): FakePlan { return FakePlan(nextPlanId++).also { plans += it } } override fun isCanceled() = canceled override fun plan(): FakePlan { // Return deferred plans preferentially. These don't require addPlan(). if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst() as FakePlan
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
} for (SLinkedList<TimeoutTask>.Entry e = timeoutTaskList.getFirstEntry(); e != null; e = e.getNext()) { final TimeoutTask task = e.getElement(); if (task.isCanceled()) { e.remove(); } else if (!task.isStopped() && task.isExpired()) { expiredTask.add(task); if (!task.isPermanent()) { e.remove();
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K bytes - Viewed (0) -
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() {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.9K bytes - Viewed (0) -
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() {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 10.5K bytes - Viewed (0)