OLD | NEW |
| (Empty) |
1 # Copyright 2015 The Chromium Authors. All rights reserved. | |
2 # Use of this source code is governed by a BSD-style license that can be | |
3 # found in the LICENSE file. | |
4 | |
5 import pickle | |
6 import zlib | |
7 | |
8 from google.appengine.api import memcache | |
9 | |
10 from testing_utils import testing | |
11 | |
12 from common import cache_decorator | |
13 | |
14 | |
15 class _DummyCacher(cache_decorator.Cacher): | |
16 def __init__(self, cached_data): | |
17 self.cached_data = cached_data | |
18 | |
19 def Get(self, key): | |
20 return self.cached_data.get(key) | |
21 | |
22 def Set(self, key, data, expire_time=0): | |
23 self.cached_data[key] = data | |
24 | |
25 | |
26 def _DummyKeyGenerator(func, *_): | |
27 return func.__name__ | |
28 | |
29 | |
30 class CacheDecoratorTest(testing.AppengineTestCase): | |
31 def testPickledMemCacher(self): | |
32 cacher = cache_decorator.PickledMemCacher() | |
33 cacher.Set('a', 'd') | |
34 self.assertEquals('d', cacher.Get('a')) | |
35 | |
36 def _MockPickleAndZlib(self): | |
37 def Func(string, *_, **__): | |
38 return string | |
39 self.mock(pickle, 'dumps', Func) | |
40 self.mock(pickle, 'loads', Func) | |
41 self.mock(zlib, 'compress', Func) | |
42 self.mock(zlib, 'decompress', Func) | |
43 | |
44 def testCachingSmallDataInCompressedMemCacher(self): | |
45 self._MockPickleAndZlib() | |
46 cacher = cache_decorator.CompressedMemCacher() | |
47 data = 'A' * 1024 # A string of size 1KB. | |
48 cacher.Set('a', data) | |
49 self.assertEquals(data, cacher.Get('a')) | |
50 | |
51 def testCachingLargeDataInCompressedMemCacher(self): | |
52 self._MockPickleAndZlib() | |
53 cacher = cache_decorator.CompressedMemCacher() | |
54 data = 'A' * (1024 * 1024 * 2) # A string of size 2MB. | |
55 cacher.Set('a', data) | |
56 self.assertEquals(data, cacher.Get('a')) | |
57 | |
58 def testMissingSubPieceOfLargeDataInCompressedMemCacher(self): | |
59 self._MockPickleAndZlib() | |
60 cacher = cache_decorator.CompressedMemCacher() | |
61 data = 'A' * (1024 * 1024 * 2) # A string of size 2MB. | |
62 cacher.Set('a', data) | |
63 memcache.delete('a-0') | |
64 self.assertEquals(None, cacher.Get('a')) | |
65 | |
66 def testDefaultKeyGenerator(self): | |
67 expected_params = { | |
68 'id1': 'fi', | |
69 'id2': 'pi', | |
70 'url': 'http://url', | |
71 } | |
72 # Hexadecimal digits of MD5 digest of "pickled_params". | |
73 expected_key = 'f5f173c811f7c537a80d44511903a3e0' | |
74 | |
75 def MockPickleDumps(params): | |
76 self.assertEqual(expected_params, params) | |
77 return 'pickled_params' | |
78 | |
79 def Func(id1, id2, url=None): # Unused parameters-pylint: disable=W0613 | |
80 return 1 # pragma: no cover. | |
81 | |
82 class CallableIdentifier(object): | |
83 def identifier(self): | |
84 return 'fi' | |
85 | |
86 class PropertyIdentifier(object): | |
87 @property | |
88 def identifier(self): | |
89 return 'pi' | |
90 | |
91 self.mock(pickle, 'dumps', MockPickleDumps) | |
92 | |
93 args = (CallableIdentifier(), PropertyIdentifier()) | |
94 kwargs = {'url': 'http://url'} | |
95 key = cache_decorator._DefaultKeyGenerator(Func, args, kwargs) | |
96 self.assertEqual(expected_key, key) | |
97 | |
98 def testCachedDecoratorWhenResultIsAlreadyCached(self): | |
99 cacher = _DummyCacher({'n-Func': 1}) | |
100 | |
101 @cache_decorator.Cached( | |
102 namespace='n', key_generator=_DummyKeyGenerator, cacher=cacher) | |
103 def Func(): | |
104 return 2 # pragma: no cover. | |
105 | |
106 self.assertEqual(1, Func()) | |
107 self.assertEqual({'n-Func': 1}, cacher.cached_data) | |
108 | |
109 def testCachedDecoratorWhenResultIsNotCachedYet(self): | |
110 cacher = _DummyCacher({}) | |
111 | |
112 @cache_decorator.Cached( | |
113 namespace='n', key_generator=_DummyKeyGenerator, cacher=cacher) | |
114 def Func(): | |
115 return 2 | |
116 | |
117 self.assertEqual(2, Func()) | |
118 self.assertEqual({'n-Func': 2}, cacher.cached_data) | |
119 | |
120 def testCachedDecoratorWhenResultShouldNotBeCached(self): | |
121 cacher = _DummyCacher({}) | |
122 | |
123 results = [None, 0, [], {}, ''] | |
124 | |
125 @cache_decorator.Cached( | |
126 namespace='n', key_generator=_DummyKeyGenerator, cacher=cacher) | |
127 def Func(): | |
128 return results.pop() | |
129 | |
130 self.assertEqual('', Func()) | |
131 self.assertEqual({}, cacher.cached_data) | |
132 self.assertEqual({}, Func()) | |
133 self.assertEqual({}, cacher.cached_data) | |
134 self.assertEqual([], Func()) | |
135 self.assertEqual({}, cacher.cached_data) | |
136 self.assertEqual(0, Func()) | |
137 self.assertEqual({}, cacher.cached_data) | |
138 self.assertIsNone(Func()) | |
139 self.assertEqual({}, cacher.cached_data) | |
140 | |
141 def testCachedDecoratorWithMethodInAClass(self): | |
142 class A(object): | |
143 def __init__(self, url, retries): | |
144 self.url = url | |
145 self.retries = retries | |
146 self.runs = 0 | |
147 | |
148 @property | |
149 def identifier(self): | |
150 return self.url | |
151 | |
152 @cache_decorator.Cached() | |
153 def Func(self, path): | |
154 self.runs += 1 | |
155 return self.url + '/' + path | |
156 | |
157 a1 = A('http://test', 3) | |
158 self.assertEqual('http://test/p1', a1.Func('p1')) | |
159 self.assertEqual('http://test/p1', a1.Func('p1')) | |
160 self.assertEqual(1, a1.runs) | |
161 | |
162 a2 = A('http://test', 5) | |
163 self.assertEqual('http://test/p1', a2.Func('p1')) | |
164 self.assertEqual(0, a2.runs) | |
OLD | NEW |