- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 138 for Storep (0.22 sec)
-
cmd/iam-object-store.go
if err == errConfigNotFound { return errNoSuchPolicy } retries-- if retries <= 0 { return err } time.Sleep(500 * time.Millisecond) goto retry } m.Store(name, p) return nil } } func (iamOS *IAMObjectStore) loadMappedPolicy(ctx context.Context, name string, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy]) error { var p MappedPolicy
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 19.5K bytes - Viewed (0) -
cmd/iam-etcd-store.go
var p MappedPolicy err := ies.loadIAMConfig(ctx, &p, getMappedPolicyPath(name, userType, isGroup)) if err != nil { if err == errConfigNotFound { return errNoSuchPolicy } return err } m.Store(name, p) return nil } func getMappedPolicy(kv *mvccpb.KeyValue, m *xsync.MapOf[string, MappedPolicy], basePrefix string) error { var p MappedPolicy err := getIAMConfig(&p, kv.Value, string(kv.Key))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 13.6K bytes - Viewed (0) -
cmd/iam-store.go
} // HasWatcher - returns if the storage system has a watcher. func (store *IAMStoreSys) HasWatcher() bool { _, ok := store.IAMStorageAPI.(iamStorageWatcher) return ok } // GetUser - fetches credential from memory. func (store *IAMStoreSys) GetUser(user string) (UserIdentity, bool) { cache := store.rlock() defer store.runlock() u, ok := cache.iamUsersMap[user] if !ok { // Check the sts map
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0) -
src/sync/map.go
// read contains the portion of the map's contents that are safe for // concurrent access (with or without mu held). // // The read field itself is always safe to load, but must only be stored with // mu held. // // Entries stored in read may be updated concurrently without mu, but updating // a previously-expunged entry requires that the entry be copied to the dirty // map and unexpunged with mu held. read atomic.Pointer[readOnly]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 15.6K bytes - Viewed (0) -
src/sync/atomic/doc.go
func LoadPointer(addr *unsafe.Pointer) (val unsafe.Pointer) // StoreInt32 atomically stores val into *addr. // Consider using the more ergonomic and less error-prone [Int32.Store] instead. func StoreInt32(addr *int32, val int32) // StoreInt64 atomically stores val into *addr. // Consider using the more ergonomic and less error-prone [Int64.Store] instead // (particularly if you target 32-bit platforms; see the bugs section).
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 11.7K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/problems/ConfigurationCacheProblems.kt
cacheAction == STORE && !hasProblems -> log("Configuration cache entry stored.") cacheAction == STORE -> log("Configuration cache entry stored with {}.", problemCountString) cacheAction == UPDATE && !hasProblems -> log("Configuration cache entry updated for {}, {} up-to-date.", updatedProjectsString, reusedProjectsString)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 13:04:02 UTC 2024 - 13.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
storagetesting.RunTestCreateWithTTL(ctx, t, store) } func TestCreateWithKeyExist(t *testing.T) { ctx, store, _ := testSetup(t) storagetesting.RunTestCreateWithKeyExist(ctx, t, store) } func TestGet(t *testing.T) { ctx, store, _ := testSetup(t) storagetesting.RunTestGet(ctx, t, store) } func TestUnconditionalDelete(t *testing.T) { ctx, store, _ := testSetup(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/initialization/ConfigurationCacheStartParameter.kt
/** * On a CC miss, should we load the newly stored state in the same invocation? * * This provides a benefit of discarding a lot of state (e.g. project state) earlier in the build, * potentially reducing the memory consumption. * Another key benefit is that this eliminates discrepancies in behavior between cache hits and misses. * * We disable load-after-store when tooling model builders are involved.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 6.6K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheBuildOperationsIntegrationTest.groovy
workGraphStoredAndLoaded() def loadOp = operations.only(ConfigurationCacheLoadBuildOperationType) def storeOp = operations.only(ConfigurationCacheStoreBuildOperationType) with(storeOp.result) { cacheEntrySize > 0 } with(loadOp.result) { cacheEntrySize == storeOp.result.cacheEntrySize } def buildInvocationId = loadOp.result.originBuildInvocationId when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 23.4K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/_gen/PPC64.rules
(Load <t> ptr mem) && is64BitFloat(t) => (FMOVDload ptr mem) (Store {t} ptr val mem) && t.Size() == 8 && t.IsFloat() => (FMOVDstore ptr val mem) (Store {t} ptr val mem) && t.Size() == 4 && t.IsFloat() => (FMOVSstore ptr val mem) (Store {t} ptr val mem) && t.Size() == 8 && !t.IsFloat() => (MOVDstore ptr val mem) (Store {t} ptr val mem) && t.Size() == 4 && !t.IsFloat() => (MOVWstore ptr val mem) (Store {t} ptr val mem) && t.Size() == 2 => (MOVHstore ptr val mem)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:02:52 UTC 2024 - 53.2K bytes - Viewed (0)