- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 336 for CANCEL (0.45 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/FailedPlan.kt
override val isReady = false override fun connectTcp() = result override fun connectTlsEtc() = result override fun handleSuccess() = error("unexpected call") override fun cancel() = error("unexpected cancel") override fun retry() = error("unexpected retry")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.5K bytes - Viewed (1) -
internal/config/dns/etcd_dns.go
key = key + etcdPathSeparator + ip ctx, cancel := context.WithTimeout(context.Background(), defaultContextTimeout) _, err = c.etcdClient.Put(ctx, key, string(bucketMsg)) cancel() if err != nil { ctx, cancel = context.WithTimeout(context.Background(), defaultContextTimeout) c.etcdClient.Delete(ctx, key) cancel() return err } } } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 8.3K bytes - Viewed (0) -
cmd/sts-handlers_test.go
runAllIAMSTSTests(testCase, &check{t, testCase.serverType}) }, ) } } func (s *TestSuiteIAM) TestSTSServiceAccountsWithUsername(c *check) { ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel() bucket := "dillon-bucket" err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{}) if err != nil { c.Fatalf("bucket create error: %v", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
this, IllegalStateException("Invalid content-type: ${body.contentType()}"), response, ) return } // This is a long-lived response. Cancel full-call timeouts. call?.timeout()?.cancel() // Replace the body with a stripped one so the callbacks can't see real data. val response = response.stripBody() val reader = ServerSentEventReader(body.source(), this)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
} private static void doTestSuccessfulAsList_resultCancelledRacingInputDone() throws Exception { // Simple (combined.cancel -> input.cancel -> setOneValue): successfulAsList(ImmutableList.of(SettableFuture.create())).cancel(true); /* * Complex (combined.cancel -> input.cancel -> other.set -> setOneValue), * to show that this isn't just about problems with the input future we just * cancelled:
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcConstants.java
public static final int DCERPC_FIRST_FRAG = 0x01; /* First fragment */ public static final int DCERPC_LAST_FRAG = 0x02; /* Last fragment */ public static final int DCERPC_PENDING_CANCEL = 0x04; /* Cancel was pending at sender */ public static final int DCERPC_RESERVED_1 = 0x08; public static final int DCERPC_CONC_MPX = 0x10; /* supports concurrent multiplexing */
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 20:39:42 GMT 2019 - 1.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
inputFuture.cancel(true); // argument is ignored assertThrows(CancellationException.class, () -> resultFuture.get()); } public void testFutureGetThrowsCancellationIfOutputCancelled() throws Exception { inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); outputFuture.cancel(true); // argument is ignored
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
this.lock = lock; this.currentFuture = currentFuture; } @Override public void cancel(boolean mayInterruptIfRunning) { /* * Lock to ensure that a task cannot be rescheduled while a cancel is ongoing. * * In theory, cancel() could execute arbitrary listeners -- bad to do while holding a lock.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0) -
cmd/iam-etcd-store.go
m[policy] = p return nil } func (ies *IAMEtcdStore) loadPolicyDocs(ctx context.Context, m map[string]PolicyDoc) error { ctx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() // Retrieve all keys and values to avoid too many calls to etcd in case of // a large number of policies r, err := ies.client.Get(ctx, iamConfigPoliciesPrefix, etcd.WithPrefix())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
} private fun cancelLater( call: Call, delayMillis: Int, ): CountDownLatch { val latch = CountDownLatch(1) Thread { sleep(delayMillis) if (cancelMode == CANCEL) { call.cancel() } else { threadToCancel!!.interrupt() } latch.countDown() }.apply { start() } return latch } companion object {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0)