- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for attempt (0.21 sec)
-
okhttp/src/test/java/okhttp3/CallTest.kt
url = server.url("/"), body = object : RequestBody() { var attempt = 0 override fun contentType(): MediaType? { return null } override fun writeTo(sink: BufferedSink) { sink.writeUtf8("attempt " + attempt++) } }, ) val response = client.newCall(request).execute()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
cmd/server_test.go
response, err = s.client.Do(request) c.Assert(err, nil) // Assert the response status code. c.Assert(response.StatusCode, http.StatusNoContent) } // TestDeleteBucketNotEmpty - Validates the operation during an attempt to delete a non-empty bucket. func (s *TestSuiteCommon) TestDeleteBucketNotEmpty(c *check) { // generate a random bucket name. bucketName := getRandomBucketName() // HTTP request to create the bucket.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
cmd/object-handlers_test.go
// First register the HTTP handler for NewMultipartUpload, then a HTTP request for NewMultipart upload is made. // The UploadID from the response body is parsed and its existence is asserted with an attempt to ListParts using it. func TestAPINewMultipartHandler(t *testing.T) { defer DetectTestLeak(t)() ExecObjectLayerAPITest(t, testAPINewMultipartHandler, []string{"NewMultipart"}) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
cmd/bucket-replication.go
var uploadID string attempts := 1 for attempts <= 3 { nctx, cancel := context.WithTimeout(ctx, time.Minute) uploadID, err = c.NewMultipartUpload(nctx, bucket, object, opts) cancel() if err == nil { break } if minio.ToErrorResponse(err).Code == "PreconditionFailed" { return err } attempts++ time.Sleep(time.Duration(rand.Int63n(int64(time.Second))))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/site-replication.go
if err != nil { if errors.Is(err, errConfigNotFound) { c.Lock() defer c.Unlock() c.state = srState{} c.enabled = false } return err } // attempt to read just the version key in the state file to ensure we // are reading a compatible version. var ver struct { Version int `json:"version"` } err = json.Unmarshal(buf, &ver) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
ValueAndCloserConsumer<C> consumer, ClosingFuture<V> closingFuture) { consumer.accept(new ValueAndCloser<C>(closingFuture)); } /** * Attempts to cancel execution of this step. This attempt will fail if the step has already * completed, has already been cancelled, or could not be cancelled for some other reason. If
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 98.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
server.enqueue(MockResponse(body = "this response comes via SSL")) client = client.newBuilder() .hostnameVerifier( RecordingHostnameVerifier(), ) // Attempt RESTRICTED_TLS then fall back to MODERN_TLS. .connectionSpecs(Arrays.asList(ConnectionSpec.RESTRICTED_TLS, ConnectionSpec.MODERN_TLS)) .sslSocketFactory( suppressTlsFallbackClientSocketFactory(),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
* performed in the order they were provided to the constructor. Verify * that as a sanity check: */ assertFalse(future2.isCancelled()); // Now attempt to trigger the exception: future2.set(DATA2); } }, directExecutor()); assertTrue(compound.cancel(false)); assertTrue(compound.isCancelled());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LocalCache.java
} /** * Gets the value from an entry. Returns null if the entry is invalid, partially-collected, * loading, or expired. Unlike {@link Segment#getLiveValue} this method does not attempt to clean * up stale entries. As such it should only be called outside a segment context, such as during * iteration. */ @CheckForNull V getLiveValue(ReferenceEntry<K, V> entry, long now) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 144.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
* performed in the order they were provided to the constructor. Verify * that as a sanity check: */ assertFalse(future2.isCancelled()); // Now attempt to trigger the exception: future2.set(DATA2); } }, directExecutor()); assertTrue(compound.cancel(false)); assertTrue(compound.isCancelled());
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)