File: CacheEntry.cs

package info (click to toggle)
mono 6.14.1%2Bds2-1
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 1,282,732 kB
  • sloc: cs: 11,182,461; xml: 2,850,281; ansic: 699,123; cpp: 122,919; perl: 58,604; javascript: 30,841; asm: 21,845; makefile: 19,602; sh: 10,973; python: 4,772; pascal: 925; sql: 859; sed: 16; php: 1
file content (433 lines) | stat: -rw-r--r-- 15,257 bytes parent folder | download | duplicates (6)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
//------------------------------------------------------------------------------
// <copyright file="CacheEntry.cs" company="Microsoft">
//     Copyright (c) Microsoft Corporation.  All rights reserved.
// </copyright>                                                                
//------------------------------------------------------------------------------

/*
 * CacheEntry
 * 
 * Copyright (c) 1998-1999, Microsoft Corporation
 * 
 */

namespace System.Web.Caching {
    using System.Text;
    using System.Threading;
    using System.Web;
    using System.Web.Util;
    using System.Collections;
    using System.Web.Management;
    using System.Web.Hosting;
    using System.Globalization;

    internal class CacheKey {
        protected const byte BitPublic = 0x20;
        protected const byte BitOutputCache = 0x40;

        protected string    _key;   /* key to the item */
        protected byte      _bits;  /* cache lifetime state and public property */
        int                 _hashCode;

        internal CacheKey(String key, bool isPublic) {
            if (key == null) {
                throw new ArgumentNullException("key");
            }
    
            _key = key;
            if (isPublic) {
                _bits = BitPublic;
            }
            else if (key[0] == CacheInternal.PrefixOutputCache[0]) {
                _bits |= BitOutputCache;
            }

#if DBG
            if (!isPublic) {
                Debug.Assert(CacheInternal.PrefixFIRST[0] <= key[0] && key[0] <= CacheInternal.PrefixLAST[0],
                             "CacheInternal.PrefixFIRST[0] <= key[0] && key[0] <= CacheInternal.PrefixLAST[0], key=" + key);
            }
#endif
        }

         internal String Key {
            get { return _key; }
        }

        internal bool IsOutputCache {
            get { return (_bits & BitOutputCache) != 0; }
        }

        internal bool IsPublic {
            get { return (_bits & BitPublic) != 0; }
        }

        public override int GetHashCode() {
            if (_hashCode == 0) {
                _hashCode = _key.GetHashCode();
            }

            return _hashCode;
        }

#if DBG
        public override string ToString() {
            return (IsPublic ? "P:" : "I:") + _key;
        }
#endif
    }

    /*
     * An entry in the cache.
     * Overhead is 68 bytes + object header.
     */
    internal sealed class CacheEntry : CacheKey {
        const CacheItemPriority     CacheItemPriorityMin = CacheItemPriority.Low;
        const CacheItemPriority     CacheItemPriorityMax = CacheItemPriority.NotRemovable;
        static readonly TimeSpan    OneYear = new TimeSpan(365, 0, 0, 0);


        internal enum EntryState : byte {
            NotInCache         = 0x00,  // Created but not in hashtable
            AddingToCache      = 0x01,  // In hashtable only
            AddedToCache       = 0x02,  // In hashtable + expires + usage
            RemovingFromCache  = 0x04,  // Removed from hashtable only
            RemovedFromCache   = 0x08,  // Removed from hashtable & expires & usage
            Closed             = 0x10, 
        }

        const byte EntryStateMask   = 0x1f;
//        protected const byte BitPublic = 0x20;

        // item
        object                      _value;                 /* value */
        DateTime                    _utcCreated;            /* creation date */


        // expiration
        DateTime                    _utcExpires;            /* when this item expires */
        TimeSpan                    _slidingExpiration;     /* expiration interval */
        byte                        _expiresBucket;         /* index of the expiration list (bucket) */
        ExpiresEntryRef             _expiresEntryRef;       /* ref into the expiration list */

        // usage
        byte                        _usageBucket;           /* index of the usage list (== priority-1) */
        UsageEntryRef               _usageEntryRef;         /* ref into the usage list */
        DateTime                    _utcLastUpdate;         /* time we last updated usage */
        CacheInternal               _cache;

        // dependencies
        CacheDependency             _dependency;            /* dependencies this item has */
        object                      _onRemovedTargets;      /* targets of OnRemove notification */

                /*
         * ctor.
         */

