- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for ClearAll (0.09 sec)
-
pilot/pkg/model/typed_xds_cache.go
// Get retrieves the cached value if it exists. Get(key K) *discovery.Resource // Clear removes the cache entries that are dependent on the configs passed. Clear(sets.Set[ConfigKey]) // ClearAll clears the entire cache. ClearAll() // Keys returns all currently configured keys. This is for testing/debug only Keys() []K // Snapshot returns a snapshot of all keys and values. This is for testing/debug only
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 11K bytes - Viewed (0) -
src/runtime/mpallocbits.go
} _ = b[j/64] // Clear leading bits. b[i/64] &^= ^uint64(0) << (i % 64) clear(b[i/64+1 : j/64]) // Clear trailing bits. b[j/64] &^= (uint64(1) << (j%64 + 1)) - 1 } // clearAll frees all the bits of b. func (b *pageBits) clearAll() { clear(b[:]) } // clearBlock64 clears the 64-bit aligned block of bits containing the i'th bit that // are set in v. func (b *pageBits) clearBlock64(i uint, v uint64) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 18 15:13:43 UTC 2024 - 12.5K bytes - Viewed (0) -
pilot/pkg/model/typed_xds_cache_test.go
}) cache.ClearAll() // no change on empty clear assert.Equal(t, cache.indexLength(), 0) assert.Equal(t, cache.store.Len(), 0) } func TestEvictQueueMemoryLeak(t *testing.T) { testEvictQueueMemoryLeak(t, "Flush") testEvictQueueMemoryLeak(t, "ClearAll") } func testEvictQueueMemoryLeak(t *testing.T, f string) { entry1 := entry{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 29 20:35:31 UTC 2024 - 18.2K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
func (s *DiscoveryServer) dropCacheForRequest(req *model.PushRequest) { // If we don't know what updated, cannot safely cache. Clear the whole cache if len(req.ConfigsUpdated) == 0 { s.Cache.ClearAll() } else { // Otherwise, just clear the updated configs s.Cache.Clear(req.ConfigsUpdated) } } // Push is called to push changes on config updates using ADS.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
for svc, shardsByNamespace := range e.shardsBySvc { for ns := range shardsByNamespace { e.deleteServiceInner(shardKey, svc, ns, false) } } if e.cache == nil { return } e.cache.ClearAll() } // must be called with lock func (e *EndpointIndex) deleteServiceInner(shard ShardKey, serviceName, namespace string, preserveKeys bool) { if e.shardsBySvc[serviceName] == nil ||
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
if err := req.ParseForm(); err != nil { w.WriteHeader(http.StatusBadRequest) _, _ = w.Write([]byte("Failed to parse request\n")) return } if req.Form.Get("clear") != "" { s.Cache.ClearAll() _, _ = w.Write([]byte("Cache cleared\n")) return } if req.Form.Get("sizes") != "" { snapshot := s.Cache.Snapshot() raw := make(map[string]int, len(snapshot)) totalSize := 0
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0)