- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 245 for isInitialized (0.1 sec)
-
guava/src/com/google/common/hash/HashFunction.java
* * @author Kevin Bourrillion * @since 11.0 */ @Immutable public interface HashFunction { /** * Begins a new hash code computation by returning an initialized, stateful {@code Hasher} * instance that is ready to receive data. Example: * * {@snippet : * HashFunction hf = Hashing.md5(); * HashCode hc = hf.newHasher() * .putLong(id)Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 10.9K bytes - Viewed (0) -
cmd/tier.go
binary.LittleEndian.PutUint16(data[2:4], tierConfigVersion) // Marshal the tier config return config.MarshalMsg(data) } // getDriver returns a warmBackend interface object initialized with remote tier config matching tierName func (config *TierConfigMgr) getDriver(ctx context.Context, tierName string) (d WarmBackend, err error) { config.Lock() defer config.Unlock() var ok bool
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
cmd/api-errors.go
}, ErrServerNotInitialized: { Code: "XMinioServerNotInitialized", Description: "Server not initialized yet, please try again.", HTTPStatusCode: http.StatusServiceUnavailable, }, ErrIAMNotInitialized: { Code: "XMinioIAMNotInitialized", Description: "IAM sub-system not initialized yet, please try again.", HTTPStatusCode: http.StatusServiceUnavailable, },Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 16 07:34:24 UTC 2025 - 93K bytes - Viewed (3) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* * <p>This class would certainly be simpler and easier to reason about if it were built with * ThreadLocal; however, ThreadLocal is not well optimized for the case where the ThreadLocal is * non-static, and is initialized/removed frequently - this causes churn in the Thread specific * hashmaps. Using a static ThreadLocal to avoid that overhead would mean that different
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 22.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
}.apply { timeout(client.callTimeoutMillis.toLong(), MILLISECONDS) } private val executed = AtomicBoolean() // These properties are only accessed by the thread executing the call. /** Initialized in [callStart]. */ private var callStackTrace: Any? = null /** Finds an exchange to send the next request and receive the next response. */ private var exchangeFinder: ExchangeFinder? = nullRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Nov 05 18:28:35 UTC 2025 - 19.7K bytes - Viewed (0) -
internal/lru/lru.go
} // Init initializes or clears list l. func (l *LruList[K, V]) Init() *LruList[K, V] { l.root.next = &l.root l.root.prev = &l.root l.len = 0 return l } // NewList returns an initialized list. func NewList[K comparable, V any]() *LruList[K, V] { return new(LruList[K, V]).Init() } // Length returns the number of elements of list l. // The complexity is O(1).
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Fri Apr 25 08:22:26 UTC 2025 - 12.5K bytes - Viewed (0) -
internal/bucket/object/lock/lock.go
config := Config{} if err := xml.NewDecoder(io.LimitReader(reader, maxObjectLockConfigSize)).Decode(&config); err != nil { return nil, err } return &config, nil } // NewObjectLockConfig returns a initialized lock.Config struct func NewObjectLockConfig() *Config { return &Config{ ObjectLockEnabled: Enabled, } } // RetentionDate is a embedded type containing time.Time to unmarshal // Date in RetentionRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 17.9K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
poolIdx, setIdx := endpoint.PoolIdx, endpoint.SetIdx disk := getStorageViaEndpoint(endpoint) if disk == nil { return fmt.Errorf("Unexpected error disk must be initialized by now after formatting: %s", endpoint) } _, err := disk.DiskInfo(ctx, DiskInfoOptions{}) if err != nil { if errors.Is(err, errDriveIsRoot) { // This is a root drive, ignore and move on return nil
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/CipherSuite.kt
return 0 } } /** * Holds interned instances. This needs to be above the init() calls below so that it's * initialized by the time those parts of `<clinit>()` run. Guarded by CipherSuite.class. */ private val INSTANCES = mutableMapOf<String, CipherSuite>() // Last updated 2016-07-03 using cipher suites from Android 24 and Java 9.Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 39.9K bytes - Viewed (0) -
cmd/bucket-metadata.go
} if !createdAt.IsZero() { b.Created = createdAt.UTC() } } // Load - loads the metadata of bucket by name from ObjectLayer api. // If an error is returned the returned metadata will be default initialized. func readBucketMetadata(ctx context.Context, api ObjectLayer, name string) (BucketMetadata, error) { if name == "" { internalLogIf(ctx, errors.New("bucket name cannot be empty"), logger.WarningKind)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 18.2K bytes - Viewed (0)