Author: fhanik Date: Fri May 5 16:12:03 2006 New Revision: 400203 URL: http://svn.apache.org/viewcvs?rev=400203&view=rev Log: Added member serialization test
Added: tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/membership/ tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/membership/MemberSerialization.java Modified: tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/MemberImpl.java Modified: tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/MemberImpl.java URL: http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/MemberImpl.java?rev=400203&r1=400202&r2=400203&view=diff ============================================================================== --- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/MemberImpl.java (original) +++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/MemberImpl.java Fri May 5 16:12:03 2006 @@ -255,15 +255,6 @@ System.arraycopy(data, pos, addr, 0, hl); pos+=hl; - byte[] dlend = new byte[4]; - System.arraycopy(data, pos, dlend, 0, 4); - pos+=4; - - int dlen = XByteBuffer.toInt(dlend, 0); - byte[] domaind = new byte[dlen]; - System.arraycopy(data, pos, domaind, 0, domaind.length); - pos+=domaind.length; - byte[] uniqueId = new byte[16]; System.arraycopy(data, pos, uniqueId, 0, 16); pos+=16; Added: tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/membership/MemberSerialization.java URL: http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/membership/MemberSerialization.java?rev=400203&view=auto ============================================================================== --- tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/membership/MemberSerialization.java (added) +++ tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/membership/MemberSerialization.java Fri May 5 16:12:03 2006 @@ -0,0 +1,85 @@ +/* + * Copyright 1999,2004 The Apache Software Foundation. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + */ +package org.apache.catalina.tribes.test.membership; + +import junit.framework.TestCase; +import org.apache.catalina.tribes.membership.MemberImpl; +import java.util.Arrays; + +/** + * <p>Title: </p> + * + * <p>Description: </p> + * + * <p>Copyright: Copyright (c) 2005</p> + * + * <p>Company: </p> + * + * @author not attributable + * @version 1.0 + */ +public class MemberSerialization extends TestCase { + MemberImpl m1, m2, p1,p2; + byte[] payload = null; + protected void setUp() throws Exception { + super.setUp(); + payload = new byte[333]; + Arrays.fill(payload,(byte)1); + m1 = new MemberImpl("localhost",3333,1,payload); + m2 = new MemberImpl("localhost",3333,1); + payload = new byte[333]; + Arrays.fill(payload,(byte)2); + p1 = new MemberImpl("localhost",3333,1,payload); + p2 = new MemberImpl("localhost",3331,1,payload); + } + + public void testCompare() throws Exception { + assertTrue(m1.equals(m2)); + assertTrue(m2.equals(m1)); + assertTrue(p1.equals(m2)); + assertFalse(m1.equals(p2)); + assertFalse(m1.equals(p2)); + assertFalse(m2.equals(p2)); + assertFalse(p1.equals(p2)); + } + + public void testSerializationOne() throws Exception { + MemberImpl m = m1; + byte[] md1 = m.getData(false,true); + byte[] mda1 = m.getData(false); + assertTrue(Arrays.equals(md1,mda1)); + MemberImpl ma1 = MemberImpl.getMember(mda1); + assertTrue(compareMembers(m,ma1)); + mda1 = p1.getData(false); + assertFalse(Arrays.equals(md1,mda1)); + ma1 = MemberImpl.getMember(mda1); + assertTrue(compareMembers(p1,ma1)); + + } + + public boolean compareMembers(MemberImpl impl1, MemberImpl impl2) { + boolean result = true; + result = result && Arrays.equals(impl1.getHost(),impl2.getHost()); + result = result && Arrays.equals(impl1.getPayload(),impl2.getPayload()); + result = result && Arrays.equals(impl1.getUniqueId(),impl2.getUniqueId()); + result = result && impl1.getPort() == impl2.getPort(); + return result; + } + + protected void tearDown() throws Exception { + super.tearDown(); + } + +} --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]