- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Attempt (0.04 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
Request( url = server.url("/"), body = object : RequestBody() { var attempt = 0 override fun contentType(): MediaType? = null override fun writeTo(sink: BufferedSink) { sink.writeUtf8("attempt " + attempt++) } }, ) val response = client.newCall(request).execute()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 146.6K 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.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118.1K 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)()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 163.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbFile.java
* the security descriptor associated with this file or directory. * If no DACL is present, null is returned. If the DACL is empty, an array with 0 elements is returned. * @param resolveSids Attempt to resolve the SIDs within each ACE from * their numeric representation to their corresponding account names. * @return an array of ACE entries for this file * @throws IOException if an I/O error occurs
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 112.2K 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 nil } attempts++ time.Sleep(time.Duration(rand.Int63n(int64(time.Second))))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
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
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 97.8K bytes - Viewed (0) -
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 {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 184.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/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(),
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 133.2K bytes - Viewed (0) -
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
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 98.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
reason to be afraid of it. Presently the Rabbit came up to the door, and tried to open it; but, as the door opened inwards, and Alice's elbow was pressed hard against it, that attempt proved a failure. Alice heard it say to itself `Then I'll go round and get in at the window.' `THAT you won't' thought Alice, and, after waiting till she fancied she heard the Rabbit just under the window, she suddenly
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Apr 21 02:27:51 UTC 2017 - 145.2K bytes - Viewed (0)