- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 490 for load3 (0.17 sec)
-
guava/src/com/google/common/cache/LoadingCache.java
* {@code key}, simply waits for that thread to finish and returns its loaded value. Note that * multiple threads can concurrently load values for distinct keys. * * <p>Caches loaded by a {@link CacheLoader} will call {@link CacheLoader#load} to load new values * into the cache. Newly loaded values are added to the cache using {@code
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Sat Aug 06 17:12:03 GMT 2022 - 8.3K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LoadingCache.java
* {@code key}, simply waits for that thread to finish and returns its loaded value. Note that * multiple threads can concurrently load values for distinct keys. * * <p>Caches loaded by a {@link CacheLoader} will call {@link CacheLoader#load} to load new values * into the cache. Newly loaded values are added to the cache using {@code
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Sat Aug 06 17:12:03 GMT 2022 - 8.3K bytes - Viewed (0) -
cmd/metrics-v3-types.go
buckets []string } // NewMetricsGroup creates a new MetricsGroup. To create a metrics group for // metrics with a `bucket` dimension (label), use `NewBucketMetricsGroup`. // // The `loader` function loads metrics from the cache and the system. func NewMetricsGroup(path collectorPath, descriptors []MetricDescriptor, loader MetricsLoaderFn, ) *MetricsGroup { mg := &MetricsGroup{ CollectorPath: path,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:05:22 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/iam-object-store.go
for _, item := range iamListing[stsListKey] { userName := path.Dir(item) // loadUser() will delete expired user during the load. err := iamOS.loadUser(ctx, userName, stsUser, stsAccountsFromStore) if err != nil && !errors.Is(err, errNoSuchUser) { iamLogIf(GlobalContext, fmt.Errorf("unable to load user during STS purge: %w (%s)", err, item)) } } // Loading the STS policy mappings from disk ensures that stale entries
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/common-main.go
// Manually load the certificate and private key into memory. // We need to check whether the private key is encrypted, and // if so, decrypt it using the user-provided password. certBytes, err := os.ReadFile(certFile) if err != nil { return tls.Certificate{}, fmt.Errorf("Unable to load KES client certificate as specified by the shell environment: %v", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
cmd/bucket-metadata-sys.go
func (sys *BucketMetadataSys) Initialized() bool { sys.RLock() defer sys.RUnlock() return sys.initialized } // Loads bucket metadata for all buckets into BucketMetadataSys. func (sys *BucketMetadataSys) init(ctx context.Context, buckets []BucketInfo) { count := 100 // load 100 bucket metadata at a time. failedBuckets := make(map[string]struct{}) for { if len(buckets) < count {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
guava/src/com/google/common/base/internal/Finalizer.java
* unloading an OSGi bundle. * * <p>{@code com.google.common.base.FinalizableReferenceQueue} loads this class in its own class * loader. That way, this class doesn't prevent the main class loader from getting garbage * collected, and this class can detect when the main class loader has been garbage collected and * stop itself. */
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Wed Aug 23 12:54:09 GMT 2023 - 9.4K bytes - Viewed (0) -
cmd/iam.go
func (sys *IAMSys) Initialized() bool { if sys == nil { return false } sys.Lock() defer sys.Unlock() return sys.store != nil } // Load - loads all credentials, policies and policy mappings. func (sys *IAMSys) Load(ctx context.Context, firstTime bool) error { loadStartTime := time.Now() err := sys.store.LoadIAMCache(ctx, firstTime) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/peer-rest-client.go
return *resp, nil } // GetSRMetrics loads site replication metrics, optionally for a specific bucket func (client *peerRESTClient) GetSRMetrics() (SRMetricsSummary, error) { resp, err := getSRMetricsRPC.Call(context.Background(), client.gridConn(), grid.NewMSS()) if err != nil || resp == nil { return SRMetricsSummary{}, err } return *resp, nil } // GetAllBucketStats - load replication stats for all buckets
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/config-current.go
return readServerConfig(GlobalContext, objAPI, nil) } // loadConfig - loads a new config from disk, overrides params // from env if found and valid // data is optional. If nil it will be loaded from backend. func loadConfig(objAPI ObjectLayer, data []byte) error { bootstrapTraceMsg("load the configuration") srvCfg, err := readServerConfig(GlobalContext, objAPI, data) if err != nil { return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0)