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 package org.eclipse.jgit.internal.storage.dfs;
45
46 import static org.eclipse.jgit.lib.Constants.OBJ_BLOB;
47 import static org.junit.Assert.assertEquals;
48 import static org.junit.Assert.assertNotNull;
49 import static org.junit.Assert.assertNull;
50 import static org.junit.Assert.assertSame;
51
52 import org.eclipse.jgit.internal.storage.dfs.DeltaBaseCache.Entry;
53 import org.eclipse.jgit.junit.TestRng;
54 import org.junit.Before;
55 import org.junit.Test;
56
57 public class DeltaBaseCacheTest {
58 private static final int SZ = 512;
59
60 private DfsStreamKey key;
61 private DeltaBaseCache cache;
62 private TestRng rng;
63
64 @Before
65 public void setUp() {
66 DfsRepositoryDescription repo = new DfsRepositoryDescription("test");
67 key = DfsStreamKey.of(repo, "test.key", null);
68 cache = new DeltaBaseCache(SZ);
69 rng = new TestRng(getClass().getSimpleName());
70 }
71
72 @Test
73 public void testObjectLargerThanCacheDoesNotEvict() {
74 byte[] obj12 = put(12, 32);
75 put(24, SZ + 5);
76 assertNull("does not store large object", cache.get(key, 24));
77 get(obj12, 12);
78 }
79
80 @Test
81 public void testCacheLruExpires1() {
82 byte[] obj1 = put(1, SZ / 4);
83 put(2, SZ / 4);
84 byte[] obj3 = put(3, SZ / 4);
85 put(4, SZ / 4);
86 assertEquals(SZ, cache.getMemoryUsed());
87
88 get(obj3, 3);
89 get(obj1, 1);
90 put(5, SZ / 2);
91 assertEquals(SZ, cache.getMemoryUsed());
92 assertEquals(SZ, cache.getMemoryUsedByTableForTest());
93 assertEquals(SZ, cache.getMemoryUsedByLruChainForTest());
94 assertNull(cache.get(key, 4));
95 assertNull(cache.get(key, 2));
96
97 get(obj1, 1);
98 get(obj3, 3);
99 }
100
101 @Test
102 public void testCacheLruExpires2() {
103 int pos0 = (0 << 10) | 2;
104 int pos1 = (1 << 10) | 2;
105 int pos2 = (2 << 10) | 2;
106 int pos5 = (5 << 10) | 2;
107 int pos6 = (6 << 10) | 2;
108
109 put(pos0, SZ / 4);
110 put(pos5, SZ / 4);
111 byte[] obj1 = put(pos1, SZ / 4);
112 byte[] obj2 = put(pos2, SZ / 4);
113 assertEquals(SZ, cache.getMemoryUsed());
114
115 byte[] obj6 = put(pos6, SZ / 2);
116 assertEquals(SZ, cache.getMemoryUsed());
117 assertEquals(SZ, cache.getMemoryUsedByTableForTest());
118 assertEquals(SZ, cache.getMemoryUsedByLruChainForTest());
119 assertNull(cache.get(key, pos0));
120 assertNull(cache.get(key, pos5));
121
122 get(obj1, pos1);
123 get(obj2, pos2);
124 get(obj6, pos6);
125 }
126
127 @Test
128 public void testCacheMemoryUsedConsistentWithExpectations() {
129 put(1, 32);
130 put(2, 32);
131 put(3, 32);
132
133 assertNotNull(cache.get(key, 1));
134 assertNotNull(cache.get(key, 1));
135
136 assertEquals(32 * 3, cache.getMemoryUsed());
137 assertEquals(32 * 3, cache.getMemoryUsedByTableForTest());
138 assertEquals(32 * 3, cache.getMemoryUsedByLruChainForTest());
139 }
140
141 private void get(byte[] data, int position) {
142 Entry e = cache.get(key, position);
143 assertNotNull("expected entry at " + position, e);
144 assertEquals("expected blob for " + position, OBJ_BLOB, e.type);
145 assertSame("expected data for " + position, data, e.data);
146 }
147
148 private byte[] put(int position, int sz) {
149 byte[] data = rng.nextBytes(sz);
150 cache.put(key, position, OBJ_BLOB, data);
151 return data;
152 }
153 }