[jboss-cvs] JBossCache/tests/functional/org/jboss/cache/api ...

[Brian Stansberry]

  User: bstansberry
  Date: 06/11/06 15:08:25

  Added:       tests/functional/org/jboss/cache/api  CacheSPITest.java
  Log:
  Add simple tests of membership list / coordinator role
  
  Revision  Changes    Path
  1.1      date: 2006/11/06 20:08:25;  author: bstansberry;  state: Exp;JBossCache/tests/functional/org/jboss/cache/api/CacheSPITest.java
  
  Index: CacheSPITest.java
  ===================================================================
  package org.jboss.cache.api;
  
  import java.util.List;
  
  import org.jboss.cache.CacheSPI;
  import org.jboss.cache.config.Configuration;
  import org.jboss.cache.factories.DefaultCacheFactory;
  import org.jboss.cache.factories.XmlConfigurationParser;
  
  import junit.framework.TestCase;
  
  public class CacheSPITest extends TestCase
  {
     public void testGetMembers() throws Exception
     {
        XmlConfigurationParser parser = new XmlConfigurationParser();
        Configuration conf1 = parser.parseFile("META-INF/replSync-service.xml");
  
        Configuration conf2 = parser.parseFile("META-INF/replSync-service.xml");
        
        CacheSPI cache1 = (CacheSPI) DefaultCacheFactory.createCache(conf1, false);
        CacheSPI cache2 = (CacheSPI) DefaultCacheFactory.createCache(conf2, false);
        
        cache1.start();
        List memb1 = cache1.getMembers();
        assertEquals("View has one member", 1, memb1.size());
        
        Object coord = memb1.get(0);
        
        cache2.start();
        memb1 = cache1.getMembers();      
        List memb2 = cache2.getMembers();
        assertEquals("View has two members", 2, memb1.size());
        assertEquals("Both caches have same view", memb1, memb2);
        
        cache1.stop();
        memb2 = cache2.getMembers();
        assertEquals("View has one member", 1, memb2.size());
        assertFalse("Coordinator changed", coord.equals(memb2.get(0)));
     }
     
     public void testIsCoordinator() throws Exception
     {
        XmlConfigurationParser parser = new XmlConfigurationParser();
        Configuration conf1 = parser.parseFile("META-INF/replSync-service.xml");
  
        Configuration conf2 = parser.parseFile("META-INF/replSync-service.xml");
        
        CacheSPI cache1 = (CacheSPI) DefaultCacheFactory.createCache(conf1, false);
        CacheSPI cache2 = (CacheSPI) DefaultCacheFactory.createCache(conf2, false);
        
        cache1.start();
        assertTrue("Cache1 is coordinator", cache1.getRPCManager().isCoordinator());
        
        cache2.start();
        assertTrue("Cache1 is still coordinator", cache1.getRPCManager().isCoordinator());
        assertFalse("Cache2 is not coordinator", cache2.getRPCManager().isCoordinator());
        
        cache1.stop();
        assertTrue("Cache2 is coordinator", cache2.getRPCManager().isCoordinator());
        
     }
  }