128 }
129
130 @Test
131 public void testArrayOffHeapDirect() {
132 int size = 10;
133 long address = UNSAFE.allocateMemory(size << ARRAY_SHIFT);
134 try {
135 for (int c = 0; c < ITERS; c++) {
136 for (int i = 0; i < size; i++) {
137 testAccess((((long) i) << ARRAY_SHIFT) + address);
138 }
139 }
140 } finally {
141 UNSAFE.freeMemory(address);
142 }
143 }
144
145 static void testAccess(Object base, long offset) {
146 // Plain
147 {
148 UNSAFE.putInt(base, offset, 1);
149 int x = UNSAFE.getInt(base, offset);
150 assertEquals(x, 1, "set int value");
151 }
152
153 // Volatile
154 {
155 UNSAFE.putIntVolatile(base, offset, 2);
156 int x = UNSAFE.getIntVolatile(base, offset);
157 assertEquals(x, 2, "putVolatile int value");
158 }
159
160 // Lazy
161 {
162 UNSAFE.putOrderedInt(base, offset, 1);
163 int x = UNSAFE.getIntVolatile(base, offset);
164 assertEquals(x, 1, "putRelease int value");
165 }
166
167
168
169 UNSAFE.putInt(base, offset, 1);
170
171 // Compare
172 {
173 boolean r = UNSAFE.compareAndSwapInt(base, offset, 1, 2);
174 assertEquals(r, true, "success compareAndSwap int");
175 int x = UNSAFE.getInt(base, offset);
176 assertEquals(x, 2, "success compareAndSwap int value");
177 }
178
179 {
180 boolean r = UNSAFE.compareAndSwapInt(base, offset, 1, 3);
181 assertEquals(r, false, "failing compareAndSwap int");
182 int x = UNSAFE.getInt(base, offset);
183 assertEquals(x, 2, "failing compareAndSwap int value");
184 }
185
186 UNSAFE.putInt(base, offset, 2);
187
188 // Compare set and get
189 {
190 int o = UNSAFE.getAndSetInt(base, offset, 1);
191 assertEquals(o, 2, "getAndSet int");
192 int x = UNSAFE.getInt(base, offset);
193 assertEquals(x, 1, "getAndSet int value");
194 }
195
196 UNSAFE.putInt(base, offset, 1);
197
198 // get and add, add and get
199 {
200 int o = UNSAFE.getAndAddInt(base, offset, 2);
201 assertEquals(o, 1, "getAndAdd int");
202 int x = UNSAFE.getInt(base, offset);
203 assertEquals(x, 1 + 2, "getAndAdd int");
204 }
205 }
206
207 static void testAccess(long address) {
208 // Plain
209 {
210 UNSAFE.putInt(address, 1);
211 int x = UNSAFE.getInt(address);
212 assertEquals(x, 1, "set int value");
213 }
214 }
215 }
216
|
128 }
129
130 @Test
131 public void testArrayOffHeapDirect() {
132 int size = 10;
133 long address = UNSAFE.allocateMemory(size << ARRAY_SHIFT);
134 try {
135 for (int c = 0; c < ITERS; c++) {
136 for (int i = 0; i < size; i++) {
137 testAccess((((long) i) << ARRAY_SHIFT) + address);
138 }
139 }
140 } finally {
141 UNSAFE.freeMemory(address);
142 }
143 }
144
145 static void testAccess(Object base, long offset) {
146 // Plain
147 {
148 UNSAFE.putInt(base, offset, 0x01234567);
149 int x = UNSAFE.getInt(base, offset);
150 assertEquals(x, 0x01234567, "set int value");
151 }
152
153 // Volatile
154 {
155 UNSAFE.putIntVolatile(base, offset, 0x89ABCDEF);
156 int x = UNSAFE.getIntVolatile(base, offset);
157 assertEquals(x, 0x89ABCDEF, "putVolatile int value");
158 }
159
160 // Lazy
161 {
162 UNSAFE.putOrderedInt(base, offset, 0x01234567);
163 int x = UNSAFE.getIntVolatile(base, offset);
164 assertEquals(x, 0x01234567, "putRelease int value");
165 }
166
167
168
169 UNSAFE.putInt(base, offset, 0x01234567);
170
171 // Compare
172 {
173 boolean r = UNSAFE.compareAndSwapInt(base, offset, 0x01234567, 0x89ABCDEF);
174 assertEquals(r, true, "success compareAndSwap int");
175 int x = UNSAFE.getInt(base, offset);
176 assertEquals(x, 0x89ABCDEF, "success compareAndSwap int value");
177 }
178
179 {
180 boolean r = UNSAFE.compareAndSwapInt(base, offset, 0x01234567, 0xCAFEBABE);
181 assertEquals(r, false, "failing compareAndSwap int");
182 int x = UNSAFE.getInt(base, offset);
183 assertEquals(x, 0x89ABCDEF, "failing compareAndSwap int value");
184 }
185
186 UNSAFE.putInt(base, offset, 0x89ABCDEF);
187
188 // Compare set and get
189 {
190 int o = UNSAFE.getAndSetInt(base, offset, 0x01234567);
191 assertEquals(o, 0x89ABCDEF, "getAndSet int");
192 int x = UNSAFE.getInt(base, offset);
193 assertEquals(x, 0x01234567, "getAndSet int value");
194 }
195
196 UNSAFE.putInt(base, offset, 0x01234567);
197
198 // get and add, add and get
199 {
200 int o = UNSAFE.getAndAddInt(base, offset, 0x89ABCDEF);
201 assertEquals(o, 0x01234567, "getAndAdd int");
202 int x = UNSAFE.getInt(base, offset);
203 assertEquals(x, (int)(0x01234567 + 0x89ABCDEF), "getAndAdd int");
204 }
205 }
206
207 static void testAccess(long address) {
208 // Plain
209 {
210 UNSAFE.putInt(address, 0x01234567);
211 int x = UNSAFE.getInt(address);
212 assertEquals(x, 0x01234567, "set int value");
213 }
214 }
215 }
216
|