Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for Attempt (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top