- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 2,588 for Storep (0.15 sec)
-
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/software/dependency-management/src/test/groovy/org/gradle/internal/resource/cached/TwoStageExternalResourceFileStoreTest.groovy
1 * writeStore.add(key, action) 0 * readStore.add(key, action) } def "searches in both read and write stores"() { setup: def r1 = Stub(LocallyAvailableResource) def r2 = Stub(LocallyAvailableResource) def r3 = Stub(LocallyAvailableResource) 1 * writeStore.search(key) >> { [r1] as Set } 1 * readStore.search(key) >> {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 2.5K bytes - Viewed (0) -
src/expvar/expvar.go
} func (v *Map) Set(key string, av Var) { // Before we store the value, check to see whether the key is new. Try a Load // before LoadOrStore: LoadOrStore causes the key interface to escape even on // the Load path. if _, ok := v.m.Load(key); !ok { if _, dup := v.m.LoadOrStore(key, av); !dup { v.addKey(key) return } } v.m.Store(key, av) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 21:32:11 UTC 2024 - 9.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/dropped_requests_tracker.go
// a single second. type unixStat struct { unixTime int64 requests int64 } type droppedRequestsStats struct { lock sync.RWMutex // history stores the history of dropped requests. history []unixStat // To reduce lock-contention, we store the information about // the current second here, which we can then access under // reader lock. currentUnix int64 currentCount atomic.Int64
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 26 13:50:25 UTC 2023 - 6.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/resource_op_lifting.cc
op.getIsInitialized().replaceAllUsesWith(const_true); op.erase(); } } // Performs store-load forwarding. This effectively removes // 1) Any resource loads after a store to that same resource is done // 2) Any resource stores except the last one. // TODO(ycao): Store-load forwarding implemented here is only correct when // computation is purely sequential (no concurrency). Need to support concurrent
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 55.1K bytes - Viewed (0) -
src/sync/poolqueue.go
// it nils the slot, at which point ownership passes to the // producer. // // The head index is stored in the most-significant bits so // that we can atomically add to it and the overflow is // harmless. headTail atomic.Uint64 // vals is a ring buffer of interface{} values stored in this // dequeue. The size of this must be a power of 2. // // vals[i].typ is nil if the slot is empty and non-nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 18:12:29 UTC 2024 - 8.3K 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/runtime/mgclimit.go
if !enabled { l.enabled.Store(true) l.lastEnabledCycle.Store(memstats.numgc + 1) } return } // Handle non-limiting cases. if change < 0 && l.bucket.fill <= uint64(-change) { // Bucket emptied. l.bucket.fill = 0 } else { // All other cases. l.bucket.fill -= uint64(-change) } if change != 0 && enabled { l.enabled.Store(false) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 22:07:41 UTC 2024 - 17.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd.go
return r.store.Update(ctx, name, objInfo, createValidation, updateValidation, false, options) } // GetResetFields implements rest.ResetFieldsStrategy func (r *StatusREST) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set { return r.store.GetResetFields() } type ScaleREST struct { store *genericregistry.Store specReplicasPath string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12.4K bytes - Viewed (0) -
pilot/pkg/xds/pushqueue.go
type PushQueue struct { cond *sync.Cond // pending stores all connections in the queue. If the same connection is enqueued again, // the PushRequest will be merged. pending map[*Connection]*model.PushRequest // queue maintains ordering of the queue queue []*Connection // processing stores all connections that have been Dequeue(), but not MarkDone().
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 16 01:37:15 UTC 2021 - 3.8K bytes - Viewed (0)