- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 652 for load (0.25 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/hash/LittleEndianByteArray.java
@ElementTypesAreNonnullByDefault final class LittleEndianByteArray { /** The instance that actually does the work; delegates to Unsafe or a pure-Java fallback. */ private static final LittleEndianBytes byteArray; /** * Load 8 bytes into long in a little endian manner, from the substring between position and * position + 8. The array must have at least 8 bytes from offset (inclusive). * * @param input the input bytes
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 9.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 Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
info.Metrics = p.getMetrics() } info.Metrics.TotalWrites = p.totalWrites.Load() info.Metrics.TotalDeletes = p.totalDeletes.Load() info.Metrics.TotalWaiting = uint32(p.health.waiting.Load()) info.Metrics.TotalErrorsTimeout = p.totalErrsTimeout.Load() info.Metrics.TotalErrorsAvailability = p.totalErrsAvailability.Load() if p.health.isFaulty() {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/http-stats.go
APIStats: st.currentS3Requests.Load(toLowerKeys), } serverStats.TotalS3Requests = ServerHTTPAPIStats{ APIStats: st.totalS3Requests.Load(toLowerKeys), } serverStats.TotalS3Errors = ServerHTTPAPIStats{ APIStats: st.totalS3Errors.Load(toLowerKeys), } serverStats.TotalS34xxErrors = ServerHTTPAPIStats{ APIStats: st.totalS34xxErrors.Load(toLowerKeys), }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 11.4K bytes - Viewed (0) -
ci/official/requirements_updater/BUILD.bazel
load("@python//3.10:defs.bzl", compile_pip_requirements_3_10 = "compile_pip_requirements") load("@python//3.11:defs.bzl", compile_pip_requirements_3_11 = "compile_pip_requirements") load("@python//3.12:defs.bzl", compile_pip_requirements_3_12 = "compile_pip_requirements") load("@python//3.9:defs.bzl", compile_pip_requirements_3_9 = "compile_pip_requirements")
Plain Text - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Mar 27 18:00:18 GMT 2024 - 3K bytes - Viewed (2) -
guava-tests/test/com/google/common/cache/CacheLoaderTest.java
final AtomicInteger loadAllCount = new AtomicInteger(); CacheLoader<Object, Object> baseLoader = new CacheLoader<Object, Object>() { @Override public Object load(Object key) { loadCount.incrementAndGet(); return new Object(); } @Override public ListenableFuture<Object> reload(Object key, Object oldValue) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri Aug 05 17:21:46 GMT 2022 - 3.6K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache_test.go
} if !reflect.DeepEqual(netns1, netns2) { t.Fatalf("Expected the same Netns for the same uid, got %v and %v", netns1, netns2) } if counter.Load() != 2 { t.Fatalf("Expected openNetns to be called twice, got %d", counter.Load()) } } func TestUpsertPodCacheWithNewInode(t *testing.T) { counter.Store(0) p := newPodNetnsCache(openNsTestOverrideWithInodes(1, 2))
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.2K bytes - Viewed (0) -
cmd/lock-rest-server.go
logger.FatalIf(lockRPCForceUnlock.Register(globalGrid.Load(), lockServer.ForceUnlockHandler), "unable to register handler") logger.FatalIf(lockRPCRefresh.Register(globalGrid.Load(), lockServer.RefreshHandler), "unable to register handler") logger.FatalIf(lockRPCLock.Register(globalGrid.Load(), lockServer.LockHandler), "unable to register handler") logger.FatalIf(lockRPCUnlock.Register(globalGrid.Load(), lockServer.UnlockHandler), "unable to register handler")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/windows/BUILD
# Experimental windows filesystem plugin. load("//tensorflow:tensorflow.bzl", "get_win_copts", "tf_cc_shared_object") load("//tensorflow/core/platform:rules_cc.bzl", "cc_library") package( # copybara:uncomment default_applicable_licenses = ["//tensorflow:license"], licenses = ["notice"], ) # Filesystem implementation for Windows environment tf_cc_shared_object( name = "windows_filesystem.dll", framework_so = [],
Plain Text - Registered: Tue Apr 09 12:39:09 GMT 2024 - Last Modified: Wed Mar 27 18:00:18 GMT 2024 - 987 bytes - Viewed (0)