Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 17 for isSet (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/once/singleton.go

    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.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 15 12:04:40 GMT 2024
    - 952 bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Settings.kt

        }
    
        val bit = 1 shl id
        set = set or bit
        values[id] = value
        return this
      }
    
      /** Returns true if a value has been assigned for the setting `id`. */
      fun isSet(id: Int): Boolean {
        val bit = 1 shl id
        return set and bit != 0
      }
    
      /** Returns the value for the setting `id`, or 0 if unset. */
      operator fun get(id: Int): Int = values[id]
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 3.8K bytes
    - Click Count (0)
  3. internal/hash/checksum.go

    		return sha1.Size
    	case c.Is(ChecksumSHA256):
    		return sha256.Size
    	case c.Is(ChecksumCRC64NVME):
    		return crc64.Size
    	}
    	return 0
    }
    
    // IsSet returns whether the type is valid and known.
    func (c ChecksumType) IsSet() bool {
    	return !c.Is(ChecksumInvalid) && !c.Base().Is(ChecksumNone)
    }
    
    // ChecksumStringToType is like NewChecksumType but without the `mode`
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 22 14:15:21 GMT 2025
    - 18.3K bytes
    - Click Count (0)
  4. cmd/common-main.go

    	//nolint:gocritic
    	if !env.IsSet(config.EnvRootUser) && env.IsSet(config.EnvRootPassword) {
    		logger.Fatal(config.ErrMissingEnvCredentialRootUser(nil), "Unable to start MinIO")
    	} else if env.IsSet(config.EnvRootUser) && !env.IsSet(config.EnvRootPassword) {
    		logger.Fatal(config.ErrMissingEnvCredentialRootPassword(nil), "Unable to start MinIO")
    	} else if !env.IsSet(config.EnvRootUser) && !env.IsSet(config.EnvRootPassword) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.5K bytes
    - Click Count (3)
  5. internal/hash/reader.go

    	}
    	return map[string]string{r.contentHash.Type.String(): r.contentHash.Encoded}
    }
    
    // Checksum returns the content checksum if set.
    func (r *Reader) Checksum() *Checksum {
    	if !r.contentHash.Type.IsSet() || !r.contentHash.Valid() {
    		return nil
    	}
    	return &r.contentHash
    }
    
    var _ io.Closer = (*Reader)(nil) // compiler check
    
    // Close and release resources.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  6. cmd/update.go

    		}
    	}
    	if osIsNotExist(err) {
    		// if none of the files are present we may be running inside
    		// CRI-O, Containerd etc..
    		// Fallback to our container specific ENVs if they are set.
    		return env.IsSet("MINIO_ACCESS_KEY_FILE")
    	}
    
    	// Log error, as we will not propagate it to caller
    	internalLogIf(GlobalContext, err)
    
    	return err == nil
    }
    
    // IsDCOS returns true if minio is running in DCOS.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  7. cmd/site-replication.go

    		if peer.DeploymentID == v.DeploymentID {
    			found = true
    			if (!peer.SyncState.Empty() || peer.DefaultBandwidth.IsSet) && peer.Endpoint == "" { // peer.Endpoint may be "" if only sync state/bandwidth is being updated
    				break
    			}
    			if peer.Endpoint == v.Endpoint && peer.SyncState.Empty() && !peer.DefaultBandwidth.IsSet {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  8. cmd/utils.go

    		}
    		r.Body = hash.NewChecker(r.Body, md5.New(), want, r.ContentLength)
    		return true
    	}
    	cs, err := hash.GetContentChecksum(r.Header)
    	if err != nil {
    		return false
    	}
    	if cs == nil || !cs.Type.IsSet() {
    		return false
    	}
    	if cs.Valid() && !cs.Type.Trailing() {
    		r.Body = hash.NewChecker(r.Body, cs.Type.Hasher(), cs.Raw, r.ContentLength)
    	}
    	return true
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  9. cmd/server-main.go

    	if lgDir == "" {
    		return os.Stderr, nil
    	}
    	lgDirAbs, err := filepath.Abs(lgDir)
    	if err != nil {
    		return nil, err
    	}
    	lgSize := ctx.Int("log-size")
    
    	var fileNameFunc func() string
    	if ctx.IsSet("log-prefix") {
    		fileNameFunc = func() string {
    			return fmt.Sprintf("%s-%s.log", ctx.String("log-prefix"), fmt.Sprintf("%X", time.Now().UTC().UnixNano()))
    		}
    	}
    
    	output, err := logger.NewDir(logger.Options{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  10. cmd/object-multipart-handlers.go

    		}
    	}
    
    	checksumType := hash.NewChecksumHeader(r.Header)
    	if checksumType.Is(hash.ChecksumInvalid) {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidChecksum), r.URL)
    		return
    	} else if checksumType.IsSet() && !checksumType.Is(hash.ChecksumTrailing) {
    		opts.WantChecksum = &hash.Checksum{Type: checksumType}
    	}
    
    	if opts.WantChecksum != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 07 16:13:09 GMT 2025
    - 39.5K bytes
    - Click Count (1)
Back to Top