Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for IsSet (0.03 sec)

  1. 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) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  2. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 952 bytes
    - Viewed (0)
  3. cmd/api-headers.go

    			continue
    		}
    
    		var isSet bool
    		for _, userMetadataPrefix := range userMetadataKeyPrefixes {
    			if !stringsHasPrefixFold(k, userMetadataPrefix) {
    				continue
    			}
    			w.Header()[strings.ToLower(k)] = []string{v}
    			isSet = true
    			break
    		}
    
    		if !isSet {
    			w.Header().Set(k, v)
    		}
    	}
    
    	var start, rangeLen int64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 04:44:00 UTC 2024
    - 7K bytes
    - Viewed (0)
  4. okhttp/src/main/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]
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. internal/hash/checksum.go

    	case c.Is(ChecksumCRC32C):
    		return 4
    	case c.Is(ChecksumSHA1):
    		return sha1.Size
    	case c.Is(ChecksumSHA256):
    		return sha256.Size
    	}
    	return 0
    }
    
    // IsSet returns whether the type is valid and known.
    func (c ChecksumType) IsSet() bool {
    	return !c.Is(ChecksumInvalid) && !c.Is(ChecksumNone)
    }
    
    // NewChecksumType returns a checksum type based on the algorithm string.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  6. cmd/admin-bucket-handlers.go

    	}
    	switch fname {
    	case bucketPolicyConfig:
    		st.Policy = madmin.MetaStatus{IsSet: true, Err: errMsg}
    	case bucketNotificationConfig:
    		st.Notification = madmin.MetaStatus{IsSet: true, Err: errMsg}
    	case bucketLifecycleConfig:
    		st.Lifecycle = madmin.MetaStatus{IsSet: true, Err: errMsg}
    	case bucketSSEConfig:
    		st.SSEConfig = madmin.MetaStatus{IsSet: true, Err: errMsg}
    	case bucketTaggingConfig:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/http2/SettingsTest.kt

    import assertk.assertions.isFalse
    import assertk.assertions.isTrue
    import org.junit.jupiter.api.Test
    
    class SettingsTest {
      @Test
      fun unsetField() {
        val settings = Settings()
        assertThat(settings.isSet(Settings.MAX_CONCURRENT_STREAMS)).isFalse()
        assertThat(settings.getMaxConcurrentStreams()).isEqualTo(Int.MAX_VALUE)
      }
    
      @Test
      fun setFields() {
        val settings = Settings()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  8. cmd/erasure-multipart.go

    	if userDefined[xhttp.AmzStorageClass] == storageclass.STANDARD {
    		delete(userDefined, xhttp.AmzStorageClass)
    	}
    
    	if opts.WantChecksum != nil && opts.WantChecksum.Type.IsSet() {
    		userDefined[hash.MinIOMultipartChecksum] = opts.WantChecksum.Type.String()
    	}
    
    	modTime := opts.MTime
    	if opts.MTime.IsZero() {
    		modTime = UTCNow()
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

          frameHeader(
            streamId = 0,
            length = settings.size() * 6,
            type = TYPE_SETTINGS,
            flags = FLAG_NONE,
          )
          for (i in 0 until Settings.COUNT) {
            if (!settings.isSet(i)) continue
            val id =
              when (i) {
                4 -> 3 // SETTINGS_MAX_CONCURRENT_STREAMS renumbered.
                7 -> 4 // SETTINGS_INITIAL_WINDOW_SIZE renumbered.
                else -> i
              }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  10. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
Back to top