        internal CacheEntry(
                   String                   key, 
                   Object                   value, 
                   CacheDependency          dependency,
                   CacheItemRemovedCallback onRemovedHandler,
                   DateTime                 utcAbsoluteExpiration,           
                   TimeSpan                 slidingExpiration,      
                   CacheItemPriority        priority,
                   bool                     isPublic,
                   CacheInternal            cache) : 

                base(key, isPublic) {

            if (value == null) {
                throw new ArgumentNullException("value");
            }

            if (slidingExpiration < TimeSpan.Zero || OneYear < slidingExpiration) {
                throw new ArgumentOutOfRangeException("slidingExpiration");
            }

            if (utcAbsoluteExpiration != Cache.NoAbsoluteExpiration && slidingExpiration != Cache.NoSlidingExpiration) {
                throw new ArgumentException(SR.GetString(SR.Invalid_expiration_combination));
            }

            if (priority < CacheItemPriorityMin || CacheItemPriorityMax < priority) {
                throw new ArgumentOutOfRangeException("priority");
            }

            _value = value;
            _dependency = dependency;
            _onRemovedTargets = onRemovedHandler;

            _utcCreated = DateTime.UtcNow;
            _slidingExpiration = slidingExpiration;
            if (_slidingExpiration > TimeSpan.Zero) {
                _utcExpires = _utcCreated + _slidingExpiration;
            }
            else {
                _utcExpires = utcAbsoluteExpiration;
            } 

            _expiresEntryRef = ExpiresEntryRef.INVALID;
            _expiresBucket = 0xff;

            _usageEntryRef = UsageEntryRef.INVALID;
            if (priority == CacheItemPriority.NotRemovable) {
                _usageBucket = 0xff;
            }
            else {
                _usageBucket = (byte) (priority - 1);
            }

            _cache = cache;
        }

        internal Object Value {
            get {return _value;}
        }

        internal DateTime UtcCreated {
            get {return _utcCreated;}
        }

        internal EntryState State {
            get { return (EntryState) (_bits & EntryStateMask); }
            set { _bits = (byte) (((uint) _bits & ~(uint)EntryStateMask) | (uint) value); }
        }

        internal DateTime UtcExpires {
            get {return _utcExpires;}
            set {_utcExpires = value;}
        }

        internal TimeSpan SlidingExpiration {
            get {return _slidingExpiration;}
        }

        internal byte ExpiresBucket {
            get {return _expiresBucket;}
            set {_expiresBucket = value;}
        }

        internal ExpiresEntryRef ExpiresEntryRef {
            get {return _expiresEntryRef;}
            set {_expiresEntryRef = value;}
        }

        internal bool HasExpiration() {
            return _utcExpires < DateTime.MaxValue;
        }

        internal bool InExpires() {
            return !_expiresEntryRef.IsInvalid;
        }

        internal byte UsageBucket {
            get {return _usageBucket;}
        }

        internal UsageEntryRef UsageEntryRef {
            get {return _usageEntryRef;}
            set {_usageEntryRef = value;}
        }

        internal DateTime UtcLastUsageUpdate {
            get {return _utcLastUpdate;}
            set {_utcLastUpdate = value;}
        }

        internal bool HasUsage() {
            return _usageBucket != 0xff;
        }

        internal bool InUsage() {
            return !_usageEntryRef.IsInvalid;
        }

        internal CacheDependency Dependency {
            get {return _dependency;}
        }

        internal void MonitorDependencyChanges() {
            // need to protect against the item being closed
            CacheDependency dependency = _dependency;
            if (dependency != null && State == EntryState.AddedToCache) {
                if (!dependency.TakeOwnership()) {
                    throw new InvalidOperationException(
                            SR.GetString(SR.Cache_dependency_used_more_that_once));
                }

                dependency.SetCacheDependencyChanged((Object sender, EventArgs args) => {
                    DependencyChanged(sender, args);
                });
            }
        }

        /*
         * The entry has changed, so remove ourselves from the cache.
         */
        void DependencyChanged(Object sender, EventArgs e) {
            if (State == EntryState.AddedToCache) {
                _cache.Remove(this, CacheItemRemovedReason.DependencyChanged);
            }
        }

        /*
         * Helper to call the on-remove callback
         */

