Internal\DefaultHybridCache.StampedeStateT.cs (20)
176if (!ValidateUnicodeCorrectness(Cache._logger, Key.Key, CacheItem.Tags))
186Cache.PrefetchTags(CacheItem.Tags);
196result = await Cache.GetFromL2DirectAsync(Key.Key, SharedToken).ConfigureAwait(false);
225Cache._logger.CacheUnderlyingDataQueryFailure(ex);
233result.AsArraySegment(), Key.Key, CacheItem.Tags, Cache, out ArraySegment<byte> payload, out TimeSpan remainingTime,
239if (pendingTags.IsEmpty || !await Cache.IsAnyTagExpiredAsync(pendingTags, CacheItem.CreationTimestamp).ConfigureAwait(false))
254Cache._logger.CacheBackendDataRejected(parseResult, fault);
299if (!Cache.IsValid(CacheItem))
311long time = Cache.CurrentTimestamp();
318time = Cache.CurrentTimestamp();
348if (Cache.TrySerialize(newValue, out BufferChunk buffer, out IHybridCacheSerializer<T>? serializer))
374await Cache.SetL2Async(Key.Key, cacheItem, in buffer, _options, SharedToken).ConfigureAwait(false);
386Cache._logger.CacheBackendWriteFailure(ex);
429Cache.RemoveStampedeState(in Key);
439Cache.RemoveStampedeState(in Key);
449IHybridCacheSerializer<T> serializer = Cache.GetSerializer<T>();
462mutable.DebugOnlyTrackBuffer(Cache);
517mutable.DebugOnlyTrackBuffer(Cache);
536Cache.SetL1(Key.Key, value, _options, maxRelativeTime); // we can do this without a TCS, for SetValue
541Cache.RemoveStampedeState(in Key);