<html><head><meta http-equiv="Content-Type" content="text/html charset=us-ascii"></head><body style="word-wrap: break-word; -webkit-nbsp-mode: space; -webkit-line-break: after-white-space; ">After fixing that ISPN-2253:<div>*&nbsp;<a href="https://github.com/alesj/infinispan/commit/05229f426e829742902de0305488282b8283b8e5">https://github.com/alesj/infinispan/commit/05229f426e829742902de0305488282b8283b8e5</a></div><div>(Sanne is working on even cleaner solution)</div><div><br></div><div>It now also looks like our CapeDwarf clustering tests have been (almost) fixed.</div><div>It now appears as if one node cannot do proper querying:</div><div><br></div><div>Deployment dep1 goes to node1, same deployment dep2 goes to node2.</div><div><br></div><div>"Failed tests: &nbsp; queryOnA(org.jboss.test.capedwarf.cluster.DatastoreTestCase): Number of entities: 0"</div><div><br></div><div>Where as "queryOnB" doesn't fail.</div><div><br></div><div>@Sanne -- do we have any query tests covering this kind of scenario?</div><div><br></div><div>I'm using jgroups' auto-master selection.</div><div><br></div><div>Tomorrow I'll try fixed jgroups master/slave selection,</div><div>and the new dynamic auto-master selection.</div><div><br></div><div>Any ideas still welcome. ;-)</div><div><br></div><div>-Ales</div><div><br></div><div>---</div><div><br></div><div><div>&nbsp; &nbsp; @InSequence(30)</div><div>&nbsp; &nbsp; @Test</div><div>&nbsp; &nbsp; @OperateOnDeployment("dep1")</div><div>&nbsp; &nbsp; public void putStoresEntityOnDepA() throws Exception {</div><div>&nbsp; &nbsp; &nbsp; &nbsp; Entity entity = createTestEntity("KIND", 1);</div><div>&nbsp; &nbsp; &nbsp; &nbsp; getService().put(entity);</div><div>&nbsp; &nbsp; &nbsp; &nbsp; assertStoreContains(entity);</div><div>&nbsp; &nbsp; }</div><div><br></div><div>&nbsp; &nbsp; @InSequence(31)</div><div>&nbsp; &nbsp; @Test</div><div>&nbsp; &nbsp; @OperateOnDeployment("dep2")</div><div>&nbsp; &nbsp; public void putStoresEntityOnDepB() throws Exception {</div><div>&nbsp; &nbsp; &nbsp; &nbsp; Entity entity = createTestEntity("KIND", 2);</div><div>&nbsp; &nbsp; &nbsp; &nbsp; getService().put(entity);</div><div>&nbsp; &nbsp; &nbsp; &nbsp; assertStoreContains(entity);</div><div>&nbsp; &nbsp; }</div><div><br></div><div>&nbsp; &nbsp; @InSequence(40)</div><div>&nbsp; &nbsp; @Test</div><div>&nbsp; &nbsp; @OperateOnDeployment("dep1")</div><div>&nbsp; &nbsp; public void getEntityOnDepA() throws Exception {</div><div>&nbsp; &nbsp; &nbsp; &nbsp; waitForSync();</div><div><br></div><div>&nbsp; &nbsp; &nbsp; &nbsp; Key key = KeyFactory.createKey("KIND", 1);</div><div>&nbsp; &nbsp; &nbsp; &nbsp; Entity lookup = getService().get(key);</div><div><br></div><div>&nbsp; &nbsp; &nbsp; &nbsp; Assert.assertNotNull(lookup);</div><div><br></div><div>&nbsp; &nbsp; &nbsp; &nbsp; Entity entity = createTestEntity("KIND", 1);</div><div>&nbsp; &nbsp; &nbsp; &nbsp; Assert.assertEquals(entity, lookup);</div><div>&nbsp; &nbsp; }</div><div><br></div><div>&nbsp; &nbsp; @InSequence(50)</div><div>&nbsp; &nbsp; @Test</div><div>&nbsp; &nbsp; @OperateOnDeployment("dep2")</div><div>&nbsp; &nbsp; public void getEntityOnDepB() throws Exception {</div><div>&nbsp; &nbsp; &nbsp; &nbsp; waitForSync();</div><div><br></div><div>&nbsp; &nbsp; &nbsp; &nbsp; Entity entity = createTestEntity("KIND", 1);</div><div>&nbsp; &nbsp; &nbsp; &nbsp; assertStoreContains(entity);</div><div>&nbsp; &nbsp; }</div><div><br></div><div>&nbsp; &nbsp; @InSequence(52)</div><div>&nbsp; &nbsp; @Test</div><div>&nbsp; &nbsp; @OperateOnDeployment("dep1")</div><div>&nbsp; &nbsp; public void queryOnA() throws Exception {</div><div>&nbsp; &nbsp; &nbsp; &nbsp; waitForSync();</div><div><br></div><div>&nbsp; &nbsp; &nbsp; &nbsp; int count = getService().prepare(new Query("KIND")).countEntities(Builder.withDefaults());</div><div>&nbsp; &nbsp; &nbsp; &nbsp; Assert.assertTrue("Number of entities: " + count, count == 2);</div><div>&nbsp; &nbsp; }</div><div><br></div><div>&nbsp; &nbsp; @InSequence(53)</div><div>&nbsp; &nbsp; @Test</div><div>&nbsp; &nbsp; @OperateOnDeployment("dep2")</div><div>&nbsp; &nbsp; public void queryOnB() throws Exception {</div><div>&nbsp; &nbsp; &nbsp; &nbsp; waitForSync();</div><div><br></div><div>&nbsp; &nbsp; &nbsp; &nbsp; int count = getService().prepare(new Query("KIND")).countEntities(Builder.withDefaults());</div><div>&nbsp; &nbsp; &nbsp; &nbsp; Assert.assertTrue("Number of entities: " + count, count == 2);</div><div>&nbsp; &nbsp; }</div></div><div><br></div></body></html>