        private void CallCacheItemRemovedCallback(CacheItemRemovedCallback callback, CacheItemRemovedReason reason) {
            if (IsPublic) {
                try {
                    // for public need to impersonate if called outside of request context
                    if (HttpContext.Current == null) {
                        using (new ApplicationImpersonationContext()) {
                            callback(_key, _value, reason);
                        }
                    }
                    else {
                        callback(_key, _value, reason);
                    }
                }
                catch (Exception e) {
                    // for public need to report application error
                    HttpApplicationFactory.RaiseError(e);

                    try {
                        WebBaseEvent.RaiseRuntimeError(e, this);
                    }
                    catch {
                    }
                }
            }
            else {
                // for private items just make the call and eat any exceptions
                try {
                    using (new ApplicationImpersonationContext()) {
                        callback(_key, _value, reason);
                    }
                }
                catch {
                }
            }
        }

        /*
         * Close the item to complete its removal from cache.
         * 
         * @param reason The reason the item is removed.
         */
        internal void Close(CacheItemRemovedReason reason) {
            Debug.Assert(State == EntryState.RemovedFromCache, "State == EntryState.RemovedFromCache");
            State = EntryState.Closed;

            object      onRemovedTargets = null;
            object[]    targets = null;

            lock (this) {
                if (_onRemovedTargets != null) {
                    onRemovedTargets = _onRemovedTargets;
                    if (onRemovedTargets is Hashtable) {
                        ICollection col = ((Hashtable) onRemovedTargets).Keys;
                        targets = new object[col.Count];
                        col.CopyTo(targets, 0);
                    }
                }
            }

            if (onRemovedTargets != null) {
                if (targets != null) {
                    foreach (object target in targets) {
                        if (target is CacheDependency) {
                            ((CacheDependency)target).ItemRemoved();
                        }
                        else {
                            CallCacheItemRemovedCallback((CacheItemRemovedCallback) target, reason);
                        }
                    }
                }
                else if (onRemovedTargets is CacheItemRemovedCallback) {
                    CallCacheItemRemovedCallback((CacheItemRemovedCallback) onRemovedTargets, reason);
                }
                else {
                    ((CacheDependency) onRemovedTargets).ItemRemoved();
                }
            }

            if (_dependency != null) {
                _dependency.DisposeInternal();
            }
        }

#if DBG
        internal /*public*/ string DebugDescription(string indent) {
            StringBuilder sb = new StringBuilder();
            String      nlindent = "\n" + indent + "    ";

            sb.Append(indent + "CacheItem");
            sb.Append(nlindent); sb.Append("_key=");        sb.Append(_key);
            sb.Append(nlindent); sb.Append("_value=");      sb.Append(Debug.GetDescription(_value, indent));
            sb.Append(nlindent); sb.Append("_utcExpires="); sb.Append(Debug.FormatUtcDate(_utcExpires));
            sb.Append(nlindent); sb.Append("_bits=0x");     sb.Append(((int)_bits).ToString("x", CultureInfo.InvariantCulture));
            sb.Append("\n");

            return sb.ToString();
        }
#endif

        internal void AddDependent(CacheDependency dependency) {
            lock (this) {
                if (_onRemovedTargets == null) {
                    _onRemovedTargets = dependency;
                }
                else if (_onRemovedTargets is Hashtable) {
                    Hashtable h = (Hashtable) _onRemovedTargets;
                    h[dependency] = dependency;
                }
                else {
                    Hashtable h = new Hashtable(2);
                    h[_onRemovedTargets] = _onRemovedTargets;
                    h[dependency] = dependency;
                    _onRemovedTargets = h;
                }
            }
        }

        internal void RemoveDependent(CacheDependency dependency) {
            lock (this) {
                if (_onRemovedTargets != null) {
                    if (_onRemovedTargets == dependency) {
                        _onRemovedTargets = null;
                    }
                    else if (_onRemovedTargets is Hashtable) {
                        Hashtable h = (Hashtable)_onRemovedTargets;
                        h.Remove(dependency);
                        if (h.Count == 0) {
                            _onRemovedTargets = null;
                        }
                    }
                }
            }
        }

#if USE_MEMORY_CACHE
        internal CacheItemRemovedCallback CacheItemRemovedCallback {
            get {
                CacheItemRemovedCallback callback = null;
                lock (this) {
                    if (_onRemovedTargets != null) {
                        if (_onRemovedTargets is Hashtable) {
                            foreach (DictionaryEntry e in (Hashtable)_onRemovedTargets) {
                                callback = e.Value as CacheItemRemovedCallback;
                                break;
                            }
                        }
                        else {
                            callback = _onRemovedTargets as CacheItemRemovedCallback;   
                        }
                    }
                }
                return callback;
            }
        }
#endif
    }
}