1 22 package org.jboss.test.recover.test; 23 24 import javax.management.Attribute ; 25 import javax.management.MBeanServerConnection ; 26 import javax.management.ObjectName ; 27 import javax.rmi.PortableRemoteObject ; 28 29 import junit.framework.Test; 30 31 import org.jboss.logging.Logger; 32 import org.jboss.test.recover.interfaces.DummyXAResource; 33 import org.jboss.test.recover.interfaces.XAResourceEnlisterCaller; 34 import org.jboss.test.recover.interfaces.XAResourceEnlisterCallerHome; 35 36 42 public class CrashBeforeDistributedTxCommittedIIOPJBRemTestCase 43 extends JBossCrashRecoveryIIOPTestCase 44 { 45 private Logger log = Logger.getLogger(this.getClass()); 46 private MBeanServerConnection server = delegate.getServer(); 47 48 public CrashBeforeDistributedTxCommittedIIOPJBRemTestCase(String name) 49 throws Exception 50 { 51 super(name); 52 } 53 54 public void test() throws Exception 55 { 56 log.info("*** starting " + getUnqualifiedClassName() + " ***"); 57 58 DummyXAResource xaRes1 = getXAResource("DummyRecoverableProxy1"); 59 DummyXAResource xaRes2 = getXAResource("DummyRecoverableProxy2"); 60 DummyXAResource xaRes3 = getXAResource("DummyRecoverableProxy3"); 61 62 xaRes1.clear(); 63 xaRes2.clear(); 64 xaRes3.clear(); 65 66 Object obj; 67 XAResourceEnlisterCallerHome home; 68 69 obj = getInitialContext().lookup( 70 "dtmrectest/XAResourceEnlisterCallerEJB"); 71 home = (XAResourceEnlisterCallerHome) 72 PortableRemoteObject.narrow(obj, XAResourceEnlisterCallerHome.class); 73 XAResourceEnlisterCaller xaResEnlisterCaller = home.create(); 74 75 for (int i = 0; i < N; i++) 76 xaResEnlisterCaller.callXAResourceEnlistersOverIIOPAndJBRem(); 77 78 int xa1CommitsBefore = xaRes1.getCommittedCount(); 79 int xa2CommitsBefore = xaRes2.getCommittedCount(); 80 int xa3CommitsBefore = xaRes3.getCommittedCount(); 81 82 log.info("Commits before crash: " + xa1CommitsBefore + ", " 83 + xa2CommitsBefore + ", " + xa3CommitsBefore); 84 85 ObjectName logger = new ObjectName ("jboss:service=RecoveryLogger"); 86 try 87 { 88 server.setAttribute(logger, new Attribute ("CrashOnFailure", 89 Boolean.TRUE)); 90 server.setAttribute(logger, new Attribute ("FailBeforeCommitting", 91 Boolean.TRUE)); 92 server.setAttribute(logger, new Attribute ("FailBefore", 93 new Integer (0))); 94 xaResEnlisterCaller.callXAResourceEnlistersOverIIOPAndJBRem(); 95 fail("Server crash expected."); 96 } 97 catch (Throwable e) 98 { 99 if (e instanceof java.rmi.MarshalException ) 100 { 101 log.info("Expected throwable:", e); 102 } 103 else 104 { 105 log.info("Unexpected throwable:", e); 106 fail("Unexpected throwable: " + e); 107 } 108 } 109 110 int xa1CommitsAfter = xaRes1.getCommittedCount(); 111 int xa2CommitsAfter = xaRes2.getCommittedCount(); 112 int xa3CommitsAfter = xaRes3.getCommittedCount(); 113 114 int xa1Rollbacks = xaRes1.getRollbackCount(); 115 int xa2Rollbacks = xaRes2.getRollbackCount(); 116 int xa3Rollbacks = xaRes3.getRollbackCount(); 117 118 log.info("Commits after crash: " + xa1CommitsAfter + ", " 119 + xa2CommitsAfter + ", " + xa3CommitsAfter); 120 log.info("Rollbacks after crash: " + xa1Rollbacks + ", " 121 + xa2Rollbacks + ", " + xa3Rollbacks); 122 123 assertEquals(3 * N, xa1CommitsBefore); 124 assertEquals(3 * N, xa2CommitsBefore); 125 assertEquals(2 * N, xa3CommitsBefore); 126 assertEquals(3 * N, xa1CommitsAfter); 127 assertEquals(3 * N, xa2CommitsAfter); 128 assertEquals(2 * N, xa3CommitsAfter); 129 assertEquals(0, xa1Rollbacks); 130 assertEquals(0, xa2Rollbacks); 131 assertEquals(0, xa3Rollbacks); 132 } 133 134 public static Test suite() throws Exception 135 { 136 return suite(CrashBeforeDistributedTxCommittedIIOPJBRemTestCase.class); 137 } 138 139 } 140 | Popular Tags |