[jboss-cvs] JBossCache/tests-50/functional/org/jboss/cache/pojo/integrated ...
Ben Wang
bwang at jboss.com
Mon Jul 17 10:41:28 EDT 2006
User: bwang
Date: 06/07/17 10:41:28
Added: tests-50/functional/org/jboss/cache/pojo/integrated
NetworkManagementTest.java
PropagationManagerlTest.java
ReplicatedNetworkManagementTest.java
ReplicatedPropagationManagerlTest.java
Removed: tests-50/functional/org/jboss/cache/pojo/integrated
NetworkManagementAopTest.java
PropagationManagerlAopTest.java
ReplicatedNetworkManagementAopTest.java
ReplicatedPropagationManagerlAopTest.java
Log:
Name changes
Revision Changes Path
1.1 date: 2006/07/17 14:41:28; author: bwang; state: Exp;JBossCache/tests-50/functional/org/jboss/cache/pojo/integrated/NetworkManagementTest.java
Index: NetworkManagementTest.java
===================================================================
package org.jboss.cache.pojo.integrated;
import junit.framework.Test;
import junit.framework.TestCase;
import junit.framework.TestSuite;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.jboss.cache.pojo.PojoCache;
import org.jboss.cache.pojo.PojoCacheFactory;
import org.jboss.cache.pojo.test.NetworkAdmin;
import org.jboss.cache.pojo.test.NetworkDomain;
import org.jboss.cache.pojo.test.NetworkElement;
import org.jboss.cache.pojo.test.NetworkNode;
import java.util.List;
/**
* Sample example for network management that consists of fine-grained replication and object graph (including
* Collection)
* <p>Specifically, it illustrates the following object relationship:
* <ul>
* <li>Multiple referece, e.g., shared sub-objects (Domain may share DataNode)</li>
* <li>Recursive, e.g., parent-child relationship (DataNode and Element)</li>
* </ul>
*
* @author Ben Wang
*/
public class NetworkManagementTest extends TestCase
{
Log log = LogFactory.getLog(NetworkManagementTest.class);
PojoCache cache1;
public NetworkManagementTest(String name)
{
super(name);
}
protected void setUp() throws Exception
{
super.setUp();
log.info("setUp() ....");
cache1 = createCache("CacheGroup");
}
protected void tearDown() throws Exception
{
super.tearDown();
cache1.getCache().remove("/");
cache1.stop();
}
private PojoCache createCache(String name) throws Exception
{
String configFile = "META-INF/replSync-service.xml";
PojoCache cache = PojoCacheFactory.createInstance(configFile);
cache.start();
return cache;
}
/**
* Domain shares Admin object.
*/
public void testDomainAndAdmin() throws Exception
{
NetworkAdmin admin = new NetworkAdmin();
admin.setId("Benny");
NetworkDomain tempSensorDomain = new NetworkDomain();
tempSensorDomain.setName("Temperature sensors");
tempSensorDomain.setAdmin(admin);
NetworkDomain vibSensorDomain = new NetworkDomain();
vibSensorDomain.setName("Vibration sensors");
vibSensorDomain.setAdmin(admin);
cache1.attach("/temp", tempSensorDomain);
cache1.attach("/vib", vibSensorDomain);
NetworkDomain d1 = (NetworkDomain) cache1.find("/temp");
NetworkDomain d2 = (NetworkDomain) cache1.find("/vib");
assertEquals("Admin should be the same", d1.getAdmin(), d2.getAdmin());
d2.getAdmin().setId("Wen");
assertEquals("New admin id is ", "Wen", d1.getAdmin().getId());
assertEquals("New admin id is ", "Wen", admin.getId());
NetworkDomain temp1 = (NetworkDomain) cache1.detach("/temp");
NetworkDomain vib1 = (NetworkDomain) cache1.detach("/vib");
assertEquals("Vibration sensor ", vibSensorDomain, vib1);
assertEquals("Temperature sensor ", tempSensorDomain, temp1);
}
/**
* Domain shares Admin object, domain also contains a list of Nodes, and each DataNode has sensor elements
*/
public void testNodeAndElement() throws Exception
{
// Construct nodes
NetworkNode taipei = new NetworkNode();
taipei.setName("Taipei machine");
taipei.setIpAddress("192.168.1.100");
NetworkNode tainan = new NetworkNode();
tainan.setName("Tainan machine");
tainan.setIpAddress("192.168.1.200");
// Contruct sensor elements
NetworkElement vibSensor1 = new NetworkElement();
vibSensor1.setName("Vibration sensor V10");
NetworkElement vibSensor2 = new NetworkElement();
vibSensor2.setName("Vibration sensor V20");
NetworkElement tempSensor1 = new NetworkElement();
tempSensor1.setName("Temperature sensor T10");
NetworkElement tempSensor2 = new NetworkElement();
tempSensor2.setName("Temperature sensor T20");
// Add sensor element to DataNode
taipei.addElement(vibSensor1);
taipei.addElement(tempSensor1);
tainan.addElement(vibSensor2);
tainan.addElement(tempSensor2);
assertEquals("Element size ", 2, taipei.getElements().size());
// ask cache to manage the domains
cache1.attach("/taipei", taipei);
cache1.attach("/tainan", tainan);
NetworkNode taipei1 = (NetworkNode) cache1.find("/taipei");
NetworkNode tainan1 = (NetworkNode) cache1.find("/tainan");
taipei1.setIpAddress("192.168.10.100");
assertEquals("New admin id is ", "192.168.10.100", taipei.getIpAddress());
List l2 = taipei1.getElements();
assertEquals("Size is ", 2, l2.size());
NetworkElement vibSens1 = (NetworkElement) l2.get(0);
NetworkElement tempSens1 = (NetworkElement) l2.get(1);
int SUSPENDED = 2;
vibSens1.setStatus(SUSPENDED);
tempSens1.setStatus(SUSPENDED);
assertEquals("Status ", vibSensor1.getStatus(), vibSens1.getStatus());
assertEquals("Status ", tempSensor1.getStatus(), tempSens1.getStatus());
}
/**
* Domain shares Admin object, domain also contains a list of Nodes, and each DataNode has sensor elements
*/
public void testSharedNodeAndElement() throws Exception
{
// Construct nodes
NetworkNode taipei = new NetworkNode();
taipei.setName("Taipei machine");
taipei.setIpAddress("192.168.1.100");
NetworkNode tainan = new NetworkNode();
tainan.setName("Tainan machine");
tainan.setIpAddress("192.168.1.200");
// Contruct sensor elements
NetworkElement vibSensor1 = new NetworkElement();
vibSensor1.setName("Vibration sensor V10");
NetworkElement vibSensor2 = new NetworkElement();
vibSensor2.setName("Vibration sensor V20");
NetworkElement tempSensor1 = new NetworkElement();
tempSensor1.setName("Temperature sensor T10");
NetworkElement tempSensor2 = new NetworkElement();
tempSensor2.setName("Temperature sensor T20");
// Add sensor element to DataNode
taipei.addElement(vibSensor1);
taipei.addElement(tempSensor1);
tainan.addElement(vibSensor2);
tainan.addElement(tempSensor2);
assertEquals("Element size ", 2, taipei.getElements().size());
// ask cache to manage the domains
cache1.attach("/taipei", taipei);
cache1.attach("/alias", taipei);
NetworkNode taipei1 = (NetworkNode) cache1.find("/taipei");
NetworkNode taipei2 = (NetworkNode) cache1.find("/alias");
taipei1.setIpAddress("192.168.10.100");
assertEquals("New admin id is ", "192.168.10.100", taipei.getIpAddress());
List l2 = taipei2.getElements();
assertEquals("Size is ", 2, l2.size());
NetworkElement vibSens1 = (NetworkElement) l2.get(0);
NetworkElement tempSens1 = (NetworkElement) l2.get(1);
int SUSPENDED = 2;
vibSens1.setStatus(SUSPENDED);
tempSens1.setStatus(SUSPENDED);
assertEquals("Status ", vibSensor1.getStatus(), vibSens1.getStatus());
assertEquals("Status ", tempSensor1.getStatus(), tempSens1.getStatus());
}
/**
* Domain shares Admin object, domain also contains a list of Nodes, and each DataNode has sensor elements
*/
public void testRecursive() throws Exception
{
NetworkAdmin admin = new NetworkAdmin();
admin.setId("Benny");
// Construct domains
NetworkDomain tempSensorDomain = new NetworkDomain();
tempSensorDomain.setName("Temperature sensors");
tempSensorDomain.setAdmin(admin);
NetworkDomain vibSensorDomain = new NetworkDomain();
vibSensorDomain.setName("Vibration sensors");
vibSensorDomain.setAdmin(admin);
// Construct nodes
NetworkNode taipei = new NetworkNode();
taipei.setName("Taipei machine");
taipei.setIpAddress("192.168.1.100");
NetworkNode tainan = new NetworkNode();
tainan.setName("Tainan machine");
tainan.setIpAddress("192.168.1.200");
// Contruct sensor elements
NetworkElement vibSensor1 = new NetworkElement();
vibSensor1.setName("Vibration sensor V10");
NetworkElement vibSensor2 = new NetworkElement();
vibSensor2.setName("Vibration sensor V20");
NetworkElement tempSensor1 = new NetworkElement();
tempSensor1.setName("Temperature sensor T10");
NetworkElement tempSensor2 = new NetworkElement();
tempSensor2.setName("Temperature sensor T20");
// Add sensor element to DataNode
taipei.addElement(vibSensor1);
taipei.addElement(tempSensor1);
tainan.addElement(vibSensor2);
tainan.addElement(tempSensor2);
assertEquals("Element size ", 2, taipei.getElements().size());
// Add elements to domains
vibSensorDomain.addElement(vibSensor1);
vibSensorDomain.addElement(vibSensor2);
tempSensorDomain.addElement(tempSensor1);
tempSensorDomain.addElement(tempSensor2);
// ask cache to manage the domains
cache1.attach("/vib", vibSensorDomain);
// System.out.println(cache1.printDetails());
}
/**
* Domain shares Admin object, domain also contains a list of Nodes, and each DataNode has sensor elements
*/
public void testAll() throws Exception
{
// Construct domains
NetworkDomain tempSensorDomain = new NetworkDomain();
tempSensorDomain.setName("Temperature sensors");
NetworkDomain vibSensorDomain = new NetworkDomain();
vibSensorDomain.setName("Vibration sensors");
// Construct nodes
NetworkNode taipei = new NetworkNode();
taipei.setName("Taipei machine");
taipei.setIpAddress("192.168.1.100");
NetworkNode tainan = new NetworkNode();
tainan.setName("Tainan machine");
tainan.setIpAddress("192.168.1.200");
// Contruct sensor elements
NetworkElement vibSensor1 = new NetworkElement();
vibSensor1.setName("Vibration sensor V10");
NetworkElement vibSensor2 = new NetworkElement();
vibSensor2.setName("Vibration sensor V20");
NetworkElement tempSensor1 = new NetworkElement();
tempSensor1.setName("Temperature sensor T10");
NetworkElement tempSensor2 = new NetworkElement();
tempSensor2.setName("Temperature sensor T20");
// Add sensor element to DataNode
taipei.addElement(vibSensor1);
taipei.addElement(tempSensor1);
tainan.addElement(vibSensor2);
tainan.addElement(tempSensor2);
assertEquals("Element size ", 2, taipei.getElements().size());
// Add elements to domains
vibSensorDomain.addElement(vibSensor1);
vibSensorDomain.addElement(vibSensor2);
tempSensorDomain.addElement(tempSensor1);
tempSensorDomain.addElement(tempSensor2);
// ask cache to manage the domains
cache1.attach("/vib", vibSensorDomain);
cache1.attach("/temp", tempSensorDomain);
NetworkDomain temp1 = (NetworkDomain) cache1.find("/temp");
NetworkDomain vib1 = (NetworkDomain) cache1.find("/vib");
NetworkNode taipei1 = (NetworkNode) temp1.getNodes().get(0);
// NetworkNode taipei1 = (NetworkNode)temp1.getNodes().get(1); this would fail on equality
NetworkNode taipei2 = (NetworkNode) vib1.getNodes().get(0);
List l1 = temp1.getNodes();
assertEquals("Size is ", 2, l1.size());
l1 = taipei.getElements();
assertEquals("Size is ", 2, l1.size());
assertEquals("IPAddress ", taipei.getIpAddress(), taipei1.getIpAddress());
assertTrue("DataNode should be the same", (taipei1 == taipei2));
taipei2.setIpAddress("192.168.10.100");
assertEquals("New admin id is ", "192.168.10.100", taipei.getIpAddress());
List l2 = taipei1.getElements();
assertEquals("Size is ", 2, l2.size());
NetworkElement vibSens1 = (NetworkElement) l2.get(0);
NetworkElement tempSens1 = (NetworkElement) l2.get(1);
int SUSPENDED = 2;
vibSens1.setStatus(SUSPENDED);
tempSens1.setStatus(SUSPENDED);
assertEquals("Status ", vibSensor1.getStatus(), vibSens1.getStatus());
assertEquals("Status ", tempSensor1.getStatus(), tempSens1.getStatus());
}
public static Test suite() throws Exception
{
return new TestSuite(NetworkManagementTest.class);
}
public static void main(String[] args) throws Exception
{
junit.textui.TestRunner.run(suite());
}
}
1.1 date: 2006/07/17 14:41:28; author: bwang; state: Exp;JBossCache/tests-50/functional/org/jboss/cache/pojo/integrated/PropagationManagerlTest.java
Index: PropagationManagerlTest.java
===================================================================
package org.jboss.cache.pojo.integrated;
import junit.framework.TestCase;
import org.jboss.cache.pojo.PojoCache;
import org.jboss.cache.pojo.PojoCacheFactory;
import org.jboss.cache.pojo.test.propagation.PropagationManager;
import org.jboss.cache.pojo.test.propagation.impl.PropagationManagerImpl;
public class PropagationManagerlTest extends TestCase
{
private PropagationManager pm_;
private PojoCache cache_;
protected void setUp() throws Exception
{
cache_ = createCache("TestCluster");
}
protected void tearDown() throws Exception
{
cache_.getCache().remove("/");
cache_.stop();
}
private PojoCache createCache(String name) throws Exception
{
String configFile = "META-INF/replSync-service.xml";
PojoCache cache = PojoCacheFactory.createInstance(configFile);
cache.start();
return cache;
}
protected void initSimplifiedPm()
{
pm_ = new PropagationManagerImpl();
pm_.setRootNode("root");
pm_.addNode("root", "kanto");
pm_.addNode("root.kanto", "tokyo");
pm_.addStateItem("root.kanto.tokyo", 1000, 1040);
pm_.addNode("root.kanto", "kanagawa");
/*
pm_.addStateItem("root.kanto.tokyo", 1001, 1040);
pm_.addStateItem("root.kanto.tokyo", 1002, 1040);
pm_.addNode("root.kanto.tokyo", "shinjuku");
pm_.addStateItem("root.kanto.tokyo.shinjuku", 1000, 1040);
pm_.addStateItem("root.kanto.tokyo.shinjuku", 1001, 1040);
pm_.addStateItem("root.kanto.tokyo.shinjuku", 1002, 1040);
pm_.addNode("root.kanto.kanagawa", "kawasaki");
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1005, 1040);
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1006, 1040);
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1007, 1030);
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("Initial pm state");
System.out.println("---------------------------------------------");
pm_.printNodes();
*/
}
public void testSimplified() throws Exception
{
initSimplifiedPm();
// Put pm into cache management first
cache_.attach("/propagation", pm_);
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("Initial cache content");
System.out.println("---------------------------------------------");
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("root.kanto.kanagawa.kawasaki:1007 1030->1031");
System.out.println("---------------------------------------------");
pm_.stateChange("root.kanto.kanagawa.kawasaki", 1007, 1031);
pm_.printNodes();
/*
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("Final cache content");
System.out.println(cache_.printDetails());
System.out.println("---------------------------------------------");
*/
}
protected void initPm()
{
pm_ = new PropagationManagerImpl();
pm_.setRootNode("root");
pm_.addNode("root", "kanto");
pm_.addNode("root.kanto", "tokyo");
pm_.addStateItem("root.kanto.tokyo", 1000, 1040);
pm_.addStateItem("root.kanto.tokyo", 1001, 1040);
pm_.addStateItem("root.kanto.tokyo", 1002, 1040);
pm_.addNode("root.kanto.tokyo", "shinjuku");
pm_.addStateItem("root.kanto.tokyo.shinjuku", 1000, 1040);
pm_.addStateItem("root.kanto.tokyo.shinjuku", 1001, 1040);
pm_.addStateItem("root.kanto.tokyo.shinjuku", 1002, 1040);
pm_.addNode("root.kanto", "kanagawa");
pm_.addNode("root.kanto.kanagawa", "kawasaki");
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1005, 1040);
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1006, 1040);
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1007, 1030);
}
public void testPropagation() throws Exception
{
initPm();
// Put pm into cache management first
cache_.attach("/propagation", pm_);
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("Initial cache content");
System.out.println("---------------------------------------------");
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("Initial pm state");
System.out.println("---------------------------------------------");
pm_.printNodes();
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("root.kanto.kanagawa.kawasaki:1007 1030->1031");
System.out.println("---------------------------------------------");
pm_.stateChange("root.kanto.kanagawa.kawasaki", 1007, 1031);
pm_.printNodes();
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("root.kanto.tokyo.shinjuku:1001 1040->1041");
System.out.println("---------------------------------------------");
pm_.stateChange("root.kanto.tokyo.shinjuku", 1001, 1041);
pm_.printNodes();
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("root.kanto.kanagawa.kawasaki:1006 1040->1041");
System.out.println("---------------------------------------------");
pm_.stateChange("root.kanto.kanagawa.kawasaki", 1006, 1041);
pm_.printNodes();
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("add new item to root.kanto.kanagawa.kawasaki:1008 default:1021");
System.out.println("---------------------------------------------");
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1008, 1021);
pm_.printNodes();
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("Final cache content");
System.out.println("---------------------------------------------");
}
public static void main(String[] args) throws Exception
{
PropagationManagerlTest pmTest = new PropagationManagerlTest();
pmTest.setUp();
pmTest.testPropagation();
}
}
1.1 date: 2006/07/17 14:41:28; author: bwang; state: Exp;JBossCache/tests-50/functional/org/jboss/cache/pojo/integrated/ReplicatedNetworkManagementTest.java
Index: ReplicatedNetworkManagementTest.java
===================================================================
package org.jboss.cache.pojo.integrated;
import junit.framework.Test;
import junit.framework.TestCase;
import junit.framework.TestSuite;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.jboss.cache.pojo.PojoCache;
import org.jboss.cache.pojo.PojoCacheFactory;
import org.jboss.cache.pojo.test.NetworkAdmin;
import org.jboss.cache.pojo.test.NetworkDomain;
import org.jboss.cache.pojo.test.NetworkElement;
import org.jboss.cache.pojo.test.NetworkNode;
import java.util.List;
/**
* Sample example for network management that consists of fine-grained replication and object graph (including
* Collection)
* <p>Specifically, it illustrates the following object relationship:
* <ul>
* <li>Multiple referece, e.g., shared sub-objects (Domain may share DataNode)</li>
* <li>Recursive, e.g., parent-child relationship (DataNode and Element)</li>
* </ul>
*
* @author Ben Wang
*/
public class ReplicatedNetworkManagementTest extends TestCase
{
Log log = LogFactory.getLog(ReplicatedNetworkManagementTest.class);
PojoCache cache1;
PojoCache cache2;
public ReplicatedNetworkManagementTest(String name)
{
super(name);
}
protected void setUp() throws Exception
{
super.setUp();
log.info("setUp() ....");
cache1 = createCache("CacheGroup");
cache2 = createCache("CacheGroup");
}
protected void tearDown() throws Exception
{
super.tearDown();
cache1.getCache().remove("/");
cache1.stop();
cache2.stop();
}
private PojoCache createCache(String name) throws Exception
{
String configFile = "META-INF/replSync-service.xml";
PojoCache cache = PojoCacheFactory.createInstance(configFile);
cache.start();
return cache;
}
/**
* Domain shares Admin object.
*/
public void testDomainAndAdmin() throws Exception
{
NetworkAdmin admin = new NetworkAdmin();
admin.setId("Benny");
NetworkDomain tempSensorDomain = new NetworkDomain();
tempSensorDomain.setName("Temperature sensors");
tempSensorDomain.setAdmin(admin);
NetworkDomain vibSensorDomain = new NetworkDomain();
vibSensorDomain.setName("Vibration sensors");
vibSensorDomain.setAdmin(admin);
cache1.attach("/temp", tempSensorDomain);
cache1.attach("/vib", vibSensorDomain);
NetworkDomain d1 = (NetworkDomain) cache2.find("/temp");
NetworkDomain d2 = (NetworkDomain) cache2.find("/vib");
assertEquals("Admin should be the same", d1.getAdmin(), d2.getAdmin());
d2.getAdmin().setId("Wen");
assertEquals("New admin id is ", "Wen", d1.getAdmin().getId());
assertEquals("New admin id is ", "Wen", admin.getId());
d1 = (NetworkDomain) cache2.find("/vib");
d2 = (NetworkDomain) cache2.find("/temp");
assertEquals("Admin should be the same", d1.getAdmin(), d2.getAdmin());
d2.getAdmin().setId("Wen");
assertEquals("New admin id is ", "Wen", d1.getAdmin().getId());
assertEquals("New admin id is ", "Wen", admin.getId());
NetworkDomain temp1 = (NetworkDomain) cache1.detach("/temp");
NetworkDomain vib1 = (NetworkDomain) cache1.detach("/vib");
assertEquals("Vibration sensor ", vibSensorDomain, vib1);
assertEquals("Temperature sensor ", tempSensorDomain, temp1);
}
/**
* Domain shares Admin object, domain also contains a list of Nodes, and each DataNode has sensor elements
*/
public void testNodeAndElement() throws Exception
{
// Construct nodes
NetworkNode taipei = new NetworkNode();
taipei.setName("Taipei machine");
taipei.setIpAddress("192.168.1.100");
NetworkNode tainan = new NetworkNode();
tainan.setName("Tainan machine");
tainan.setIpAddress("192.168.1.200");
// Contruct sensor elements
NetworkElement vibSensor1 = new NetworkElement();
vibSensor1.setName("Vibration sensor V10");
NetworkElement vibSensor2 = new NetworkElement();
vibSensor2.setName("Vibration sensor V20");
NetworkElement tempSensor1 = new NetworkElement();
tempSensor1.setName("Temperature sensor T10");
NetworkElement tempSensor2 = new NetworkElement();
tempSensor2.setName("Temperature sensor T20");
// Add sensor element to DataNode
taipei.addElement(vibSensor1);
taipei.addElement(tempSensor1);
tainan.addElement(vibSensor2);
tainan.addElement(tempSensor2);
assertEquals("Element size ", 2, taipei.getElements().size());
// ask cache to manage the domains
cache1.attach("/taipei", taipei);
cache1.attach("/tainan", tainan);
NetworkNode taipei1 = (NetworkNode) cache2.find("/taipei");
NetworkNode tainan1 = (NetworkNode) cache2.find("/tainan");
taipei1.setIpAddress("192.168.10.100");
assertEquals("New admin id is ", "192.168.10.100", taipei.getIpAddress());
tainan1.setIpAddress("192.168.10.200");
assertEquals("New admin id is ", "192.168.10.200", tainan.getIpAddress());
List l2 = taipei1.getElements();
assertEquals("Size is ", 2, l2.size());
NetworkElement vibSens1 = (NetworkElement) l2.get(0);
NetworkElement tempSens1 = (NetworkElement) l2.get(1);
int SUSPENDED = 2;
vibSens1.setStatus(SUSPENDED);
tempSens1.setStatus(SUSPENDED);
assertEquals("Status ", vibSensor1.getStatus(), vibSens1.getStatus());
assertEquals("Status ", tempSensor1.getStatus(), tempSens1.getStatus());
}
/**
* Domain shares Admin object, domain also contains a list of Nodes, and each DataNode has sensor elements
*/
public void testAll() throws Exception
{
NetworkAdmin admin = new NetworkAdmin();
admin.setId("Benny");
// Construct domains
NetworkDomain tempSensorDomain = new NetworkDomain();
tempSensorDomain.setName("Temperature sensors");
tempSensorDomain.setAdmin(admin);
NetworkDomain vibSensorDomain = new NetworkDomain();
vibSensorDomain.setName("Vibration sensors");
vibSensorDomain.setAdmin(admin);
// Construct nodes
NetworkNode taipei = new NetworkNode();
taipei.setName("Taipei machine");
taipei.setIpAddress("192.168.1.100");
NetworkNode tainan = new NetworkNode();
tainan.setName("Tainan machine");
tainan.setIpAddress("192.168.1.200");
// Contruct sensor elements
NetworkElement vibSensor1 = new NetworkElement();
vibSensor1.setName("Vibration sensor V10");
NetworkElement vibSensor2 = new NetworkElement();
vibSensor2.setName("Vibration sensor V20");
NetworkElement tempSensor1 = new NetworkElement();
tempSensor1.setName("Temperature sensor T10");
NetworkElement tempSensor2 = new NetworkElement();
tempSensor2.setName("Temperature sensor T20");
// Add sensor element to DataNode
taipei.addElement(vibSensor1);
taipei.addElement(tempSensor1);
tainan.addElement(vibSensor2);
tainan.addElement(tempSensor2);
assertEquals("Element size ", 2, taipei.getElements().size());
// Add elements to domains
vibSensorDomain.addElement(vibSensor1);
vibSensorDomain.addElement(vibSensor2);
tempSensorDomain.addElement(tempSensor1);
tempSensorDomain.addElement(tempSensor2);
// ask cache to manage the domains
cache1.attach("/temp", tempSensorDomain);
cache1.attach("/vib", vibSensorDomain);
NetworkDomain temp1 = (NetworkDomain) cache2.find("/temp");
NetworkDomain vib1 = (NetworkDomain) cache2.find("/vib");
NetworkNode taipei1 = (NetworkNode) temp1.getNodes().get(0);
// NetworkNode taipei1 = (NetworkNode)temp1.getNodes().get(1); this would fail on equality
NetworkNode taipei2 = (NetworkNode) vib1.getNodes().get(0);
List l1 = temp1.getNodes();
assertEquals("Size is ", 2, l1.size());
l1 = taipei.getElements();
assertEquals("Size is ", 2, l1.size());
assertEquals("IPAddress ", taipei.getIpAddress(), taipei1.getIpAddress());
assertTrue("DataNode should be the same", (taipei1 == taipei2));
taipei2.setIpAddress("192.168.10.100");
assertEquals("New admin id is ", "192.168.10.100", taipei.getIpAddress());
List l2 = taipei1.getElements();
assertEquals("Size is ", 2, l2.size());
NetworkElement vibSens1 = (NetworkElement) l2.get(0);
NetworkElement tempSens1 = (NetworkElement) l2.get(1);
int SUSPENDED = 2;
vibSens1.setStatus(SUSPENDED);
tempSens1.setStatus(SUSPENDED);
assertEquals("Status ", vibSensor1.getStatus(), vibSens1.getStatus());
assertEquals("Status ", tempSensor1.getStatus(), tempSens1.getStatus());
}
public static Test suite() throws Exception
{
return new TestSuite(ReplicatedNetworkManagementTest.class);
}
public static void main(String[] args) throws Exception
{
junit.textui.TestRunner.run(suite());
}
}
1.1 date: 2006/07/17 14:41:28; author: bwang; state: Exp;JBossCache/tests-50/functional/org/jboss/cache/pojo/integrated/ReplicatedPropagationManagerlTest.java
Index: ReplicatedPropagationManagerlTest.java
===================================================================
package org.jboss.cache.pojo.integrated;
import junit.framework.TestCase;
import org.jboss.cache.pojo.PojoCache;
import org.jboss.cache.pojo.PojoCacheFactory;
import org.jboss.cache.pojo.test.propagation.PropagationManager;
import org.jboss.cache.pojo.test.propagation.impl.PropagationManagerImpl;
public class ReplicatedPropagationManagerlTest extends TestCase {
private PropagationManager pm_;
private PojoCache cache1_;
private PojoCache cache2_;
protected void setUp() throws Exception {
cache1_ = createCache("TestCluster");
cache2_ = createCache("TestCluster");
}
protected void tearDown() throws Exception {
cache1_.getCache().remove("/");
cache1_.stop();
cache2_.stop();
}
private PojoCache createCache(String name) throws Exception {
String configFile = "META-INF/replSync-service.xml";
PojoCache cache = PojoCacheFactory.createInstance(configFile);
cache.start();
return cache;
}
protected void initSimplifiedPm() {
pm_ = new PropagationManagerImpl();
pm_.setRootNode("root");
pm_.addNode("root", "kanto");
pm_.addNode("root.kanto", "tokyo");
pm_.addStateItem("root.kanto.tokyo", 1000, 1040);
pm_.addNode("root.kanto", "kanagawa");
/*
pm_.addStateItem("root.kanto.tokyo", 1001, 1040);
pm_.addStateItem("root.kanto.tokyo", 1002, 1040);
pm_.addNode("root.kanto.tokyo", "shinjuku");
pm_.addStateItem("root.kanto.tokyo.shinjuku", 1000, 1040);
pm_.addStateItem("root.kanto.tokyo.shinjuku", 1001, 1040);
pm_.addStateItem("root.kanto.tokyo.shinjuku", 1002, 1040);
pm_.addNode("root.kanto.kanagawa", "kawasaki");
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1005, 1040);
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1006, 1040);
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1007, 1030);
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("Initial pm state");
System.out.println("---------------------------------------------");
pm_.printNodes();
*/
}
public void testSimplified() throws Exception {
initSimplifiedPm();
// Put pm into cache management first
cache1_.attach("/propagation", pm_);
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("Initial cache content");
System.out.println("---------------------------------------------");
PropagationManager pm1 = (PropagationManager) cache2_.find("/propagation");
assertEquals("PropagationManager should ", pm_.toString(), pm1.toString());
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("root.kanto.kanagawa.kawasaki:1007 1030->1031");
System.out.println("---------------------------------------------");
pm_.stateChange("root.kanto.kanagawa.kawasaki", 1007, 1031);
pm_.printNodes();
/*
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("Final cache content");
System.out.println(cache_.printDetails());
System.out.println("---------------------------------------------");
*/
}
protected void initPm() {
pm_ = new PropagationManagerImpl();
pm_.setRootNode("root");
pm_.addNode("root", "kanto");
pm_.addNode("root.kanto", "tokyo");
pm_.addStateItem("root.kanto.tokyo", 1000, 1040);
pm_.addStateItem("root.kanto.tokyo", 1001, 1040);
pm_.addStateItem("root.kanto.tokyo", 1002, 1040);
pm_.addNode("root.kanto.tokyo", "shinjuku");
pm_.addStateItem("root.kanto.tokyo.shinjuku", 1000, 1040);
pm_.addStateItem("root.kanto.tokyo.shinjuku", 1001, 1040);
pm_.addStateItem("root.kanto.tokyo.shinjuku", 1002, 1040);
pm_.addNode("root.kanto", "kanagawa");
pm_.addNode("root.kanto.kanagawa", "kawasaki");
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1005, 1040);
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1006, 1040);
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1007, 1030);
}
public void testPropagation() throws Exception {
initPm();
// Put pm into cache management first
cache1_.attach("/propagation", pm_);
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("Initial cache content");
System.out.println("---------------------------------------------");
PropagationManager pm1 = (PropagationManager) cache2_.find("/propagation");
assertEquals("PropagationManager should ", pm_.toString(), pm1.toString());
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("Initial pm state");
System.out.println("---------------------------------------------");
pm_.printNodes();
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("root.kanto.kanagawa.kawasaki:1007 1030->1031");
System.out.println("---------------------------------------------");
pm_.stateChange("root.kanto.kanagawa.kawasaki", 1007, 1031);
pm_.printNodes();
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("root.kanto.tokyo.shinjuku:1001 1040->1041");
System.out.println("---------------------------------------------");
pm_.stateChange("root.kanto.tokyo.shinjuku", 1001, 1041);
pm_.printNodes();
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("root.kanto.kanagawa.kawasaki:1006 1040->1041");
System.out.println("---------------------------------------------");
pm_.stateChange("root.kanto.kanagawa.kawasaki", 1006, 1041);
pm_.printNodes();
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("add new item to root.kanto.kanagawa.kawasaki:1008 default:1021");
System.out.println("---------------------------------------------");
pm_.addStateItem("root.kanto.kanagawa.kawasaki", 1008, 1021);
pm_.printNodes();
System.out.println("\n\n");
System.out.println("---------------------------------------------");
System.out.println("Final cache content");
System.out.println("---------------------------------------------");
}
public static void main(String[] args) throws Exception {
ReplicatedPropagationManagerlTest pmTest = new ReplicatedPropagationManagerlTest();
pmTest.setUp();
pmTest.testPropagation();
}
}
More information about the jboss-cvs-commits
mailing list