112113114115116117118119120121122
initC2(key); f = c1.putAsync(key, v2); assert f != null; assert !f.isDone(); assert c2.get(key).equals(v); key.allowSerialization(); assert !f.isCancelled(); assert f.get().equals(v); assert f.isDone(); assertInvalidated(key, v2);
124125126127128129130131132133134
initC2(key); Future<Void> f2 = c1.putAllAsync(Collections.singletonMap(key, v3)); assert f2 != null; assert !f2.isDone(); assert c2.get(key).equals(v); key.allowSerialization(); assert !f2.isCancelled(); assert f2.get() == null; assert f2.isDone(); assertInvalidated(key, v3);
145146147148149150151152153154155
initC2(key); f = c1.removeAsync(key); assert f != null; assert !f.isDone(); assert c2.get(key).equals(v); key.allowSerialization(); assert !f.isCancelled(); assert f.get().equals(v3); assert f.isDone(); assertInvalidated(key, null);
157158159160161162163164165166167
initC2(key); f = c1.putIfAbsentAsync(key, v4); assert f != null; assert !f.isDone(); assert c2.get(key).equals(v); key.allowSerialization(); assert !f.isCancelled(); assert f.get() == null; assert f.isDone(); assertInvalidated(key, v4);
176177178179180181182183184185186
f3 = c1.removeAsync(key, v4); assert f3 != null; assert !f3.isDone(); assert c2.get(key).equals(v); key.allowSerialization(); assert !f3.isCancelled(); assert f3.get().equals(true); assert f3.isDone(); assertInvalidated(key, null);
191192193194195196197198199200201
assert !f.isCancelled(); assert f.get() == null; assert f.isDone(); assert c2.get(key).equals(v); key.allowSerialization(); resetListeners(); c1.put(key, v); asyncWait(); initC2(key);
201202203204205206207208209210211
initC2(key); f = c1.replaceAsync(key, v5); assert f != null; assert !f.isDone(); assert c2.get(key).equals(v); key.allowSerialization(); assert !f.isCancelled(); assert f.get().equals(v); assert f.isDone(); assertInvalidated(key, v5);
221222223224225226227228229230231
f3 = c1.replaceAsync(key, v5, v6); assert f3 != null; assert !f3.isDone(); assert c2.get(key).equals(v); key.allowSerialization(); assert !f3.isCancelled(); assert f3.get().equals(true); assert f3.isDone(); assertInvalidated(key, v6); }