- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 494 for Load (0.14 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
private Class<?> settableFutureClass; private Class<?> abstractFutureClass; @Override protected void setUp() throws Exception { // Load the "normal" copy of SettableFuture and related classes. SettableFuture<?> unused = SettableFuture.create(); // Hack to load AbstractFuture et. al. in a new classloader so that it re-reads the cancellation
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 6.2K bytes - Viewed (0) -
cmd/routers.go
// Composed function registering routers for only distributed Erasure setup. func registerDistErasureRouters(router *mux.Router, endpointServerPools EndpointServerPools) { var ( lockGrid = globalLockGrid.Load() commonGrid = globalGrid.Load() ) // Register storage REST router only if its a distributed setup. registerStorageRESTHandlers(router, endpointServerPools, commonGrid)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 3.9K bytes - Viewed (0) -
cmd/config.go
} // NewConfigSys - creates new config system object. func NewConfigSys() *ConfigSys { return &ConfigSys{} } // Initialize and load config from remote etcd or local config directory func initConfig(objAPI ObjectLayer) (err error) { bootstrapTraceMsg("load the configuration") defer func() { if err != nil { bootstrapTraceMsg(fmt.Sprintf("loading configuration failed: %v", err)) } }()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.9K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/model/SimpleClassMetaDataRepository.java
public class SimpleClassMetaDataRepository<T extends Attachable<T>> implements ClassMetaDataRepository<T> { private final Map<String, T> classes = new TreeMap<>(); @SuppressWarnings("unchecked") public void load(File repoFile) { try { FileInputStream inputStream = new FileInputStream(repoFile); try {
Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Wed May 21 06:20:45 UTC 2025 - 4K bytes - Viewed (0) -
cmd/config-current.go
} case config.LoggerWebhookSubSys: loggerCfg, err := logger.LookupConfigForSubSys(ctx, s, config.LoggerWebhookSubSys) if err != nil { configLogIf(ctx, fmt.Errorf("Unable to load logger webhook config: %w", err)) } userAgent := getUserAgent(getMinioMode()) for n, l := range loggerCfg.HTTP { if l.Enabled { l.LogOnceIf = configLogOnceConsoleIf l.UserAgent = userAgent
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 28.5K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
defer locker.Unlock(lkctx) // Load healing tracker in this disk tracker, err := loadHealingTracker(ctx, disk) if err != nil { // A healing tracker may be deleted if another disk in the // same erasure set with same healing-id successfully finished // healing. if errors.Is(err, errFileNotFound) { 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) -
internal/kms/kms.go
latency := make(map[time.Duration]uint64, len(k.latencyBuckets)) for i, b := range k.latencyBuckets { latency[b] = k.latency[i].Load() } return &Metrics{ ReqOK: k.reqOK.Load(), ReqErr: k.reqErr.Load(), ReqFail: k.reqFail.Load(), Latency: latency, }, nil } // Status returns status information about the KMS. //
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Apr 24 15:33:57 UTC 2025 - 11.4K bytes - Viewed (0) -
internal/kms/config.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) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java
} // constructor tests public void testComputingFunction() { CacheLoader<Object, Object> loader = new CacheLoader<Object, Object>() { @Override public Object load(Object from) { return new Object(); } }; LocalLoadingCache<Object, Object> cache = makeCache(createCacheBuilder(), loader);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 13.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/KeyMatchHelper.java
*/ @PostConstruct public void init() { if (logger.isDebugEnabled()) { logger.debug("Initializing {}", this.getClass().getSimpleName()); } load(); } /** * Returns a list of available KeyMatch instances. * * @return A list of KeyMatch instances. */ public List<KeyMatch> getAvailableKeyMatchList() {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 10.1K bytes - Viewed (0)