Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 369 for Joiner (0.12 sec)

  1. CONTRIBUTING.md

      quality requirements. For example, we check if the CLA is signed, PR has
      sufficient description, if applicable unit tests are added, if it is a
      reasonable contribution (meaning it is not a single liner cosmetic PR).
    
    **2. Valid?**
    
    -   If the PR passes all the quality checks then we go ahead and assign a
        reviewer.
    -   If the PR didn't meet the validation criteria, we request for additional
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Sat Jan 11 04:47:59 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  2. cmd/storage-rest-server.go

    	if err := xjwt.ParseWithStandardClaims(token, claims, []byte(globalActiveCred.SecretKey)); err != nil {
    		return errAuthentication
    	}
    
    	owner := claims.AccessKey == globalActiveCred.AccessKey || claims.Subject == globalActiveCred.AccessKey
    	if !owner {
    		return errAuthentication
    	}
    
    	return nil
    }
    
    // Authenticates storage client's requests and validates for skewed time.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java

        assertEquals(Outer.Sub.class, subtype.getRawType());
        assertThat(subtype.getActualTypeArguments()[0]).isInstanceOf(WildcardType.class);
        ParameterizedType owner = (ParameterizedType) subtype.getOwnerType();
        assertEquals(Outer.class, owner.getRawType());
        // This returns a strange ? extends Sub2<Y> type, which isn't ideal.
        TypeToken<?> unused = new TypeToken<BaseWithTypeVar<List<?>>>() {}.getSubtype(Outer.Sub2.class);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Sep 02 17:23:59 UTC 2025
    - 89K bytes
    - Viewed (0)
  4. docs/en/docs/async.md

    But in this case, if you could bring the 8 ex-cashier/cooks/now-cleaners, and each one of them (plus you) could take a zone of the house to clean it, you could do all the work in **parallel**, with the extra help, and finish much sooner.
    
    In this scenario, each one of the cleaners (including you) would be a processor, doing their part of the job.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24K bytes
    - Viewed (0)
  5. cmd/bucket-lifecycle.go

    	return xxh3.HashString(e.objInfo.Bucket + e.objInfo.Name)
    }
    
    // expiryState manages all ILM related expiration activities.
    type expiryState struct {
    	mu      sync.RWMutex
    	workers atomic.Pointer[[]chan expiryOp]
    
    	ctx    context.Context
    	objAPI ObjectLayer
    
    	stats expiryStats
    }
    
    // PendingTasks returns the number of pending ILM expiry tasks.
    func (es *expiryState) PendingTasks() int {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/ClosingFuture.java

      public boolean cancel(boolean mayInterruptIfRunning) {
        logger.get().log(FINER, "cancelling {0}", this);
        boolean cancelled = future.cancel(mayInterruptIfRunning);
        if (cancelled) {
          close();
        }
        return cancelled;
      }
    
      private void close() {
        logger.get().log(FINER, "closing {0}", this);
        closeables.close();
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 98.1K bytes
    - Viewed (0)
  7. cmd/peer-rest-client.go

    		defer cancel()
    		respBody, err := healthClient.Call(ctx, peerRESTMethodHealth, nil, nil, -1)
    		xhttp.DrainBody(respBody)
    		return !isNetworkError(err)
    	}
    	var gridConn atomic.Pointer[grid.Connection]
    
    	return &peerRESTClient{
    		host: peer, restClient: restClient, gridHost: gridHost,
    		gridConn: func() *grid.Connection {
    			// Lazy initialization of grid connection.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  8. docs/fr/docs/async.md

    Pour une opération qui nécessite de l'attente avant de donner un résultat et qui supporte ces nouvelles fonctionnalités Python, vous pouvez l'utiliser comme tel :
    
    ```Python
    burgers = await get_burgers(2)
    ```
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  9. guava/src/com/google/common/hash/Hashing.java

        return new ConcatenatedHashFunction(hashFunctions);
      }
    
      /**
       * Used to randomize {@link #goodFastHash} instances, so that programs which persist anything
       * dependent on the hash codes they produce will fail sooner.
       */
      @SuppressWarnings("GoodTime") // reading system time without TimeSource
      static final int GOOD_FAST_HASH_SEED = (int) System.currentTimeMillis();
    
      /**
       * Returns a hash function implementing the <a
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 22:06:57 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/dcerpc/msrpc/lsarpc.java

        public static final int POLICY_INFO_MODIFICATION = 9;
        /** Policy information level for DNS domain information. */
        public static final int POLICY_INFO_DNS_DOMAIN = 12;
    
        /**
         * LSA SID pointer structure.
         */
        public static class LsarSidPtr extends NdrObject {
    
            /**
             * Default constructor for LsarSidPtr.
             */
            public LsarSidPtr() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 42.5K bytes
    - Viewed (0)
Back to top