Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 1,333 for CASE (0.06 sec)

  1. internal/once/singleton.go

    // GetNonBlocking will return the singleton value or nil if not set yet.
    func (s *Singleton[T]) GetNonBlocking() *T {
    	select {
    	case <-s.set:
    		return s.v
    	default:
    		return nil
    	}
    }
    
    // IsSet will return whether the singleton has been set.
    func (s *Singleton[T]) IsSet() bool {
    	select {
    	case <-s.set:
    		return true
    	default:
    		return false
    	}
    }
    
    // Set the value and unblock all Get requests.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 952 bytes
    - Viewed (0)
  2. cmd/admin-heal-ops.go

    			// unconsumedTimer fires.
    			select {
    			// Check after a second
    			case <-time.After(time.Second):
    				h.mutex.Unlock()
    				continue
    
    			case <-h.ctx.Done():
    				h.mutex.Unlock()
    				// discard result and return.
    				return errHealStopSignalled
    
    			// Timeout if no results consumed for too long.
    			case <-unconsumedTimer.C:
    				h.mutex.Unlock()
    				return errHealIdleTimeout
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/NullnessCasts.java

       * analysis that that means "plain {@code T}" rather than the inferred type {@code @Nullable T}.
       * (Even if supported added {@code @NonNull}, that would not help, since the problem case
       * addressed by this method is the case in which {@code T} has parametric nullness -- and thus its
       * value may be legitimately {@code null}.)
       */
      @SuppressWarnings("nullness")
      @ParametricNullness
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 10 20:36:34 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  4. internal/bucket/versioning/versioning.go

    	// Not supported yet
    	// switch v.MFADelete {
    	// case Enabled, Disabled:
    	// default:
    	// 	return Errorf("unsupported MFADelete state %s", v.MFADelete)
    	// }
    	switch v.Status {
    	case Enabled:
    		const maxExcludedPrefixes = 10
    		if len(v.ExcludedPrefixes) > maxExcludedPrefixes {
    			return errTooManyExcludedPrefixes
    		}
    
    	case Suspended:
    		if len(v.ExcludedPrefixes) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. cmd/sts-handlers.go

    		switch err {
    		case openid.ErrTokenExpired:
    			switch action {
    			case clientGrants:
    				writeSTSErrorResponse(ctx, w, ErrSTSClientGrantsExpiredToken, err)
    			case webIdentity:
    				writeSTSErrorResponse(ctx, w, ErrSTSWebIdentityExpiredToken, err)
    			}
    			return
    		case auth.ErrInvalidDuration:
    			writeSTSErrorResponse(ctx, w, ErrSTSInvalidParameterValue, err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  6. src/main/java/jcifs/pac/kerberos/KerberosAuthData.java

            List<KerberosAuthData> authorizations = new ArrayList<>();
    
            switch ( authType ) {
            case KerberosConstants.AUTH_DATA_RELEVANT:
                authorizations = new KerberosRelevantAuthData(token, keys).getAuthorizations();
                break;
            case KerberosConstants.AUTH_DATA_PAC:
                authorizations.add(new KerberosPacAuthData(token, keys));
                break;
            default:
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 1.6K bytes
    - Viewed (0)
  7. docs/en/docs/tutorial/dependencies/global-dependencies.md

    Similar to the way you can [add `dependencies` to the *path operation decorators*](dependencies-in-path-operation-decorators.md){.internal-link target=_blank}, you can add them to the `FastAPI` application.
    
    In that case, they will be applied to all the *path operations* in the application:
    
    //// tab | Python 3.9+
    
    ```Python hl_lines="16"
    {!> ../../docs_src/dependencies/tutorial012_an_py39.py!}
    ```
    
    ////
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/smb1/Trans2QueryFSInformationResponse.java

            switch( informationLevel ) {
                case SMB_INFO_ALLOCATION:
                    return readSmbInfoAllocationWireFormat( buffer, bufferIndex );
                case SMB_QUERY_FS_SIZE_INFO:
                    return readSmbQueryFSSizeInfoWireFormat( buffer, bufferIndex );
                case SMB_FS_FULL_SIZE_INFORMATION:
                    return readFsFullSizeInformationWireFormat( buffer, bufferIndex );
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 5.1K bytes
    - Viewed (0)
  9. cmd/veeam-sos-api.go

    	var buf []byte
    	switch object {
    	case systemXMLObject:
    		si := systemInfo{
    			ProtocolVersion: `"1.0"`,
    			ModelName:       "\"MinIO " + ReleaseTag + "\"",
    		}
    		si.ProtocolCapabilities.CapacityInfo = true
    
    		// Default recommended block size with MinIO
    		si.SystemRecommendations.KBBlockSize = 4096
    
    		buf = encodeResponse(&si)
    	case capacityXMLObject:
    		objAPI := newObjectLayerFn()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  10. internal/event/target/webhook.go

    	// already present we can blindly use the
    	// authToken as is instead of adding 'Bearer'
    	tokens := strings.Fields(target.args.AuthToken)
    	switch len(tokens) {
    	case 2:
    		req.Header.Set("Authorization", target.args.AuthToken)
    	case 1:
    		req.Header.Set("Authorization", "Bearer "+target.args.AuthToken)
    	}
    
    	req.Header.Set("Content-Type", "application/json")
    
    	resp, err := target.httpClient.Do(req)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
Back to top