Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 359 for retrying (0.04 sec)

  1. docs/distributed/DESIGN.md

    - Choosing an erasure set for the object is decided during `PutObject()`, object names are used to find the right erasure set using the following pseudo code.
    
    ```go
    // hashes the key returning an integer.
    func sipHashMod(key string, cardinality int, id [16]byte) int {
            if cardinality <= 0 {
                    return -1
            }
            sip := siphash.New(id[:])
            sip.Write([]byte(key))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Feb 26 09:25:50 UTC 2025
    - 8K bytes
    - Viewed (2)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

        }
      }
    }
    
    @Throws(IOException::class)
    internal fun BufferedSource.skipAll() {
      while (!exhausted()) {
        skip(buffer.size)
      }
    }
    
    /**
     * Attempts to exhaust this, returning true if successful. This is useful when reading a complete
     * source is helpful, such as when doing so completes a cache body or frees a socket connection for
     * reuse.
     */
    internal fun Source.discard(
      timeout: Int,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 10.2K bytes
    - Viewed (1)
  3. guava/src/com/google/common/collect/Multiset.java

     *
     * <p>In addition to these required methods, implementations of {@code Multiset} are expected to
     * provide two {@code static} creation methods: {@code create()}, returning an empty multiset, and
     * {@code create(Iterable<? extends E>)}, returning a multiset containing the given initial
     * elements. This is simply a refinement of {@code Collection}'s constructor recommendations.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/cache/Striped64.java

      /**
       * Handles cases of updates involving initialization, resizing, creating new Cells, and/or
       * contention. See above for explanation. This method suffers the usual non-modularity problems of
       * optimistic retry code, relying on rechecked sets of reads.
       *
       * @param x the value
       * @param hc the hash code holder
       * @param wasUncontended false if CAS failed before call
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jan 15 22:17:15 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  5. src/test/java/jcifs/pac/kerberos/KerberosApRequestTest.java

            ASN1Sequence seq = new DERSequence(v);
    
            // Act + Assert
            // Note: The actual error will be from ASN1Util.as() trying to cast to ASN1TaggedObject
            assertThrows(PACDecodingException.class, () -> new KerberosApRequest(seq, null));
        }
    
        @Test
        @DisplayName("seq ctor: tag 3 APPLICATION triggers ticket parsing")
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  6. cmd/streaming-signature-v4.go

    var errChunkTooBig = errors.New("chunk too big: choose chunk size <= 16MiB")
    
    // newSignV4ChunkedReader returns a new s3ChunkedReader that translates the data read from r
    // out of HTTP "chunked" format before returning it.
    // The s3ChunkedReader returns io.EOF when the final 0-length chunk is read.
    //
    // NewChunkedReader is not needed by normal applications. The http package
    // automatically decodes chunking when reading response bodies.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/Monitor.java

       * satisfied, it does *not* need to call this method before returning to wait. This can only
       * happen due to spurious wakeup (ignorable) or another thread acquiring the lock before the
       * current thread can and returning the guard to the unsatisfied state. In the latter case the
       * other thread (last thread modifying the state protected by the monitor) takes over the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  8. docs/en/docs/tutorial/path-params.md

    You can return *enum members* from your *path operation*, even nested in a JSON body (e.g. a `dict`).
    
    They will be converted to their corresponding values (strings in this case) before returning them to the client:
    
    {* ../../docs_src/path_params/tutorial005.py hl[18,21,23] *}
    
    In your client you will get a JSON response like:
    
    ```JSON
    {
      "model_name": "alexnet",
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 10:29:01 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/DirFileEntryEnumIteratorBaseTest.java

            assertEquals(wildcard, it.getWildcard());
            assertSame(parent, it.getParent());
            verify(tree, times(1)).acquire();
        }
    
        @Test
        @DisplayName("Constructor with open() returning null closes immediately and hasNext=false")
        void constructorOpenNullCloses() throws Exception {
            // Arrange
            stubAcquireReturnsSelf();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.5K bytes
    - Viewed (0)
  10. cmd/bootstrap-peer-server.go

    	if newObjectLayerFn() != nil {
    		return nil
    	}
    
    	recvCfg, err := serverVerifyHandler.Call(ctx, client.gridConn, grid.NewMSS())
    	if err != nil {
    		return err
    	}
    	// We do not need the response after returning.
    	defer serverVerifyHandler.PutResponse(recvCfg)
    
    	return srcCfg.Diff(recvCfg)
    }
    
    // Stringer provides a canonicalized representation of node.
    func (client *bootstrapRESTClient) String() string {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top