From 887d02de111a741f481b11dacd18cb345840584a Mon Sep 17 00:00:00 2001 From: markt Date: Tue, 24 Oct 2006 03:11:45 +0000 Subject: [PATCH] Correct props. git-svn-id: https://svn.apache.org/repos/asf/tomcat/tc6.0.x/trunk@467214 13f79535-47bb-0310-9956-ffa450edef68 --- .../catalina/tribes/demos/ChannelCreator.java | 506 ++--- .../catalina/tribes/demos/IntrospectionUtils.java | 2006 ++++++++++---------- .../org/apache/catalina/tribes/demos/LoadTest.java | 848 ++++----- .../tribes/test/channel/ChannelStartStop.java | 238 +-- .../test/channel/TestRemoteProcessException.java | 246 +-- .../test/interceptors/TestTwoPhaseCommit.java | 86 +- .../test/membership/MemberSerialization.java | 202 +- .../tribes/test/membership/TestDomainFilter.java | 208 +- .../catalina/tribes/test/transport/SocketSend.java | 106 +- 9 files changed, 2223 insertions(+), 2223 deletions(-) diff --git a/test/org/apache/catalina/tribes/demos/ChannelCreator.java b/test/org/apache/catalina/tribes/demos/ChannelCreator.java index 6310e767c..36de09d14 100644 --- a/test/org/apache/catalina/tribes/demos/ChannelCreator.java +++ b/test/org/apache/catalina/tribes/demos/ChannelCreator.java @@ -1,254 +1,254 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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 - * limitations under the License. - */ -package org.apache.catalina.tribes.demos; - -import java.util.Iterator; -import java.util.Properties; - -import org.apache.catalina.tribes.Channel; -import org.apache.catalina.tribes.ManagedChannel; -import org.apache.catalina.tribes.group.GroupChannel; -import org.apache.catalina.tribes.group.interceptors.FragmentationInterceptor; -import org.apache.catalina.tribes.group.interceptors.GzipInterceptor; -import org.apache.catalina.tribes.group.interceptors.MessageDispatchInterceptor; -import org.apache.catalina.tribes.group.interceptors.OrderInterceptor; -import org.apache.catalina.tribes.membership.McastService; -import org.apache.catalina.tribes.transport.MultiPointSender; -import org.apache.catalina.tribes.transport.ReceiverBase; -import org.apache.catalina.tribes.transport.ReplicationTransmitter; -import org.apache.catalina.tribes.group.interceptors.ThroughputInterceptor; -import org.apache.catalina.tribes.group.interceptors.MessageDispatch15Interceptor; -import org.apache.catalina.tribes.group.interceptors.TcpFailureDetector; -import org.apache.catalina.tribes.group.interceptors.DomainFilterInterceptor; -import java.util.ArrayList; -import org.apache.catalina.tribes.membership.MemberImpl; -import org.apache.catalina.tribes.group.interceptors.StaticMembershipInterceptor; -import org.apache.catalina.tribes.Member; - -/** - *

Title:

- * - *

Description:

- * - * - *

Company:

- * - * @author fhanik - * @version 1.0 - */ -public class ChannelCreator { - - org.apache.commons.logging.impl.LogFactoryImpl impl=null; - public static StringBuffer usage() { - StringBuffer buf = new StringBuffer(); - buf.append("\n\t\t[-bind tcpbindaddress]") - .append("\n\t\t[-tcpselto tcpselectortimeout]") - .append("\n\t\t[-tcpthreads tcpthreadcount]") - .append("\n\t\t[-port tcplistenport]") - .append("\n\t\t[-autobind tcpbindtryrange]") - .append("\n\t\t[-ackto acktimeout]") - .append("\n\t\t[-receiver org.apache.catalina.tribes.transport.nio.NioReceiver|org.apache.catalina.tribes.transport.bio.BioReceiver|]") - .append("\n\t\t[-transport org.apache.catalina.tribes.transport.nio.PooledParallelSender|org.apache.catalina.tribes.transport.bio.PooledMultiSender]") - .append("\n\t\t[-transport.xxx transport specific property]") - .append("\n\t\t[-maddr multicastaddr]") - .append("\n\t\t[-mport multicastport]") - .append("\n\t\t[-mbind multicastbindaddr]") - .append("\n\t\t[-mfreq multicastfrequency]") - .append("\n\t\t[-mdrop multicastdroptime]") - .append("\n\t\t[-gzip]") - .append("\n\t\t[-static hostname:port (-static localhost:9999 -static 127.0.0.1:8888 can be repeated)]") - .append("\n\t\t[-order]") - .append("\n\t\t[-ordersize maxorderqueuesize]") - .append("\n\t\t[-frag]") - .append("\n\t\t[-fragsize maxmsgsize]") - .append("\n\t\t[-throughput]") - .append("\n\t\t[-failuredetect]") - .append("\n\t\t[-async]") - .append("\n\t\t[-asyncsize maxqueuesizeinkilobytes]"); - return buf; - - } - - public static Channel createChannel(String[] args) throws Exception { - String bind = "auto"; - int port = 4001; - String mbind = null; - boolean gzip = false; - int tcpseltimeout = 5000; - int tcpthreadcount = 4; - int acktimeout = 15000; - String mcastaddr = "228.0.0.5"; - int mcastport = 45565; - long mcastfreq = 500; - long mcastdrop = 2000; - boolean order = false; - int ordersize = Integer.MAX_VALUE; - boolean frag = false; - int fragsize = 1024; - int autoBind = 10; - ArrayList staticMembers = new ArrayList(); - Properties transportProperties = new Properties(); - String transport = "org.apache.catalina.tribes.transport.nio.PooledParallelSender"; - String receiver = "org.apache.catalina.tribes.transport.nio.NioReceiver"; - boolean async = false; - int asyncsize = 1024*1024*50; //50MB - boolean throughput = false; - boolean failuredetect = false; - - for (int i = 0; i < args.length; i++) { - if ("-bind".equals(args[i])) { - bind = args[++i]; - } else if ("-port".equals(args[i])) { - port = Integer.parseInt(args[++i]); - } else if ("-autobind".equals(args[i])) { - autoBind = Integer.parseInt(args[++i]); - } else if ("-tcpselto".equals(args[i])) { - tcpseltimeout = Integer.parseInt(args[++i]); - } else if ("-tcpthreads".equals(args[i])) { - tcpthreadcount = Integer.parseInt(args[++i]); - } else if ("-gzip".equals(args[i])) { - gzip = true; - } else if ("-async".equals(args[i])) { - async = true; - } else if ("-failuredetect".equals(args[i])) { - failuredetect = true; - } else if ("-asyncsize".equals(args[i])) { - asyncsize = Integer.parseInt(args[++i]); - System.out.println("Setting MessageDispatchInterceptor.maxQueueSize="+asyncsize); - } else if ("-static".equals(args[i])) { - String d = args[++i]; - String h = d.substring(0,d.indexOf(":")); - String p = d.substring(h.length()+1); - MemberImpl m = new MemberImpl(h,Integer.parseInt(p),2000); - staticMembers.add(m); - } else if ("-throughput".equals(args[i])) { - throughput = true; - } else if ("-order".equals(args[i])) { - order = true; - } else if ("-ordersize".equals(args[i])) { - ordersize = Integer.parseInt(args[++i]); - System.out.println("Setting OrderInterceptor.maxQueue="+ordersize); - } else if ("-frag".equals(args[i])) { - frag = true; - } else if ("-fragsize".equals(args[i])) { - fragsize = Integer.parseInt(args[++i]); - System.out.println("Setting FragmentationInterceptor.maxSize="+fragsize); - } else if ("-ackto".equals(args[i])) { - acktimeout = Integer.parseInt(args[++i]); - } else if ("-transport".equals(args[i])) { - transport = args[++i]; - } else if (args[i]!=null && args[i].startsWith("transport.")) { - String key = args[i]; - String val = args[++i]; - transportProperties.setProperty(key,val); - } else if ("-receiver".equals(args[i])) { - receiver = args[++i]; - } else if ("-maddr".equals(args[i])) { - mcastaddr = args[++i]; - } else if ("-mport".equals(args[i])) { - mcastport = Integer.parseInt(args[++i]); - } else if ("-mfreq".equals(args[i])) { - mcastfreq = Long.parseLong(args[++i]); - } else if ("-mdrop".equals(args[i])) { - mcastdrop = Long.parseLong(args[++i]); - } else if ("-mbind".equals(args[i])) { - mbind = args[++i]; - } - } - - System.out.println("Creating receiver class="+receiver); - Class cl = Class.forName(receiver,true,ChannelCreator.class.getClassLoader()); - ReceiverBase rx = (ReceiverBase)cl.newInstance(); - rx.setTcpListenAddress(bind); - rx.setTcpListenPort(port); - rx.setTcpSelectorTimeout(tcpseltimeout); - rx.setTcpThreadCount(tcpthreadcount); - rx.getBind(); - rx.setRxBufSize(43800); - rx.setTxBufSize(25188); - rx.setAutoBind(autoBind); - - - ReplicationTransmitter ps = new ReplicationTransmitter(); - System.out.println("Creating transport class="+transport); - MultiPointSender sender = (MultiPointSender)Class.forName(transport,true,ChannelCreator.class.getClassLoader()).newInstance(); - sender.setTimeout(acktimeout); - sender.setMaxRetryAttempts(2); - sender.setRxBufSize(43800); - sender.setTxBufSize(25188); - - Iterator i = transportProperties.keySet().iterator(); - while ( i.hasNext() ) { - String key = (String)i.next(); - IntrospectionUtils.setProperty(sender,key,transportProperties.getProperty(key)); - } - ps.setTransport(sender); - - McastService service = new McastService(); - service.setMcastAddr(mcastaddr); - if (mbind != null) service.setMcastBindAddress(mbind); - service.setMcastFrequency(mcastfreq); - service.setMcastDropTime(mcastdrop); - service.setMcastPort(mcastport); - - ManagedChannel channel = new GroupChannel(); - channel.setChannelReceiver(rx); - channel.setChannelSender(ps); - channel.setMembershipService(service); - - if ( throughput ) channel.addInterceptor(new ThroughputInterceptor()); - if (gzip) channel.addInterceptor(new GzipInterceptor()); - if ( frag ) { - FragmentationInterceptor fi = new FragmentationInterceptor(); - fi.setMaxSize(fragsize); - channel.addInterceptor(fi); - } - if (order) { - OrderInterceptor oi = new OrderInterceptor(); - oi.setMaxQueue(ordersize); - channel.addInterceptor(oi); - } - - if ( async ) { - MessageDispatchInterceptor mi = new MessageDispatch15Interceptor(); - mi.setMaxQueueSize(asyncsize); - channel.addInterceptor(mi); - System.out.println("Added MessageDispatchInterceptor"); - } - - if ( failuredetect ) { - TcpFailureDetector tcpfi = new TcpFailureDetector(); - channel.addInterceptor(tcpfi); - } - if ( staticMembers.size() > 0 ) { - StaticMembershipInterceptor smi = new StaticMembershipInterceptor(); - for (int x=0; xTitle:

+ * + *

Description:

+ * + * + *

Company:

+ * + * @author fhanik + * @version 1.0 + */ +public class ChannelCreator { + + org.apache.commons.logging.impl.LogFactoryImpl impl=null; + public static StringBuffer usage() { + StringBuffer buf = new StringBuffer(); + buf.append("\n\t\t[-bind tcpbindaddress]") + .append("\n\t\t[-tcpselto tcpselectortimeout]") + .append("\n\t\t[-tcpthreads tcpthreadcount]") + .append("\n\t\t[-port tcplistenport]") + .append("\n\t\t[-autobind tcpbindtryrange]") + .append("\n\t\t[-ackto acktimeout]") + .append("\n\t\t[-receiver org.apache.catalina.tribes.transport.nio.NioReceiver|org.apache.catalina.tribes.transport.bio.BioReceiver|]") + .append("\n\t\t[-transport org.apache.catalina.tribes.transport.nio.PooledParallelSender|org.apache.catalina.tribes.transport.bio.PooledMultiSender]") + .append("\n\t\t[-transport.xxx transport specific property]") + .append("\n\t\t[-maddr multicastaddr]") + .append("\n\t\t[-mport multicastport]") + .append("\n\t\t[-mbind multicastbindaddr]") + .append("\n\t\t[-mfreq multicastfrequency]") + .append("\n\t\t[-mdrop multicastdroptime]") + .append("\n\t\t[-gzip]") + .append("\n\t\t[-static hostname:port (-static localhost:9999 -static 127.0.0.1:8888 can be repeated)]") + .append("\n\t\t[-order]") + .append("\n\t\t[-ordersize maxorderqueuesize]") + .append("\n\t\t[-frag]") + .append("\n\t\t[-fragsize maxmsgsize]") + .append("\n\t\t[-throughput]") + .append("\n\t\t[-failuredetect]") + .append("\n\t\t[-async]") + .append("\n\t\t[-asyncsize maxqueuesizeinkilobytes]"); + return buf; + + } + + public static Channel createChannel(String[] args) throws Exception { + String bind = "auto"; + int port = 4001; + String mbind = null; + boolean gzip = false; + int tcpseltimeout = 5000; + int tcpthreadcount = 4; + int acktimeout = 15000; + String mcastaddr = "228.0.0.5"; + int mcastport = 45565; + long mcastfreq = 500; + long mcastdrop = 2000; + boolean order = false; + int ordersize = Integer.MAX_VALUE; + boolean frag = false; + int fragsize = 1024; + int autoBind = 10; + ArrayList staticMembers = new ArrayList(); + Properties transportProperties = new Properties(); + String transport = "org.apache.catalina.tribes.transport.nio.PooledParallelSender"; + String receiver = "org.apache.catalina.tribes.transport.nio.NioReceiver"; + boolean async = false; + int asyncsize = 1024*1024*50; //50MB + boolean throughput = false; + boolean failuredetect = false; + + for (int i = 0; i < args.length; i++) { + if ("-bind".equals(args[i])) { + bind = args[++i]; + } else if ("-port".equals(args[i])) { + port = Integer.parseInt(args[++i]); + } else if ("-autobind".equals(args[i])) { + autoBind = Integer.parseInt(args[++i]); + } else if ("-tcpselto".equals(args[i])) { + tcpseltimeout = Integer.parseInt(args[++i]); + } else if ("-tcpthreads".equals(args[i])) { + tcpthreadcount = Integer.parseInt(args[++i]); + } else if ("-gzip".equals(args[i])) { + gzip = true; + } else if ("-async".equals(args[i])) { + async = true; + } else if ("-failuredetect".equals(args[i])) { + failuredetect = true; + } else if ("-asyncsize".equals(args[i])) { + asyncsize = Integer.parseInt(args[++i]); + System.out.println("Setting MessageDispatchInterceptor.maxQueueSize="+asyncsize); + } else if ("-static".equals(args[i])) { + String d = args[++i]; + String h = d.substring(0,d.indexOf(":")); + String p = d.substring(h.length()+1); + MemberImpl m = new MemberImpl(h,Integer.parseInt(p),2000); + staticMembers.add(m); + } else if ("-throughput".equals(args[i])) { + throughput = true; + } else if ("-order".equals(args[i])) { + order = true; + } else if ("-ordersize".equals(args[i])) { + ordersize = Integer.parseInt(args[++i]); + System.out.println("Setting OrderInterceptor.maxQueue="+ordersize); + } else if ("-frag".equals(args[i])) { + frag = true; + } else if ("-fragsize".equals(args[i])) { + fragsize = Integer.parseInt(args[++i]); + System.out.println("Setting FragmentationInterceptor.maxSize="+fragsize); + } else if ("-ackto".equals(args[i])) { + acktimeout = Integer.parseInt(args[++i]); + } else if ("-transport".equals(args[i])) { + transport = args[++i]; + } else if (args[i]!=null && args[i].startsWith("transport.")) { + String key = args[i]; + String val = args[++i]; + transportProperties.setProperty(key,val); + } else if ("-receiver".equals(args[i])) { + receiver = args[++i]; + } else if ("-maddr".equals(args[i])) { + mcastaddr = args[++i]; + } else if ("-mport".equals(args[i])) { + mcastport = Integer.parseInt(args[++i]); + } else if ("-mfreq".equals(args[i])) { + mcastfreq = Long.parseLong(args[++i]); + } else if ("-mdrop".equals(args[i])) { + mcastdrop = Long.parseLong(args[++i]); + } else if ("-mbind".equals(args[i])) { + mbind = args[++i]; + } + } + + System.out.println("Creating receiver class="+receiver); + Class cl = Class.forName(receiver,true,ChannelCreator.class.getClassLoader()); + ReceiverBase rx = (ReceiverBase)cl.newInstance(); + rx.setTcpListenAddress(bind); + rx.setTcpListenPort(port); + rx.setTcpSelectorTimeout(tcpseltimeout); + rx.setTcpThreadCount(tcpthreadcount); + rx.getBind(); + rx.setRxBufSize(43800); + rx.setTxBufSize(25188); + rx.setAutoBind(autoBind); + + + ReplicationTransmitter ps = new ReplicationTransmitter(); + System.out.println("Creating transport class="+transport); + MultiPointSender sender = (MultiPointSender)Class.forName(transport,true,ChannelCreator.class.getClassLoader()).newInstance(); + sender.setTimeout(acktimeout); + sender.setMaxRetryAttempts(2); + sender.setRxBufSize(43800); + sender.setTxBufSize(25188); + + Iterator i = transportProperties.keySet().iterator(); + while ( i.hasNext() ) { + String key = (String)i.next(); + IntrospectionUtils.setProperty(sender,key,transportProperties.getProperty(key)); + } + ps.setTransport(sender); + + McastService service = new McastService(); + service.setMcastAddr(mcastaddr); + if (mbind != null) service.setMcastBindAddress(mbind); + service.setMcastFrequency(mcastfreq); + service.setMcastDropTime(mcastdrop); + service.setMcastPort(mcastport); + + ManagedChannel channel = new GroupChannel(); + channel.setChannelReceiver(rx); + channel.setChannelSender(ps); + channel.setMembershipService(service); + + if ( throughput ) channel.addInterceptor(new ThroughputInterceptor()); + if (gzip) channel.addInterceptor(new GzipInterceptor()); + if ( frag ) { + FragmentationInterceptor fi = new FragmentationInterceptor(); + fi.setMaxSize(fragsize); + channel.addInterceptor(fi); + } + if (order) { + OrderInterceptor oi = new OrderInterceptor(); + oi.setMaxQueue(ordersize); + channel.addInterceptor(oi); + } + + if ( async ) { + MessageDispatchInterceptor mi = new MessageDispatch15Interceptor(); + mi.setMaxQueueSize(asyncsize); + channel.addInterceptor(mi); + System.out.println("Added MessageDispatchInterceptor"); + } + + if ( failuredetect ) { + TcpFailureDetector tcpfi = new TcpFailureDetector(); + channel.addInterceptor(tcpfi); + } + if ( staticMembers.size() > 0 ) { + StaticMembershipInterceptor smi = new StaticMembershipInterceptor(); + for (int x=0; x 1) - d("setProperty(" + o.getClass() + " " + name + "=" + value + ")"); - - String setter = "set" + capitalize(name); - - try { - Method methods[] = findMethods(o.getClass()); - Method setPropertyMethod = null; - - // First, the ideal case - a setFoo( String ) method - for (int i = 0; i < methods.length; i++) { - Class paramT[] = methods[i].getParameterTypes(); - if (setter.equals(methods[i].getName()) && paramT.length == 1 - && "java.lang.String".equals(paramT[0].getName())) { - - methods[i].invoke(o, new Object[] { value }); - return; - } - } - - // Try a setFoo ( int ) or ( boolean ) - for (int i = 0; i < methods.length; i++) { - boolean ok = true; - if (setter.equals(methods[i].getName()) - && methods[i].getParameterTypes().length == 1) { - - // match - find the type and invoke it - Class paramType = methods[i].getParameterTypes()[0]; - Object params[] = new Object[1]; - - // Try a setFoo ( int ) - if ("java.lang.Integer".equals(paramType.getName()) - || "int".equals(paramType.getName())) { - try { - params[0] = new Integer(value); - } catch (NumberFormatException ex) { - ok = false; - } - // Try a setFoo ( long ) - }else if ("java.lang.Long".equals(paramType.getName()) - || "long".equals(paramType.getName())) { - try { - params[0] = new Long(value); - } catch (NumberFormatException ex) { - ok = false; - } - - // Try a setFoo ( boolean ) - } else if ("java.lang.Boolean".equals(paramType.getName()) - || "boolean".equals(paramType.getName())) { - params[0] = new Boolean(value); - - // Try a setFoo ( InetAddress ) - } else if ("java.net.InetAddress".equals(paramType - .getName())) { - try { - params[0] = InetAddress.getByName(value); - } catch (UnknownHostException exc) { - d("Unable to resolve host name:" + value); - ok = false; - } - - // Unknown type - } else { - d("Unknown type " + paramType.getName()); - } - - if (ok) { - methods[i].invoke(o, params); - return; - } - } - - // save "setProperty" for later - if ("setProperty".equals(methods[i].getName())) { - setPropertyMethod = methods[i]; - } - } - - // Ok, no setXXX found, try a setProperty("name", "value") - if (setPropertyMethod != null) { - Object params[] = new Object[2]; - params[0] = name; - params[1] = value; - setPropertyMethod.invoke(o, params); - } - - } catch (IllegalArgumentException ex2) { - log.warn("IAE " + o + " " + name + " " + value, ex2); - } catch (SecurityException ex1) { - if (dbg > 0) - d("SecurityException for " + o.getClass() + " " + name + "=" - + value + ")"); - if (dbg > 1) - ex1.printStackTrace(); - } catch (IllegalAccessException iae) { - if (dbg > 0) - d("IllegalAccessException for " + o.getClass() + " " + name - + "=" + value + ")"); - if (dbg > 1) - iae.printStackTrace(); - } catch (InvocationTargetException ie) { - if (dbg > 0) - d("InvocationTargetException for " + o.getClass() + " " + name - + "=" + value + ")"); - if (dbg > 1) - ie.printStackTrace(); - } - } - - public static Object getProperty(Object o, String name) { - String getter = "get" + capitalize(name); - String isGetter = "is" + capitalize(name); - - try { - Method methods[] = findMethods(o.getClass()); - Method getPropertyMethod = null; - - // First, the ideal case - a getFoo() method - for (int i = 0; i < methods.length; i++) { - Class paramT[] = methods[i].getParameterTypes(); - if (getter.equals(methods[i].getName()) && paramT.length == 0) { - return methods[i].invoke(o, (Object[]) null); - } - if (isGetter.equals(methods[i].getName()) && paramT.length == 0) { - return methods[i].invoke(o, (Object[]) null); - } - - if ("getProperty".equals(methods[i].getName())) { - getPropertyMethod = methods[i]; - } - } - - // Ok, no setXXX found, try a getProperty("name") - if (getPropertyMethod != null) { - Object params[] = new Object[1]; - params[0] = name; - return getPropertyMethod.invoke(o, params); - } - - } catch (IllegalArgumentException ex2) { - log.warn("IAE " + o + " " + name, ex2); - } catch (SecurityException ex1) { - if (dbg > 0) - d("SecurityException for " + o.getClass() + " " + name + ")"); - if (dbg > 1) - ex1.printStackTrace(); - } catch (IllegalAccessException iae) { - if (dbg > 0) - d("IllegalAccessException for " + o.getClass() + " " + name - + ")"); - if (dbg > 1) - iae.printStackTrace(); - } catch (InvocationTargetException ie) { - if (dbg > 0) - d("InvocationTargetException for " + o.getClass() + " " + name - + ")"); - if (dbg > 1) - ie.printStackTrace(); - } - return null; - } - - /** - */ - public static void setProperty(Object o, String name) { - String setter = "set" + capitalize(name); - try { - Method methods[] = findMethods(o.getClass()); - Method setPropertyMethod = null; - // find setFoo() method - for (int i = 0; i < methods.length; i++) { - Class paramT[] = methods[i].getParameterTypes(); - if (setter.equals(methods[i].getName()) && paramT.length == 0) { - methods[i].invoke(o, new Object[] {}); - return; - } - } - } catch (Exception ex1) { - if (dbg > 0) - d("Exception for " + o.getClass() + " " + name); - if (dbg > 1) - ex1.printStackTrace(); - } - } - - /** - * Replace ${NAME} with the property value - * - * @deprecated Use the explicit method - */ - public static String replaceProperties(String value, Object getter) { - if (getter instanceof Hashtable) - return replaceProperties(value, (Hashtable) getter, null); - - if (getter instanceof PropertySource) { - PropertySource src[] = new PropertySource[] { (PropertySource) getter }; - return replaceProperties(value, null, src); - } - return value; - } - - /** - * Replace ${NAME} with the property value - */ - public static String replaceProperties(String value, Hashtable staticProp, - PropertySource dynamicProp[]) { - StringBuffer sb = new StringBuffer(); - int prev = 0; - // assert value!=nil - int pos; - while ((pos = value.indexOf("$", prev)) >= 0) { - if (pos > 0) { - sb.append(value.substring(prev, pos)); - } - if (pos == (value.length() - 1)) { - sb.append('$'); - prev = pos + 1; - } else if (value.charAt(pos + 1) != '{') { - sb.append('$'); - prev = pos + 1; // XXX - } else { - int endName = value.indexOf('}', pos); - if (endName < 0) { - sb.append(value.substring(pos)); - prev = value.length(); - continue; - } - String n = value.substring(pos + 2, endName); - String v = null; - if (staticProp != null) { - v = (String) ((Hashtable) staticProp).get(n); - } - if (v == null && dynamicProp != null) { - for (int i = 0; i < dynamicProp.length; i++) { - v = dynamicProp[i].getProperty(n); - if (v != null) { - break; - } - } - } - if (v == null) - v = "${" + n + "}"; - - sb.append(v); - prev = endName + 1; - } - } - if (prev < value.length()) - sb.append(value.substring(prev)); - return sb.toString(); - } - - /** - * Reverse of Introspector.decapitalize - */ - public static String capitalize(String name) { - if (name == null || name.length() == 0) { - return name; - } - char chars[] = name.toCharArray(); - chars[0] = Character.toUpperCase(chars[0]); - return new String(chars); - } - - public static String unCapitalize(String name) { - if (name == null || name.length() == 0) { - return name; - } - char chars[] = name.toCharArray(); - chars[0] = Character.toLowerCase(chars[0]); - return new String(chars); - } - - // -------------------- Class path tools -------------------- - - /** - * Add all the jar files in a dir to the classpath, represented as a Vector - * of URLs. - */ - public static void addToClassPath(Vector cpV, String dir) { - try { - String cpComp[] = getFilesByExt(dir, ".jar"); - if (cpComp != null) { - int jarCount = cpComp.length; - for (int i = 0; i < jarCount; i++) { - URL url = getURL(dir, cpComp[i]); - if (url != null) - cpV.addElement(url); - } - } - } catch (Exception ex) { - ex.printStackTrace(); - } - } - - public static void addToolsJar(Vector v) { - try { - // Add tools.jar in any case - File f = new File(System.getProperty("java.home") - + "/../lib/tools.jar"); - - if (!f.exists()) { - // On some systems java.home gets set to the root of jdk. - // That's a bug, but we can work around and be nice. - f = new File(System.getProperty("java.home") + "/lib/tools.jar"); - if (f.exists()) { - if (log.isDebugEnabled()) - log.debug("Detected strange java.home value " - + System.getProperty("java.home") - + ", it should point to jre"); - } - } - URL url = new URL("file", "", f.getAbsolutePath()); - - v.addElement(url); - } catch (MalformedURLException ex) { - ex.printStackTrace(); - } - } - - /** - * Return all files with a given extension in a dir - */ - public static String[] getFilesByExt(String ld, String ext) { - File dir = new File(ld); - String[] names = null; - final String lext = ext; - if (dir.isDirectory()) { - names = dir.list(new FilenameFilter() { - public boolean accept(File d, String name) { - if (name.endsWith(lext)) { - return true; - } - return false; - } - }); - } - return names; - } - - /** - * Construct a file url from a file, using a base dir - */ - public static URL getURL(String base, String file) { - try { - File baseF = new File(base); - File f = new File(baseF, file); - String path = f.getCanonicalPath(); - if (f.isDirectory()) { - path += "/"; - } - if (!f.exists()) - return null; - return new URL("file", "", path); - } catch (Exception ex) { - ex.printStackTrace(); - return null; - } - } - - /** - * Add elements from the classpath cp to a Vector jars as - * file URLs (We use Vector for JDK 1.1 compat). - *

- * - * @param jars The jar list - * @param cp a String classpath of directory or jar file elements - * separated by path.separator delimiters. - * @throws IOException If an I/O error occurs - * @throws MalformedURLException Doh ;) - */ - public static void addJarsFromClassPath(Vector jars, String cp) - throws IOException, MalformedURLException { - String sep = System.getProperty("path.separator"); - String token; - StringTokenizer st; - if (cp != null) { - st = new StringTokenizer(cp, sep); - while (st.hasMoreTokens()) { - File f = new File(st.nextToken()); - String path = f.getCanonicalPath(); - if (f.isDirectory()) { - path += "/"; - } - URL url = new URL("file", "", path); - if (!jars.contains(url)) { - jars.addElement(url); - } - } - } - } - - /** - * Return a URL[] that can be used to construct a class loader - */ - public static URL[] getClassPath(Vector v) { - URL[] urls = new URL[v.size()]; - for (int i = 0; i < v.size(); i++) { - urls[i] = (URL) v.elementAt(i); - } - return urls; - } - - /** - * Construct a URL classpath from files in a directory, a cpath property, - * and tools.jar. - */ - public static URL[] getClassPath(String dir, String cpath, - String cpathProp, boolean addTools) throws IOException, - MalformedURLException { - Vector jarsV = new Vector(); - if (dir != null) { - // Add dir/classes first, if it exists - URL url = getURL(dir, "classes"); - if (url != null) - jarsV.addElement(url); - addToClassPath(jarsV, dir); - } - - if (cpath != null) - addJarsFromClassPath(jarsV, cpath); - - if (cpathProp != null) { - String cpath1 = System.getProperty(cpathProp); - addJarsFromClassPath(jarsV, cpath1); - } - - if (addTools) - addToolsJar(jarsV); - - return getClassPath(jarsV); - } - - // -------------------- Mapping command line params to setters - - public static boolean processArgs(Object proxy, String args[]) - throws Exception { - String args0[] = null; - if (null != findMethod(proxy.getClass(), "getOptions1", new Class[] {})) { - args0 = (String[]) callMethod0(proxy, "getOptions1"); - } - - if (args0 == null) { - //args0=findVoidSetters(proxy.getClass()); - args0 = findBooleanSetters(proxy.getClass()); - } - Hashtable h = null; - if (null != findMethod(proxy.getClass(), "getOptionAliases", - new Class[] {})) { - h = (Hashtable) callMethod0(proxy, "getOptionAliases"); - } - return processArgs(proxy, args, args0, null, h); - } - - public static boolean processArgs(Object proxy, String args[], - String args0[], String args1[], Hashtable aliases) throws Exception { - for (int i = 0; i < args.length; i++) { - String arg = args[i]; - if (arg.startsWith("-")) - arg = arg.substring(1); - if (aliases != null && aliases.get(arg) != null) - arg = (String) aliases.get(arg); - - if (args0 != null) { - boolean set = false; - for (int j = 0; j < args0.length; j++) { - if (args0[j].equalsIgnoreCase(arg)) { - setProperty(proxy, args0[j], "true"); - set = true; - break; - } - } - if (set) - continue; - } - if (args1 != null) { - for (int j = 0; j < args1.length; j++) { - if (args1[j].equalsIgnoreCase(arg)) { - i++; - if (i >= args.length) - return false; - setProperty(proxy, arg, args[i]); - break; - } - } - } else { - // if args1 is not specified,assume all other options have param - i++; - if (i >= args.length) - return false; - setProperty(proxy, arg, args[i]); - } - - } - return true; - } - - // -------------------- other utils -------------------- - public static void clear() { - objectMethods.clear(); - } - - public static String[] findVoidSetters(Class c) { - Method m[] = findMethods(c); - if (m == null) - return null; - Vector v = new Vector(); - for (int i = 0; i < m.length; i++) { - if (m[i].getName().startsWith("set") - && m[i].getParameterTypes().length == 0) { - String arg = m[i].getName().substring(3); - v.addElement(unCapitalize(arg)); - } - } - String s[] = new String[v.size()]; - for (int i = 0; i < s.length; i++) { - s[i] = (String) v.elementAt(i); - } - return s; - } - - public static String[] findBooleanSetters(Class c) { - Method m[] = findMethods(c); - if (m == null) - return null; - Vector v = new Vector(); - for (int i = 0; i < m.length; i++) { - if (m[i].getName().startsWith("set") - && m[i].getParameterTypes().length == 1 - && "boolean".equalsIgnoreCase(m[i].getParameterTypes()[0] - .getName())) { - String arg = m[i].getName().substring(3); - v.addElement(unCapitalize(arg)); - } - } - String s[] = new String[v.size()]; - for (int i = 0; i < s.length; i++) { - s[i] = (String) v.elementAt(i); - } - return s; - } - - static Hashtable objectMethods = new Hashtable(); - - public static Method[] findMethods(Class c) { - Method methods[] = (Method[]) objectMethods.get(c); - if (methods != null) - return methods; - - methods = c.getMethods(); - objectMethods.put(c, methods); - return methods; - } - - public static Method findMethod(Class c, String name, Class params[]) { - Method methods[] = findMethods(c); - if (methods == null) - return null; - for (int i = 0; i < methods.length; i++) { - if (methods[i].getName().equals(name)) { - Class methodParams[] = methods[i].getParameterTypes(); - if (methodParams == null) - if (params == null || params.length == 0) - return methods[i]; - if (params == null) - if (methodParams == null || methodParams.length == 0) - return methods[i]; - if (params.length != methodParams.length) - continue; - boolean found = true; - for (int j = 0; j < params.length; j++) { - if (params[j] != methodParams[j]) { - found = false; - break; - } - } - if (found) - return methods[i]; - } - } - return null; - } - - /** Test if the object implements a particular - * method - */ - public static boolean hasHook(Object obj, String methodN) { - try { - Method myMethods[] = findMethods(obj.getClass()); - for (int i = 0; i < myMethods.length; i++) { - if (methodN.equals(myMethods[i].getName())) { - // check if it's overriden - Class declaring = myMethods[i].getDeclaringClass(); - Class parentOfDeclaring = declaring.getSuperclass(); - // this works only if the base class doesn't extend - // another class. - - // if the method is declared in a top level class - // like BaseInterceptor parent is Object, otherwise - // parent is BaseInterceptor or an intermediate class - if (!"java.lang.Object".equals(parentOfDeclaring.getName())) { - return true; - } - } - } - } catch (Exception ex) { - ex.printStackTrace(); - } - return false; - } - - public static void callMain(Class c, String args[]) throws Exception { - Class p[] = new Class[1]; - p[0] = args.getClass(); - Method m = c.getMethod("main", p); - m.invoke(c, new Object[] { args }); - } - - public static Object callMethod1(Object target, String methodN, - Object param1, String typeParam1, ClassLoader cl) throws Exception { - if (target == null || param1 == null) { - d("Assert: Illegal params " + target + " " + param1); - } - if (dbg > 0) - d("callMethod1 " + target.getClass().getName() + " " - + param1.getClass().getName() + " " + typeParam1); - - Class params[] = new Class[1]; - if (typeParam1 == null) - params[0] = param1.getClass(); - else - params[0] = cl.loadClass(typeParam1); - Method m = findMethod(target.getClass(), methodN, params); - if (m == null) - throw new NoSuchMethodException(target.getClass().getName() + " " - + methodN); - return m.invoke(target, new Object[] { param1 }); - } - - public static Object callMethod0(Object target, String methodN) - throws Exception { - if (target == null) { - d("Assert: Illegal params " + target); - return null; - } - if (dbg > 0) - d("callMethod0 " + target.getClass().getName() + "." + methodN); - - Class params[] = new Class[0]; - Method m = findMethod(target.getClass(), methodN, params); - if (m == null) - throw new NoSuchMethodException(target.getClass().getName() + " " - + methodN); - return m.invoke(target, emptyArray); - } - - static Object[] emptyArray = new Object[] {}; - - public static Object callMethodN(Object target, String methodN, - Object params[], Class typeParams[]) throws Exception { - Method m = null; - m = findMethod(target.getClass(), methodN, typeParams); - if (m == null) { - d("Can't find method " + methodN + " in " + target + " CLASS " - + target.getClass()); - return null; - } - Object o = m.invoke(target, params); - - if (dbg > 0) { - // debug - StringBuffer sb = new StringBuffer(); - sb.append("" + target.getClass().getName() + "." + methodN + "( "); - for (int i = 0; i < params.length; i++) { - if (i > 0) - sb.append(", "); - sb.append(params[i]); - } - sb.append(")"); - d(sb.toString()); - } - return o; - } - - public static Object convert(String object, Class paramType) { - Object result = null; - if ("java.lang.String".equals(paramType.getName())) { - result = object; - } else if ("java.lang.Integer".equals(paramType.getName()) - || "int".equals(paramType.getName())) { - try { - result = new Integer(object); - } catch (NumberFormatException ex) { - } - // Try a setFoo ( boolean ) - } else if ("java.lang.Boolean".equals(paramType.getName()) - || "boolean".equals(paramType.getName())) { - result = new Boolean(object); - - // Try a setFoo ( InetAddress ) - } else if ("java.net.InetAddress".equals(paramType - .getName())) { - try { - result = InetAddress.getByName(object); - } catch (UnknownHostException exc) { - d("Unable to resolve host name:" + object); - } - - // Unknown type - } else { - d("Unknown type " + paramType.getName()); - } - if (result == null) { - throw new IllegalArgumentException("Can't convert argument: " + object); - } - return result; - } - - // -------------------- Get property -------------------- - // This provides a layer of abstraction - - public static interface PropertySource { - - public String getProperty(String key); - - } - - public static interface AttributeHolder { - - public void setAttribute(String key, Object o); - - } - - // debug -------------------- - static final int dbg = 0; - - static void d(String s) { - if (log.isDebugEnabled()) - log.debug("IntrospectionUtils: " + s); - } -} +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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 + * limitations under the License. + */ + +package org.apache.catalina.tribes.demos; + +import java.io.File; +import java.io.FilenameFilter; +import java.io.IOException; +import java.lang.reflect.InvocationTargetException; +import java.lang.reflect.Method; +import java.net.InetAddress; +import java.net.MalformedURLException; +import java.net.URL; +import java.net.UnknownHostException; +import java.util.Hashtable; +import java.util.StringTokenizer; +import java.util.Vector; + +// Depends: JDK1.1 + +/** + * Utils for introspection and reflection + */ +public final class IntrospectionUtils { + + + private static org.apache.commons.logging.Log log= + org.apache.commons.logging.LogFactory.getLog( IntrospectionUtils.class ); + + /** + * Call execute() - any ant-like task should work + */ + public static void execute(Object proxy, String method) throws Exception { + Method executeM = null; + Class c = proxy.getClass(); + Class params[] = new Class[0]; + // params[0]=args.getClass(); + executeM = findMethod(c, method, params); + if (executeM == null) { + throw new RuntimeException("No execute in " + proxy.getClass()); + } + executeM.invoke(proxy, (Object[]) null);//new Object[] { args }); + } + + /** + * Call void setAttribute( String ,Object ) + */ + public static void setAttribute(Object proxy, String n, Object v) + throws Exception { + if (proxy instanceof AttributeHolder) { + ((AttributeHolder) proxy).setAttribute(n, v); + return; + } + + Method executeM = null; + Class c = proxy.getClass(); + Class params[] = new Class[2]; + params[0] = String.class; + params[1] = Object.class; + executeM = findMethod(c, "setAttribute", params); + if (executeM == null) { + if (log.isDebugEnabled()) + log.debug("No setAttribute in " + proxy.getClass()); + return; + } + if (false) + if (log.isDebugEnabled()) + log.debug("Setting " + n + "=" + v + " in " + proxy); + executeM.invoke(proxy, new Object[] { n, v }); + return; + } + + /** + * Call void getAttribute( String ) + */ + public static Object getAttribute(Object proxy, String n) throws Exception { + Method executeM = null; + Class c = proxy.getClass(); + Class params[] = new Class[1]; + params[0] = String.class; + executeM = findMethod(c, "getAttribute", params); + if (executeM == null) { + if (log.isDebugEnabled()) + log.debug("No getAttribute in " + proxy.getClass()); + return null; + } + return executeM.invoke(proxy, new Object[] { n }); + } + + /** + * Construct a URLClassLoader. Will compile and work in JDK1.1 too. + */ + public static ClassLoader getURLClassLoader(URL urls[], ClassLoader parent) { + try { + Class urlCL = Class.forName("java.net.URLClassLoader"); + Class paramT[] = new Class[2]; + paramT[0] = urls.getClass(); + paramT[1] = ClassLoader.class; + Method m = findMethod(urlCL, "newInstance", paramT); + if (m == null) + return null; + + ClassLoader cl = (ClassLoader) m.invoke(urlCL, new Object[] { urls, + parent }); + return cl; + } catch (ClassNotFoundException ex) { + // jdk1.1 + return null; + } catch (Exception ex) { + ex.printStackTrace(); + return null; + } + } + + public static String guessInstall(String installSysProp, + String homeSysProp, String jarName) { + return guessInstall(installSysProp, homeSysProp, jarName, null); + } + + /** + * Guess a product install/home by analyzing the class path. It works for + * product using the pattern: lib/executable.jar or if executable.jar is + * included in classpath by a shell script. ( java -jar also works ) + * + * Insures both "install" and "home" System properties are set. If either or + * both System properties are unset, "install" and "home" will be set to the + * same value. This value will be the other System property that is set, or + * the guessed value if neither is set. + */ + public static String guessInstall(String installSysProp, + String homeSysProp, String jarName, String classFile) { + String install = null; + String home = null; + + if (installSysProp != null) + install = System.getProperty(installSysProp); + + if (homeSysProp != null) + home = System.getProperty(homeSysProp); + + if (install != null) { + if (home == null) + System.getProperties().put(homeSysProp, install); + return install; + } + + // Find the directory where jarName.jar is located + + String cpath = System.getProperty("java.class.path"); + String pathSep = System.getProperty("path.separator"); + StringTokenizer st = new StringTokenizer(cpath, pathSep); + while (st.hasMoreTokens()) { + String path = st.nextToken(); + // log( "path " + path ); + if (path.endsWith(jarName)) { + home = path.substring(0, path.length() - jarName.length()); + try { + if ("".equals(home)) { + home = new File("./").getCanonicalPath(); + } else if (home.endsWith(File.separator)) { + home = home.substring(0, home.length() - 1); + } + File f = new File(home); + String parentDir = f.getParent(); + if (parentDir == null) + parentDir = home; // unix style + File f1 = new File(parentDir); + install = f1.getCanonicalPath(); + if (installSysProp != null) + System.getProperties().put(installSysProp, install); + if (home == null && homeSysProp != null) + System.getProperties().put(homeSysProp, install); + return install; + } catch (Exception ex) { + ex.printStackTrace(); + } + } else { + String fname = path + (path.endsWith("/") ? "" : "/") + + classFile; + if (new File(fname).exists()) { + try { + File f = new File(path); + String parentDir = f.getParent(); + if (parentDir == null) + parentDir = path; // unix style + File f1 = new File(parentDir); + install = f1.getCanonicalPath(); + if (installSysProp != null) + System.getProperties().put(installSysProp, install); + if (home == null && homeSysProp != null) + System.getProperties().put(homeSysProp, install); + return install; + } catch (Exception ex) { + ex.printStackTrace(); + } + } + } + } + + // if install directory can't be found, use home as the default + if (home != null) { + System.getProperties().put(installSysProp, home); + return home; + } + + return null; + } + + /** + * Debug method, display the classpath + */ + public static void displayClassPath(String msg, URL[] cp) { + if (log.isDebugEnabled()) { + log.debug(msg); + for (int i = 0; i < cp.length; i++) { + log.debug(cp[i].getFile()); + } + } + } + + public static String PATH_SEPARATOR = System.getProperty("path.separator"); + + /** + * Adds classpath entries from a vector of URL's to the "tc_path_add" System + * property. This System property lists the classpath entries common to web + * applications. This System property is currently used by Jasper when its + * JSP servlet compiles the Java file for a JSP. + */ + public static String classPathAdd(URL urls[], String cp) { + if (urls == null) + return cp; + + for (int i = 0; i < urls.length; i++) { + if (cp != null) + cp += PATH_SEPARATOR + urls[i].getFile(); + else + cp = urls[i].getFile(); + } + return cp; + } + + /** + * Find a method with the right name If found, call the method ( if param is + * int or boolean we'll convert value to the right type before) - that means + * you can have setDebug(1). + */ + public static void setProperty(Object o, String name, String value) { + if (dbg > 1) + d("setProperty(" + o.getClass() + " " + name + "=" + value + ")"); + + String setter = "set" + capitalize(name); + + try { + Method methods[] = findMethods(o.getClass()); + Method setPropertyMethod = null; + + // First, the ideal case - a setFoo( String ) method + for (int i = 0; i < methods.length; i++) { + Class paramT[] = methods[i].getParameterTypes(); + if (setter.equals(methods[i].getName()) && paramT.length == 1 + && "java.lang.String".equals(paramT[0].getName())) { + + methods[i].invoke(o, new Object[] { value }); + return; + } + } + + // Try a setFoo ( int ) or ( boolean ) + for (int i = 0; i < methods.length; i++) { + boolean ok = true; + if (setter.equals(methods[i].getName()) + && methods[i].getParameterTypes().length == 1) { + + // match - find the type and invoke it + Class paramType = methods[i].getParameterTypes()[0]; + Object params[] = new Object[1]; + + // Try a setFoo ( int ) + if ("java.lang.Integer".equals(paramType.getName()) + || "int".equals(paramType.getName())) { + try { + params[0] = new Integer(value); + } catch (NumberFormatException ex) { + ok = false; + } + // Try a setFoo ( long ) + }else if ("java.lang.Long".equals(paramType.getName()) + || "long".equals(paramType.getName())) { + try { + params[0] = new Long(value); + } catch (NumberFormatException ex) { + ok = false; + } + + // Try a setFoo ( boolean ) + } else if ("java.lang.Boolean".equals(paramType.getName()) + || "boolean".equals(paramType.getName())) { + params[0] = new Boolean(value); + + // Try a setFoo ( InetAddress ) + } else if ("java.net.InetAddress".equals(paramType + .getName())) { + try { + params[0] = InetAddress.getByName(value); + } catch (UnknownHostException exc) { + d("Unable to resolve host name:" + value); + ok = false; + } + + // Unknown type + } else { + d("Unknown type " + paramType.getName()); + } + + if (ok) { + methods[i].invoke(o, params); + return; + } + } + + // save "setProperty" for later + if ("setProperty".equals(methods[i].getName())) { + setPropertyMethod = methods[i]; + } + } + + // Ok, no setXXX found, try a setProperty("name", "value") + if (setPropertyMethod != null) { + Object params[] = new Object[2]; + params[0] = name; + params[1] = value; + setPropertyMethod.invoke(o, params); + } + + } catch (IllegalArgumentException ex2) { + log.warn("IAE " + o + " " + name + " " + value, ex2); + } catch (SecurityException ex1) { + if (dbg > 0) + d("SecurityException for " + o.getClass() + " " + name + "=" + + value + ")"); + if (dbg > 1) + ex1.printStackTrace(); + } catch (IllegalAccessException iae) { + if (dbg > 0) + d("IllegalAccessException for " + o.getClass() + " " + name + + "=" + value + ")"); + if (dbg > 1) + iae.printStackTrace(); + } catch (InvocationTargetException ie) { + if (dbg > 0) + d("InvocationTargetException for " + o.getClass() + " " + name + + "=" + value + ")"); + if (dbg > 1) + ie.printStackTrace(); + } + } + + public static Object getProperty(Object o, String name) { + String getter = "get" + capitalize(name); + String isGetter = "is" + capitalize(name); + + try { + Method methods[] = findMethods(o.getClass()); + Method getPropertyMethod = null; + + // First, the ideal case - a getFoo() method + for (int i = 0; i < methods.length; i++) { + Class paramT[] = methods[i].getParameterTypes(); + if (getter.equals(methods[i].getName()) && paramT.length == 0) { + return methods[i].invoke(o, (Object[]) null); + } + if (isGetter.equals(methods[i].getName()) && paramT.length == 0) { + return methods[i].invoke(o, (Object[]) null); + } + + if ("getProperty".equals(methods[i].getName())) { + getPropertyMethod = methods[i]; + } + } + + // Ok, no setXXX found, try a getProperty("name") + if (getPropertyMethod != null) { + Object params[] = new Object[1]; + params[0] = name; + return getPropertyMethod.invoke(o, params); + } + + } catch (IllegalArgumentException ex2) { + log.warn("IAE " + o + " " + name, ex2); + } catch (SecurityException ex1) { + if (dbg > 0) + d("SecurityException for " + o.getClass() + " " + name + ")"); + if (dbg > 1) + ex1.printStackTrace(); + } catch (IllegalAccessException iae) { + if (dbg > 0) + d("IllegalAccessException for " + o.getClass() + " " + name + + ")"); + if (dbg > 1) + iae.printStackTrace(); + } catch (InvocationTargetException ie) { + if (dbg > 0) + d("InvocationTargetException for " + o.getClass() + " " + name + + ")"); + if (dbg > 1) + ie.printStackTrace(); + } + return null; + } + + /** + */ + public static void setProperty(Object o, String name) { + String setter = "set" + capitalize(name); + try { + Method methods[] = findMethods(o.getClass()); + Method setPropertyMethod = null; + // find setFoo() method + for (int i = 0; i < methods.length; i++) { + Class paramT[] = methods[i].getParameterTypes(); + if (setter.equals(methods[i].getName()) && paramT.length == 0) { + methods[i].invoke(o, new Object[] {}); + return; + } + } + } catch (Exception ex1) { + if (dbg > 0) + d("Exception for " + o.getClass() + " " + name); + if (dbg > 1) + ex1.printStackTrace(); + } + } + + /** + * Replace ${NAME} with the property value + * + * @deprecated Use the explicit method + */ + public static String replaceProperties(String value, Object getter) { + if (getter instanceof Hashtable) + return replaceProperties(value, (Hashtable) getter, null); + + if (getter instanceof PropertySource) { + PropertySource src[] = new PropertySource[] { (PropertySource) getter }; + return replaceProperties(value, null, src); + } + return value; + } + + /** + * Replace ${NAME} with the property value + */ + public static String replaceProperties(String value, Hashtable staticProp, + PropertySource dynamicProp[]) { + StringBuffer sb = new StringBuffer(); + int prev = 0; + // assert value!=nil + int pos; + while ((pos = value.indexOf("$", prev)) >= 0) { + if (pos > 0) { + sb.append(value.substring(prev, pos)); + } + if (pos == (value.length() - 1)) { + sb.append('$'); + prev = pos + 1; + } else if (value.charAt(pos + 1) != '{') { + sb.append('$'); + prev = pos + 1; // XXX + } else { + int endName = value.indexOf('}', pos); + if (endName < 0) { + sb.append(value.substring(pos)); + prev = value.length(); + continue; + } + String n = value.substring(pos + 2, endName); + String v = null; + if (staticProp != null) { + v = (String) ((Hashtable) staticProp).get(n); + } + if (v == null && dynamicProp != null) { + for (int i = 0; i < dynamicProp.length; i++) { + v = dynamicProp[i].getProperty(n); + if (v != null) { + break; + } + } + } + if (v == null) + v = "${" + n + "}"; + + sb.append(v); + prev = endName + 1; + } + } + if (prev < value.length()) + sb.append(value.substring(prev)); + return sb.toString(); + } + + /** + * Reverse of Introspector.decapitalize + */ + public static String capitalize(String name) { + if (name == null || name.length() == 0) { + return name; + } + char chars[] = name.toCharArray(); + chars[0] = Character.toUpperCase(chars[0]); + return new String(chars); + } + + public static String unCapitalize(String name) { + if (name == null || name.length() == 0) { + return name; + } + char chars[] = name.toCharArray(); + chars[0] = Character.toLowerCase(chars[0]); + return new String(chars); + } + + // -------------------- Class path tools -------------------- + + /** + * Add all the jar files in a dir to the classpath, represented as a Vector + * of URLs. + */ + public static void addToClassPath(Vector cpV, String dir) { + try { + String cpComp[] = getFilesByExt(dir, ".jar"); + if (cpComp != null) { + int jarCount = cpComp.length; + for (int i = 0; i < jarCount; i++) { + URL url = getURL(dir, cpComp[i]); + if (url != null) + cpV.addElement(url); + } + } + } catch (Exception ex) { + ex.printStackTrace(); + } + } + + public static void addToolsJar(Vector v) { + try { + // Add tools.jar in any case + File f = new File(System.getProperty("java.home") + + "/../lib/tools.jar"); + + if (!f.exists()) { + // On some systems java.home gets set to the root of jdk. + // That's a bug, but we can work around and be nice. + f = new File(System.getProperty("java.home") + "/lib/tools.jar"); + if (f.exists()) { + if (log.isDebugEnabled()) + log.debug("Detected strange java.home value " + + System.getProperty("java.home") + + ", it should point to jre"); + } + } + URL url = new URL("file", "", f.getAbsolutePath()); + + v.addElement(url); + } catch (MalformedURLException ex) { + ex.printStackTrace(); + } + } + + /** + * Return all files with a given extension in a dir + */ + public static String[] getFilesByExt(String ld, String ext) { + File dir = new File(ld); + String[] names = null; + final String lext = ext; + if (dir.isDirectory()) { + names = dir.list(new FilenameFilter() { + public boolean accept(File d, String name) { + if (name.endsWith(lext)) { + return true; + } + return false; + } + }); + } + return names; + } + + /** + * Construct a file url from a file, using a base dir + */ + public static URL getURL(String base, String file) { + try { + File baseF = new File(base); + File f = new File(baseF, file); + String path = f.getCanonicalPath(); + if (f.isDirectory()) { + path += "/"; + } + if (!f.exists()) + return null; + return new URL("file", "", path); + } catch (Exception ex) { + ex.printStackTrace(); + return null; + } + } + + /** + * Add elements from the classpath cp to a Vector jars as + * file URLs (We use Vector for JDK 1.1 compat). + *

+ * + * @param jars The jar list + * @param cp a String classpath of directory or jar file elements + * separated by path.separator delimiters. + * @throws IOException If an I/O error occurs + * @throws MalformedURLException Doh ;) + */ + public static void addJarsFromClassPath(Vector jars, String cp) + throws IOException, MalformedURLException { + String sep = System.getProperty("path.separator"); + String token; + StringTokenizer st; + if (cp != null) { + st = new StringTokenizer(cp, sep); + while (st.hasMoreTokens()) { + File f = new File(st.nextToken()); + String path = f.getCanonicalPath(); + if (f.isDirectory()) { + path += "/"; + } + URL url = new URL("file", "", path); + if (!jars.contains(url)) { + jars.addElement(url); + } + } + } + } + + /** + * Return a URL[] that can be used to construct a class loader + */ + public static URL[] getClassPath(Vector v) { + URL[] urls = new URL[v.size()]; + for (int i = 0; i < v.size(); i++) { + urls[i] = (URL) v.elementAt(i); + } + return urls; + } + + /** + * Construct a URL classpath from files in a directory, a cpath property, + * and tools.jar. + */ + public static URL[] getClassPath(String dir, String cpath, + String cpathProp, boolean addTools) throws IOException, + MalformedURLException { + Vector jarsV = new Vector(); + if (dir != null) { + // Add dir/classes first, if it exists + URL url = getURL(dir, "classes"); + if (url != null) + jarsV.addElement(url); + addToClassPath(jarsV, dir); + } + + if (cpath != null) + addJarsFromClassPath(jarsV, cpath); + + if (cpathProp != null) { + String cpath1 = System.getProperty(cpathProp); + addJarsFromClassPath(jarsV, cpath1); + } + + if (addTools) + addToolsJar(jarsV); + + return getClassPath(jarsV); + } + + // -------------------- Mapping command line params to setters + + public static boolean processArgs(Object proxy, String args[]) + throws Exception { + String args0[] = null; + if (null != findMethod(proxy.getClass(), "getOptions1", new Class[] {})) { + args0 = (String[]) callMethod0(proxy, "getOptions1"); + } + + if (args0 == null) { + //args0=findVoidSetters(proxy.getClass()); + args0 = findBooleanSetters(proxy.getClass()); + } + Hashtable h = null; + if (null != findMethod(proxy.getClass(), "getOptionAliases", + new Class[] {})) { + h = (Hashtable) callMethod0(proxy, "getOptionAliases"); + } + return processArgs(proxy, args, args0, null, h); + } + + public static boolean processArgs(Object proxy, String args[], + String args0[], String args1[], Hashtable aliases) throws Exception { + for (int i = 0; i < args.length; i++) { + String arg = args[i]; + if (arg.startsWith("-")) + arg = arg.substring(1); + if (aliases != null && aliases.get(arg) != null) + arg = (String) aliases.get(arg); + + if (args0 != null) { + boolean set = false; + for (int j = 0; j < args0.length; j++) { + if (args0[j].equalsIgnoreCase(arg)) { + setProperty(proxy, args0[j], "true"); + set = true; + break; + } + } + if (set) + continue; + } + if (args1 != null) { + for (int j = 0; j < args1.length; j++) { + if (args1[j].equalsIgnoreCase(arg)) { + i++; + if (i >= args.length) + return false; + setProperty(proxy, arg, args[i]); + break; + } + } + } else { + // if args1 is not specified,assume all other options have param + i++; + if (i >= args.length) + return false; + setProperty(proxy, arg, args[i]); + } + + } + return true; + } + + // -------------------- other utils -------------------- + public static void clear() { + objectMethods.clear(); + } + + public static String[] findVoidSetters(Class c) { + Method m[] = findMethods(c); + if (m == null) + return null; + Vector v = new Vector(); + for (int i = 0; i < m.length; i++) { + if (m[i].getName().startsWith("set") + && m[i].getParameterTypes().length == 0) { + String arg = m[i].getName().substring(3); + v.addElement(unCapitalize(arg)); + } + } + String s[] = new String[v.size()]; + for (int i = 0; i < s.length; i++) { + s[i] = (String) v.elementAt(i); + } + return s; + } + + public static String[] findBooleanSetters(Class c) { + Method m[] = findMethods(c); + if (m == null) + return null; + Vector v = new Vector(); + for (int i = 0; i < m.length; i++) { + if (m[i].getName().startsWith("set") + && m[i].getParameterTypes().length == 1 + && "boolean".equalsIgnoreCase(m[i].getParameterTypes()[0] + .getName())) { + String arg = m[i].getName().substring(3); + v.addElement(unCapitalize(arg)); + } + } + String s[] = new String[v.size()]; + for (int i = 0; i < s.length; i++) { + s[i] = (String) v.elementAt(i); + } + return s; + } + + static Hashtable objectMethods = new Hashtable(); + + public static Method[] findMethods(Class c) { + Method methods[] = (Method[]) objectMethods.get(c); + if (methods != null) + return methods; + + methods = c.getMethods(); + objectMethods.put(c, methods); + return methods; + } + + public static Method findMethod(Class c, String name, Class params[]) { + Method methods[] = findMethods(c); + if (methods == null) + return null; + for (int i = 0; i < methods.length; i++) { + if (methods[i].getName().equals(name)) { + Class methodParams[] = methods[i].getParameterTypes(); + if (methodParams == null) + if (params == null || params.length == 0) + return methods[i]; + if (params == null) + if (methodParams == null || methodParams.length == 0) + return methods[i]; + if (params.length != methodParams.length) + continue; + boolean found = true; + for (int j = 0; j < params.length; j++) { + if (params[j] != methodParams[j]) { + found = false; + break; + } + } + if (found) + return methods[i]; + } + } + return null; + } + + /** Test if the object implements a particular + * method + */ + public static boolean hasHook(Object obj, String methodN) { + try { + Method myMethods[] = findMethods(obj.getClass()); + for (int i = 0; i < myMethods.length; i++) { + if (methodN.equals(myMethods[i].getName())) { + // check if it's overriden + Class declaring = myMethods[i].getDeclaringClass(); + Class parentOfDeclaring = declaring.getSuperclass(); + // this works only if the base class doesn't extend + // another class. + + // if the method is declared in a top level class + // like BaseInterceptor parent is Object, otherwise + // parent is BaseInterceptor or an intermediate class + if (!"java.lang.Object".equals(parentOfDeclaring.getName())) { + return true; + } + } + } + } catch (Exception ex) { + ex.printStackTrace(); + } + return false; + } + + public static void callMain(Class c, String args[]) throws Exception { + Class p[] = new Class[1]; + p[0] = args.getClass(); + Method m = c.getMethod("main", p); + m.invoke(c, new Object[] { args }); + } + + public static Object callMethod1(Object target, String methodN, + Object param1, String typeParam1, ClassLoader cl) throws Exception { + if (target == null || param1 == null) { + d("Assert: Illegal params " + target + " " + param1); + } + if (dbg > 0) + d("callMethod1 " + target.getClass().getName() + " " + + param1.getClass().getName() + " " + typeParam1); + + Class params[] = new Class[1]; + if (typeParam1 == null) + params[0] = param1.getClass(); + else + params[0] = cl.loadClass(typeParam1); + Method m = findMethod(target.getClass(), methodN, params); + if (m == null) + throw new NoSuchMethodException(target.getClass().getName() + " " + + methodN); + return m.invoke(target, new Object[] { param1 }); + } + + public static Object callMethod0(Object target, String methodN) + throws Exception { + if (target == null) { + d("Assert: Illegal params " + target); + return null; + } + if (dbg > 0) + d("callMethod0 " + target.getClass().getName() + "." + methodN); + + Class params[] = new Class[0]; + Method m = findMethod(target.getClass(), methodN, params); + if (m == null) + throw new NoSuchMethodException(target.getClass().getName() + " " + + methodN); + return m.invoke(target, emptyArray); + } + + static Object[] emptyArray = new Object[] {}; + + public static Object callMethodN(Object target, String methodN, + Object params[], Class typeParams[]) throws Exception { + Method m = null; + m = findMethod(target.getClass(), methodN, typeParams); + if (m == null) { + d("Can't find method " + methodN + " in " + target + " CLASS " + + target.getClass()); + return null; + } + Object o = m.invoke(target, params); + + if (dbg > 0) { + // debug + StringBuffer sb = new StringBuffer(); + sb.append("" + target.getClass().getName() + "." + methodN + "( "); + for (int i = 0; i < params.length; i++) { + if (i > 0) + sb.append(", "); + sb.append(params[i]); + } + sb.append(")"); + d(sb.toString()); + } + return o; + } + + public static Object convert(String object, Class paramType) { + Object result = null; + if ("java.lang.String".equals(paramType.getName())) { + result = object; + } else if ("java.lang.Integer".equals(paramType.getName()) + || "int".equals(paramType.getName())) { + try { + result = new Integer(object); + } catch (NumberFormatException ex) { + } + // Try a setFoo ( boolean ) + } else if ("java.lang.Boolean".equals(paramType.getName()) + || "boolean".equals(paramType.getName())) { + result = new Boolean(object); + + // Try a setFoo ( InetAddress ) + } else if ("java.net.InetAddress".equals(paramType + .getName())) { + try { + result = InetAddress.getByName(object); + } catch (UnknownHostException exc) { + d("Unable to resolve host name:" + object); + } + + // Unknown type + } else { + d("Unknown type " + paramType.getName()); + } + if (result == null) { + throw new IllegalArgumentException("Can't convert argument: " + object); + } + return result; + } + + // -------------------- Get property -------------------- + // This provides a layer of abstraction + + public static interface PropertySource { + + public String getProperty(String key); + + } + + public static interface AttributeHolder { + + public void setAttribute(String key, Object o); + + } + + // debug -------------------- + static final int dbg = 0; + + static void d(String s) { + if (log.isDebugEnabled()) + log.debug("IntrospectionUtils: " + s); + } +} diff --git a/test/org/apache/catalina/tribes/demos/LoadTest.java b/test/org/apache/catalina/tribes/demos/LoadTest.java index e9a990ed2..eab3c5167 100644 --- a/test/org/apache/catalina/tribes/demos/LoadTest.java +++ b/test/org/apache/catalina/tribes/demos/LoadTest.java @@ -1,425 +1,425 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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 - * limitations under the License. - */ -package org.apache.catalina.tribes.demos; - -import java.io.Serializable; -import java.util.Random; - -import org.apache.catalina.tribes.ByteMessage; -import org.apache.catalina.tribes.ChannelException; -import org.apache.catalina.tribes.ChannelListener; -import org.apache.catalina.tribes.ManagedChannel; -import org.apache.catalina.tribes.Member; -import org.apache.catalina.tribes.MembershipListener; -import org.apache.catalina.tribes.io.XByteBuffer; -import org.apache.catalina.tribes.Channel; -import java.io.Externalizable; - - -/** - *

Title:

- * - *

Description:

- * - *

Copyright: Copyright (c) 2005

- * - *

Company:

- * - * @author not attributable - * @version 1.0 - */ -public class LoadTest implements MembershipListener,ChannelListener, Runnable { - protected static org.apache.commons.logging.Log log = org.apache.commons.logging.LogFactory.getLog(LoadTest.class); - public static int size = 24000; - public static Object mutex = new Object(); - public boolean doRun = true; - - public long bytesReceived = 0; - public float mBytesReceived = 0; - public int messagesReceived = 0; - public boolean send = true; - public boolean debug = false; - public int msgCount = 100; - ManagedChannel channel=null; - public int statsInterval = 10000; - public long pause = 0; - public boolean breakonChannelException = false; - public boolean async = false; - public long receiveStart = 0; - public int channelOptions = Channel.SEND_OPTIONS_DEFAULT; - - static int messageSize = 0; - - public static long messagesSent = 0; - public static long messageStartSendTime = 0; - public static long messageEndSendTime = 0; - public static int threadCount = 0; - - public static synchronized void startTest() { - threadCount++; - if ( messageStartSendTime == 0 ) messageStartSendTime = System.currentTimeMillis(); - } - - public static synchronized void endTest() { - threadCount--; - if ( messageEndSendTime == 0 && threadCount==0 ) messageEndSendTime = System.currentTimeMillis(); - } - - - public static synchronized long addSendStats(long count) { - messagesSent+=count; - return 0l; - } - - private static void printSendStats(long counter, int messageSize) { - float cnt = (float)counter; - float size = (float)messageSize; - float time = (float)(System.currentTimeMillis()-messageStartSendTime) / 1000f; - log.info("****SEND STATS-"+Thread.currentThread().getName()+"*****"+ - "\n\tMessage count:"+counter+ - "\n\tTotal bytes :"+(long)(size*cnt)+ - "\n\tTotal seconds:"+(time)+ - "\n\tBytes/second :"+(size*cnt/time)+ - "\n\tMBytes/second:"+(size*cnt/time/1024f/1024f)); - } - - - - public LoadTest(ManagedChannel channel, - boolean send, - int msgCount, - boolean debug, - long pause, - int stats, - boolean breakOnEx) { - this.channel = channel; - this.send = send; - this.msgCount = msgCount; - this.debug = debug; - this.pause = pause; - this.statsInterval = stats; - this.breakonChannelException = breakOnEx; - } - - - - public void run() { - - long counter = 0; - long total = 0; - LoadMessage msg = new LoadMessage(); - int messageSize = LoadTest.messageSize; - - try { - startTest(); - while (total < msgCount) { - if (channel.getMembers().length == 0 || (!send)) { - synchronized (mutex) { - try { - mutex.wait(); - } catch (InterruptedException x) { - log.info("Thread interrupted from wait"); - } - } - } else { - try { - //msg.setMsgNr((int)++total); - counter++; - if (debug) { - printArray(msg.getMessage()); - } - channel.send(channel.getMembers(), msg, channelOptions); - if ( pause > 0 ) { - if ( debug) System.out.println("Pausing sender for "+pause+" ms."); - Thread.sleep(pause); - } - } catch (ChannelException x) { - if ( debug ) log.error("Unable to send message:"+x.getMessage(),x); - log.error("Unable to send message:"+x.getMessage()); - ChannelException.FaultyMember[] faulty = x.getFaultyMembers(); - for (int i=0; i 0)) { - //add to the global counter - counter = addSendStats(counter); - //print from the global counter - //printSendStats(LoadTest.messagesSent, LoadTest.messageSize, LoadTest.messageSendTime); - printSendStats(LoadTest.messagesSent, LoadTest.messageSize); - - } - - } - }catch ( Exception x ) { - log.error("Captured error while sending:"+x.getMessage()); - if ( debug ) log.error("",x); - printSendStats(LoadTest.messagesSent, LoadTest.messageSize); - } - endTest(); - } - - - - /** - * memberAdded - * - * @param member Member - * @todo Implement this org.apache.catalina.tribes.MembershipListener - * method - */ - public void memberAdded(Member member) { - log.info("Member added:"+member); - synchronized (mutex) { - mutex.notifyAll(); - } - } - - /** - * memberDisappeared - * - * @param member Member - * @todo Implement this org.apache.catalina.tribes.MembershipListener - * method - */ - public void memberDisappeared(Member member) { - log.info("Member disappeared:"+member); - } - - public boolean accept(Serializable msg, Member mbr){ - return (msg instanceof LoadMessage) || (msg instanceof ByteMessage); - } - - public void messageReceived(Serializable msg, Member mbr){ - if ( receiveStart == 0 ) receiveStart = System.currentTimeMillis(); - if ( debug ) { - if ( msg instanceof LoadMessage ) { - printArray(((LoadMessage)msg).getMessage()); - } - } - - if ( msg instanceof ByteMessage && !(msg instanceof LoadMessage)) { - LoadMessage tmp = new LoadMessage(); - tmp.setMessage(((ByteMessage)msg).getMessage()); - msg = tmp; - tmp = null; - } - - - bytesReceived+=((LoadMessage)msg).getMessage().length; - mBytesReceived+=((float)((LoadMessage)msg).getMessage().length)/1024f/1024f; - messagesReceived++; - if ( (messagesReceived%statsInterval)==0 || (messagesReceived==msgCount)) { - float bytes = (float)(((LoadMessage)msg).getMessage().length*messagesReceived); - float seconds = ((float)(System.currentTimeMillis()-receiveStart)) / 1000f; - log.info("****RECEIVE STATS-"+Thread.currentThread().getName()+"*****"+ - "\n\tMessage count :"+(long)messagesReceived+ - "\n\tTotal bytes :"+(long)bytes+ - "\n\tTotal mbytes :"+(long)mBytesReceived+ - "\n\tTime since 1st:"+seconds+" seconds"+ - "\n\tBytes/second :"+(bytes/seconds)+ - "\n\tMBytes/second :"+(mBytesReceived/seconds)+"\n"); - - } - } - - - public static void printArray(byte[] data) { - System.out.print("{"); - for (int i=0; i 1 ) { - Thread t = new Thread(test); - t.setDaemon(true); - t.start(); - threads--; - test = new LoadTest(channel,send,count,debug,pause,stats,breakOnEx); - test.channelOptions = channelOptions; - } - test.run(); - if ( shutdown && send ) channel.stop(channel.DEFAULT); - System.out.println("System test complete, sleeping to let threads finish."); - Thread.sleep(60*1000*60); - } - - public static class Shutdown extends Thread { - ManagedChannel channel = null; - public Shutdown(ManagedChannel channel) { - this.channel = channel; - } - - public void run() { - System.out.println("Shutting down..."); - SystemExit exit = new SystemExit(5000); - exit.setDaemon(true); - exit.start(); - try { - channel.stop(channel.DEFAULT); - - }catch ( Exception x ) { - x.printStackTrace(); - } - System.out.println("Channel stopped."); - } - } - public static class SystemExit extends Thread { - private long delay; - public SystemExit(long delay) { - this.delay = delay; - } - public void run () { - try { - Thread.sleep(delay); - }catch ( Exception x ) { - x.printStackTrace(); - } - System.exit(0); - - } - } - +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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 + * limitations under the License. + */ +package org.apache.catalina.tribes.demos; + +import java.io.Serializable; +import java.util.Random; + +import org.apache.catalina.tribes.ByteMessage; +import org.apache.catalina.tribes.ChannelException; +import org.apache.catalina.tribes.ChannelListener; +import org.apache.catalina.tribes.ManagedChannel; +import org.apache.catalina.tribes.Member; +import org.apache.catalina.tribes.MembershipListener; +import org.apache.catalina.tribes.io.XByteBuffer; +import org.apache.catalina.tribes.Channel; +import java.io.Externalizable; + + +/** + *

Title:

+ * + *

Description:

+ * + *

Copyright: Copyright (c) 2005

+ * + *

Company:

+ * + * @author not attributable + * @version 1.0 + */ +public class LoadTest implements MembershipListener,ChannelListener, Runnable { + protected static org.apache.commons.logging.Log log = org.apache.commons.logging.LogFactory.getLog(LoadTest.class); + public static int size = 24000; + public static Object mutex = new Object(); + public boolean doRun = true; + + public long bytesReceived = 0; + public float mBytesReceived = 0; + public int messagesReceived = 0; + public boolean send = true; + public boolean debug = false; + public int msgCount = 100; + ManagedChannel channel=null; + public int statsInterval = 10000; + public long pause = 0; + public boolean breakonChannelException = false; + public boolean async = false; + public long receiveStart = 0; + public int channelOptions = Channel.SEND_OPTIONS_DEFAULT; + + static int messageSize = 0; + + public static long messagesSent = 0; + public static long messageStartSendTime = 0; + public static long messageEndSendTime = 0; + public static int threadCount = 0; + + public static synchronized void startTest() { + threadCount++; + if ( messageStartSendTime == 0 ) messageStartSendTime = System.currentTimeMillis(); + } + + public static synchronized void endTest() { + threadCount--; + if ( messageEndSendTime == 0 && threadCount==0 ) messageEndSendTime = System.currentTimeMillis(); + } + + + public static synchronized long addSendStats(long count) { + messagesSent+=count; + return 0l; + } + + private static void printSendStats(long counter, int messageSize) { + float cnt = (float)counter; + float size = (float)messageSize; + float time = (float)(System.currentTimeMillis()-messageStartSendTime) / 1000f; + log.info("****SEND STATS-"+Thread.currentThread().getName()+"*****"+ + "\n\tMessage count:"+counter+ + "\n\tTotal bytes :"+(long)(size*cnt)+ + "\n\tTotal seconds:"+(time)+ + "\n\tBytes/second :"+(size*cnt/time)+ + "\n\tMBytes/second:"+(size*cnt/time/1024f/1024f)); + } + + + + public LoadTest(ManagedChannel channel, + boolean send, + int msgCount, + boolean debug, + long pause, + int stats, + boolean breakOnEx) { + this.channel = channel; + this.send = send; + this.msgCount = msgCount; + this.debug = debug; + this.pause = pause; + this.statsInterval = stats; + this.breakonChannelException = breakOnEx; + } + + + + public void run() { + + long counter = 0; + long total = 0; + LoadMessage msg = new LoadMessage(); + int messageSize = LoadTest.messageSize; + + try { + startTest(); + while (total < msgCount) { + if (channel.getMembers().length == 0 || (!send)) { + synchronized (mutex) { + try { + mutex.wait(); + } catch (InterruptedException x) { + log.info("Thread interrupted from wait"); + } + } + } else { + try { + //msg.setMsgNr((int)++total); + counter++; + if (debug) { + printArray(msg.getMessage()); + } + channel.send(channel.getMembers(), msg, channelOptions); + if ( pause > 0 ) { + if ( debug) System.out.println("Pausing sender for "+pause+" ms."); + Thread.sleep(pause); + } + } catch (ChannelException x) { + if ( debug ) log.error("Unable to send message:"+x.getMessage(),x); + log.error("Unable to send message:"+x.getMessage()); + ChannelException.FaultyMember[] faulty = x.getFaultyMembers(); + for (int i=0; i 0)) { + //add to the global counter + counter = addSendStats(counter); + //print from the global counter + //printSendStats(LoadTest.messagesSent, LoadTest.messageSize, LoadTest.messageSendTime); + printSendStats(LoadTest.messagesSent, LoadTest.messageSize); + + } + + } + }catch ( Exception x ) { + log.error("Captured error while sending:"+x.getMessage()); + if ( debug ) log.error("",x); + printSendStats(LoadTest.messagesSent, LoadTest.messageSize); + } + endTest(); + } + + + + /** + * memberAdded + * + * @param member Member + * @todo Implement this org.apache.catalina.tribes.MembershipListener + * method + */ + public void memberAdded(Member member) { + log.info("Member added:"+member); + synchronized (mutex) { + mutex.notifyAll(); + } + } + + /** + * memberDisappeared + * + * @param member Member + * @todo Implement this org.apache.catalina.tribes.MembershipListener + * method + */ + public void memberDisappeared(Member member) { + log.info("Member disappeared:"+member); + } + + public boolean accept(Serializable msg, Member mbr){ + return (msg instanceof LoadMessage) || (msg instanceof ByteMessage); + } + + public void messageReceived(Serializable msg, Member mbr){ + if ( receiveStart == 0 ) receiveStart = System.currentTimeMillis(); + if ( debug ) { + if ( msg instanceof LoadMessage ) { + printArray(((LoadMessage)msg).getMessage()); + } + } + + if ( msg instanceof ByteMessage && !(msg instanceof LoadMessage)) { + LoadMessage tmp = new LoadMessage(); + tmp.setMessage(((ByteMessage)msg).getMessage()); + msg = tmp; + tmp = null; + } + + + bytesReceived+=((LoadMessage)msg).getMessage().length; + mBytesReceived+=((float)((LoadMessage)msg).getMessage().length)/1024f/1024f; + messagesReceived++; + if ( (messagesReceived%statsInterval)==0 || (messagesReceived==msgCount)) { + float bytes = (float)(((LoadMessage)msg).getMessage().length*messagesReceived); + float seconds = ((float)(System.currentTimeMillis()-receiveStart)) / 1000f; + log.info("****RECEIVE STATS-"+Thread.currentThread().getName()+"*****"+ + "\n\tMessage count :"+(long)messagesReceived+ + "\n\tTotal bytes :"+(long)bytes+ + "\n\tTotal mbytes :"+(long)mBytesReceived+ + "\n\tTime since 1st:"+seconds+" seconds"+ + "\n\tBytes/second :"+(bytes/seconds)+ + "\n\tMBytes/second :"+(mBytesReceived/seconds)+"\n"); + + } + } + + + public static void printArray(byte[] data) { + System.out.print("{"); + for (int i=0; i 1 ) { + Thread t = new Thread(test); + t.setDaemon(true); + t.start(); + threads--; + test = new LoadTest(channel,send,count,debug,pause,stats,breakOnEx); + test.channelOptions = channelOptions; + } + test.run(); + if ( shutdown && send ) channel.stop(channel.DEFAULT); + System.out.println("System test complete, sleeping to let threads finish."); + Thread.sleep(60*1000*60); + } + + public static class Shutdown extends Thread { + ManagedChannel channel = null; + public Shutdown(ManagedChannel channel) { + this.channel = channel; + } + + public void run() { + System.out.println("Shutting down..."); + SystemExit exit = new SystemExit(5000); + exit.setDaemon(true); + exit.start(); + try { + channel.stop(channel.DEFAULT); + + }catch ( Exception x ) { + x.printStackTrace(); + } + System.out.println("Channel stopped."); + } + } + public static class SystemExit extends Thread { + private long delay; + public SystemExit(long delay) { + this.delay = delay; + } + public void run () { + try { + Thread.sleep(delay); + }catch ( Exception x ) { + x.printStackTrace(); + } + System.exit(0); + + } + } + } \ No newline at end of file diff --git a/test/org/apache/catalina/tribes/test/channel/ChannelStartStop.java b/test/org/apache/catalina/tribes/test/channel/ChannelStartStop.java index f47aaf690..e514001a5 100644 --- a/test/org/apache/catalina/tribes/test/channel/ChannelStartStop.java +++ b/test/org/apache/catalina/tribes/test/channel/ChannelStartStop.java @@ -1,119 +1,119 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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.channel; - -import org.apache.catalina.tribes.group.GroupChannel; -import junit.framework.TestCase; - -/** - * @author Filip Hanik - * @version 1.0 - */ -public class ChannelStartStop extends TestCase { - GroupChannel channel = null; - protected void setUp() throws Exception { - super.setUp(); - channel = new GroupChannel(); - } - - protected void tearDown() throws Exception { - super.tearDown(); - try {channel.stop(channel.DEFAULT);}catch (Exception ignore){} - } - - public void testDoubleFullStart() throws Exception { - int count = 0; - try { - channel.start(channel.DEFAULT); - count++; - } catch ( Exception x){x.printStackTrace();} - try { - channel.start(channel.DEFAULT); - count++; - } catch ( Exception x){x.printStackTrace();} - assertEquals(count,2); - channel.stop(channel.DEFAULT); - } - - public void testDoublePartialStart() throws Exception { - //try to double start the RX - int count = 0; - try { - channel.start(channel.SND_RX_SEQ); - channel.start(channel.MBR_RX_SEQ); - count++; - } catch ( Exception x){x.printStackTrace();} - try { - channel.start(channel.MBR_RX_SEQ); - count++; - } catch ( Exception x){/*expected*/} - assertEquals(count,1); - channel.stop(channel.DEFAULT); - //double the membership sender - count = 0; - try { - channel.start(channel.SND_RX_SEQ); - channel.start(channel.MBR_TX_SEQ); - count++; - } catch ( Exception x){x.printStackTrace();} - try { - channel.start(channel.MBR_TX_SEQ); - count++; - } catch ( Exception x){/*expected*/} - assertEquals(count,1); - channel.stop(channel.DEFAULT); - - count = 0; - try { - channel.start(channel.SND_RX_SEQ); - count++; - } catch ( Exception x){x.printStackTrace();} - try { - channel.start(channel.SND_RX_SEQ); - count++; - } catch ( Exception x){/*expected*/} - assertEquals(count,1); - channel.stop(channel.DEFAULT); - - count = 0; - try { - channel.start(channel.SND_TX_SEQ); - count++; - } catch ( Exception x){x.printStackTrace();} - try { - channel.start(channel.SND_TX_SEQ); - count++; - } catch ( Exception x){/*expected*/} - assertEquals(count,1); - channel.stop(channel.DEFAULT); - } - - public void testFalseOption() throws Exception { - int flag = 0xFFF0;//should get ignored by the underlying components - int count = 0; - try { - channel.start(flag); - count++; - } catch ( Exception x){x.printStackTrace();} - try { - channel.start(flag); - count++; - } catch ( Exception x){/*expected*/} - assertEquals(count,2); - channel.stop(channel.DEFAULT); - } - -} +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.channel; + +import org.apache.catalina.tribes.group.GroupChannel; +import junit.framework.TestCase; + +/** + * @author Filip Hanik + * @version 1.0 + */ +public class ChannelStartStop extends TestCase { + GroupChannel channel = null; + protected void setUp() throws Exception { + super.setUp(); + channel = new GroupChannel(); + } + + protected void tearDown() throws Exception { + super.tearDown(); + try {channel.stop(channel.DEFAULT);}catch (Exception ignore){} + } + + public void testDoubleFullStart() throws Exception { + int count = 0; + try { + channel.start(channel.DEFAULT); + count++; + } catch ( Exception x){x.printStackTrace();} + try { + channel.start(channel.DEFAULT); + count++; + } catch ( Exception x){x.printStackTrace();} + assertEquals(count,2); + channel.stop(channel.DEFAULT); + } + + public void testDoublePartialStart() throws Exception { + //try to double start the RX + int count = 0; + try { + channel.start(channel.SND_RX_SEQ); + channel.start(channel.MBR_RX_SEQ); + count++; + } catch ( Exception x){x.printStackTrace();} + try { + channel.start(channel.MBR_RX_SEQ); + count++; + } catch ( Exception x){/*expected*/} + assertEquals(count,1); + channel.stop(channel.DEFAULT); + //double the membership sender + count = 0; + try { + channel.start(channel.SND_RX_SEQ); + channel.start(channel.MBR_TX_SEQ); + count++; + } catch ( Exception x){x.printStackTrace();} + try { + channel.start(channel.MBR_TX_SEQ); + count++; + } catch ( Exception x){/*expected*/} + assertEquals(count,1); + channel.stop(channel.DEFAULT); + + count = 0; + try { + channel.start(channel.SND_RX_SEQ); + count++; + } catch ( Exception x){x.printStackTrace();} + try { + channel.start(channel.SND_RX_SEQ); + count++; + } catch ( Exception x){/*expected*/} + assertEquals(count,1); + channel.stop(channel.DEFAULT); + + count = 0; + try { + channel.start(channel.SND_TX_SEQ); + count++; + } catch ( Exception x){x.printStackTrace();} + try { + channel.start(channel.SND_TX_SEQ); + count++; + } catch ( Exception x){/*expected*/} + assertEquals(count,1); + channel.stop(channel.DEFAULT); + } + + public void testFalseOption() throws Exception { + int flag = 0xFFF0;//should get ignored by the underlying components + int count = 0; + try { + channel.start(flag); + count++; + } catch ( Exception x){x.printStackTrace();} + try { + channel.start(flag); + count++; + } catch ( Exception x){/*expected*/} + assertEquals(count,2); + channel.stop(channel.DEFAULT); + } + +} diff --git a/test/org/apache/catalina/tribes/test/channel/TestRemoteProcessException.java b/test/org/apache/catalina/tribes/test/channel/TestRemoteProcessException.java index 1200d0b9b..be1085bef 100644 --- a/test/org/apache/catalina/tribes/test/channel/TestRemoteProcessException.java +++ b/test/org/apache/catalina/tribes/test/channel/TestRemoteProcessException.java @@ -1,123 +1,123 @@ -package org.apache.catalina.tribes.test.channel; - -import junit.framework.TestCase; -import java.io.Serializable; -import java.util.Random; -import java.util.Arrays; -import org.apache.catalina.tribes.ChannelListener; -import org.apache.catalina.tribes.Member; -import org.apache.catalina.tribes.group.GroupChannel; -import java.io.PrintStream; - -/** - *

Title:

- * - *

Description:

- * - *

Copyright: Copyright (c) 2005

- * - *

Company:

- * - * @author not attributable - * @version 1.0 - */ -public class TestRemoteProcessException extends TestCase { - int msgCount = 10000; - GroupChannel channel1; - GroupChannel channel2; - Listener listener1; - protected void setUp() throws Exception { - super.setUp(); - channel1 = new GroupChannel(); - channel2 = new GroupChannel(); - listener1 = new Listener(); - channel2.addChannelListener(listener1); - channel1.start(GroupChannel.DEFAULT); - channel2.start(GroupChannel.DEFAULT); - } - - protected void tearDown() throws Exception { - super.tearDown(); - channel1.stop(GroupChannel.DEFAULT); - channel2.stop(GroupChannel.DEFAULT); - } - - public void testDataSendSYNCACK() throws Exception { - System.err.println("Starting SYNC_ACK"); - int errC=0, nerrC=0; - for (int i=0; iTitle:

+ * + *

Description:

+ * + *

Copyright: Copyright (c) 2005

+ * + *

Company:

+ * + * @author not attributable + * @version 1.0 + */ +public class TestRemoteProcessException extends TestCase { + int msgCount = 10000; + GroupChannel channel1; + GroupChannel channel2; + Listener listener1; + protected void setUp() throws Exception { + super.setUp(); + channel1 = new GroupChannel(); + channel2 = new GroupChannel(); + listener1 = new Listener(); + channel2.addChannelListener(listener1); + channel1.start(GroupChannel.DEFAULT); + channel2.start(GroupChannel.DEFAULT); + } + + protected void tearDown() throws Exception { + super.tearDown(); + channel1.stop(GroupChannel.DEFAULT); + channel2.stop(GroupChannel.DEFAULT); + } + + public void testDataSendSYNCACK() throws Exception { + System.err.println("Starting SYNC_ACK"); + int errC=0, nerrC=0; + for (int i=0; iTitle:

- * - *

Description:

- * - *

Copyright: Copyright (c) 2005

- * - *

Company:

- * - * @author not attributable - * @version 1.0 - */ -public class TestTwoPhaseCommit extends TestCase { - - protected void setUp() throws Exception { - super.setUp(); - } - - protected void tearDown() throws Exception { - super.tearDown(); - } - -} +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.interceptors; + +import junit.framework.TestCase; + +/** + *

Title:

+ * + *

Description:

+ * + *

Copyright: Copyright (c) 2005

+ * + *

Company:

+ * + * @author not attributable + * @version 1.0 + */ +public class TestTwoPhaseCommit extends TestCase { + + protected void setUp() throws Exception { + super.setUp(); + } + + protected void tearDown() throws Exception { + super.tearDown(); + } + +} diff --git a/test/org/apache/catalina/tribes/test/membership/MemberSerialization.java b/test/org/apache/catalina/tribes/test/membership/MemberSerialization.java index 97cca2a7b..6720231ba 100644 --- a/test/org/apache/catalina/tribes/test/membership/MemberSerialization.java +++ b/test/org/apache/catalina/tribes/test/membership/MemberSerialization.java @@ -1,101 +1,101 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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; - -/** - *

Title:

- * - *

Description:

- * - *

Copyright: Copyright (c) 2005

- * - *

Company:

- * - * @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("127.0.0.1",3333,1,payload); - p2 = new MemberImpl("localhost",3331,1,payload); - m1.setDomain(new byte[] {1,2,3,4,5,6,7,8,9}); - m2.setDomain(new byte[] {1,2,3,4,5,6,7,8,9}); - m1.setCommand(new byte[] {1,2,4,5,6,7,8,9}); - m2.setCommand(new byte[] {1,2,4,5,6,7,8,9}); - } - - 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,false); - assertTrue(Arrays.equals(md1,mda1)); - assertTrue(md1==mda1); - mda1 = m.getData(true,true); - 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)); - - md1 = m.getData(true,true); - Thread.sleep(50); - mda1 = m.getData(true,true); - MemberImpl a1 = MemberImpl.getMember(md1); - MemberImpl a2 = MemberImpl.getMember(mda1); - assertTrue(a1.equals(a2)); - assertFalse(Arrays.equals(md1,mda1)); - - - } - - 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(); - } - -} +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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; + +/** + *

Title:

+ * + *

Description:

+ * + *

Copyright: Copyright (c) 2005

+ * + *

Company:

+ * + * @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("127.0.0.1",3333,1,payload); + p2 = new MemberImpl("localhost",3331,1,payload); + m1.setDomain(new byte[] {1,2,3,4,5,6,7,8,9}); + m2.setDomain(new byte[] {1,2,3,4,5,6,7,8,9}); + m1.setCommand(new byte[] {1,2,4,5,6,7,8,9}); + m2.setCommand(new byte[] {1,2,4,5,6,7,8,9}); + } + + 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,false); + assertTrue(Arrays.equals(md1,mda1)); + assertTrue(md1==mda1); + mda1 = m.getData(true,true); + 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)); + + md1 = m.getData(true,true); + Thread.sleep(50); + mda1 = m.getData(true,true); + MemberImpl a1 = MemberImpl.getMember(md1); + MemberImpl a2 = MemberImpl.getMember(mda1); + assertTrue(a1.equals(a2)); + assertFalse(Arrays.equals(md1,mda1)); + + + } + + 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(); + } + +} diff --git a/test/org/apache/catalina/tribes/test/membership/TestDomainFilter.java b/test/org/apache/catalina/tribes/test/membership/TestDomainFilter.java index ca3c75240..8b2181cfd 100644 --- a/test/org/apache/catalina/tribes/test/membership/TestDomainFilter.java +++ b/test/org/apache/catalina/tribes/test/membership/TestDomainFilter.java @@ -1,104 +1,104 @@ -package org.apache.catalina.tribes.test.membership; - -import java.util.ArrayList; - -import org.apache.catalina.tribes.Channel; -import org.apache.catalina.tribes.ManagedChannel; -import org.apache.catalina.tribes.Member; -import org.apache.catalina.tribes.MembershipListener; -import org.apache.catalina.tribes.group.GroupChannel; -import junit.framework.TestCase; -import org.apache.catalina.tribes.group.interceptors.DomainFilterInterceptor; -import org.apache.catalina.tribes.util.UUIDGenerator; - -public class TestDomainFilter - extends TestCase { - private static int count = 10; - private ManagedChannel[] channels = new ManagedChannel[count]; - private TestMbrListener[] listeners = new TestMbrListener[count]; - - protected void setUp() throws Exception { - super.setUp(); - for (int i = 0; i < channels.length; i++) { - channels[i] = new GroupChannel(); - channels[i].getMembershipService().setPayload( ("Channel-" + (i + 1)).getBytes("ASCII")); - listeners[i] = new TestMbrListener( ("Listener-" + (i + 1))); - channels[i].addMembershipListener(listeners[i]); - DomainFilterInterceptor filter = new DomainFilterInterceptor(); - filter.setDomain(UUIDGenerator.randomUUID(false)); - channels[i].addInterceptor(filter); - } - } - - public void clear() { - for (int i = 0; i < channels.length; i++) { - listeners[i].members.clear(); - } - } - - public void testMemberArrival() throws Exception { - //purpose of this test is to make sure that we have received all the members - //that we can expect before the start method returns - Thread[] threads = new Thread[channels.length]; - for (int i=0; i=0; i-- ) assertEquals("Checking member arrival length",0,listeners[i].members.size()); - } - - protected void tearDown() throws Exception { - - for (int i = 0; i < channels.length; i++) { - try { - channels[i].stop(Channel.DEFAULT); - } catch (Exception ignore) {} - } - super.tearDown(); - } - - public class TestMbrListener - implements MembershipListener { - public String name = null; - public TestMbrListener(String name) { - this.name = name; - } - - public ArrayList members = new ArrayList(); - public void memberAdded(Member member) { - if (!members.contains(member)) { - members.add(member); - try { - System.out.println(name + ":member added[" + new String(member.getPayload(), "ASCII") + "; Thread:"+Thread.currentThread().getName()+"]"); - } catch (Exception x) { - System.out.println(name + ":member added[unknown]"); - } - } - } - - public void memberDisappeared(Member member) { - if (members.contains(member)) { - members.remove(member); - try { - System.out.println(name + ":member disappeared[" + new String(member.getPayload(), "ASCII") + "; Thread:"+Thread.currentThread().getName()+"]"); - } catch (Exception x) { - System.out.println(name + ":member disappeared[unknown]"); - } - } - } - - } - -} +package org.apache.catalina.tribes.test.membership; + +import java.util.ArrayList; + +import org.apache.catalina.tribes.Channel; +import org.apache.catalina.tribes.ManagedChannel; +import org.apache.catalina.tribes.Member; +import org.apache.catalina.tribes.MembershipListener; +import org.apache.catalina.tribes.group.GroupChannel; +import junit.framework.TestCase; +import org.apache.catalina.tribes.group.interceptors.DomainFilterInterceptor; +import org.apache.catalina.tribes.util.UUIDGenerator; + +public class TestDomainFilter + extends TestCase { + private static int count = 10; + private ManagedChannel[] channels = new ManagedChannel[count]; + private TestMbrListener[] listeners = new TestMbrListener[count]; + + protected void setUp() throws Exception { + super.setUp(); + for (int i = 0; i < channels.length; i++) { + channels[i] = new GroupChannel(); + channels[i].getMembershipService().setPayload( ("Channel-" + (i + 1)).getBytes("ASCII")); + listeners[i] = new TestMbrListener( ("Listener-" + (i + 1))); + channels[i].addMembershipListener(listeners[i]); + DomainFilterInterceptor filter = new DomainFilterInterceptor(); + filter.setDomain(UUIDGenerator.randomUUID(false)); + channels[i].addInterceptor(filter); + } + } + + public void clear() { + for (int i = 0; i < channels.length; i++) { + listeners[i].members.clear(); + } + } + + public void testMemberArrival() throws Exception { + //purpose of this test is to make sure that we have received all the members + //that we can expect before the start method returns + Thread[] threads = new Thread[channels.length]; + for (int i=0; i=0; i-- ) assertEquals("Checking member arrival length",0,listeners[i].members.size()); + } + + protected void tearDown() throws Exception { + + for (int i = 0; i < channels.length; i++) { + try { + channels[i].stop(Channel.DEFAULT); + } catch (Exception ignore) {} + } + super.tearDown(); + } + + public class TestMbrListener + implements MembershipListener { + public String name = null; + public TestMbrListener(String name) { + this.name = name; + } + + public ArrayList members = new ArrayList(); + public void memberAdded(Member member) { + if (!members.contains(member)) { + members.add(member); + try { + System.out.println(name + ":member added[" + new String(member.getPayload(), "ASCII") + "; Thread:"+Thread.currentThread().getName()+"]"); + } catch (Exception x) { + System.out.println(name + ":member added[unknown]"); + } + } + } + + public void memberDisappeared(Member member) { + if (members.contains(member)) { + members.remove(member); + try { + System.out.println(name + ":member disappeared[" + new String(member.getPayload(), "ASCII") + "; Thread:"+Thread.currentThread().getName()+"]"); + } catch (Exception x) { + System.out.println(name + ":member disappeared[unknown]"); + } + } + } + + } + +} diff --git a/test/org/apache/catalina/tribes/test/transport/SocketSend.java b/test/org/apache/catalina/tribes/test/transport/SocketSend.java index fff73c116..fcae89bfb 100644 --- a/test/org/apache/catalina/tribes/test/transport/SocketSend.java +++ b/test/org/apache/catalina/tribes/test/transport/SocketSend.java @@ -1,53 +1,53 @@ -package org.apache.catalina.tribes.test.transport; - -import java.io.OutputStream; -import java.net.Socket; -import java.text.DecimalFormat; -import org.apache.catalina.tribes.membership.MemberImpl; -import org.apache.catalina.tribes.io.XByteBuffer; -import org.apache.catalina.tribes.Member; -import org.apache.catalina.tribes.io.ChannelData; -import org.apache.catalina.tribes.Channel; -import java.math.BigDecimal; - -public class SocketSend { - - public static void main(String[] args) throws Exception { - - - Member mbr = new MemberImpl("localhost", 9999, 0); - ChannelData data = new ChannelData(); - data.setOptions(Channel.SEND_OPTIONS_BYTE_MESSAGE); - data.setAddress(mbr); - byte[] buf = new byte[8192 * 4]; - data.setMessage(new XByteBuffer(buf,false)); - buf = XByteBuffer.createDataPackage(data); - int len = buf.length; - System.out.println("Message size:"+len+" bytes"); - BigDecimal total = new BigDecimal((double)0); - BigDecimal bytes = new BigDecimal((double)len); - Socket socket = new Socket("localhost",9999); - System.out.println("Writing to 9999"); - OutputStream out = socket.getOutputStream(); - long start = 0; - double mb = 0; - boolean first = true; - int count = 0; - DecimalFormat df = new DecimalFormat("##.00"); - while ( count<100000 ) { - if ( first ) { first = false; start = System.currentTimeMillis();} - out.write(buf,0,buf.length); - mb += ( (double) buf.length) / 1024 / 1024; - total = total.add(bytes); - if ( ((++count) % 10000) == 0 ) { - long time = System.currentTimeMillis(); - double seconds = ((double)(time-start))/1000; - System.out.println("Throughput "+df.format(mb/seconds)+" MB/seconds messages "+count+", total "+mb+" MB, total "+total+" bytes."); - } - } - out.flush(); - System.out.println("Complete, sleeping 5 seconds"); - Thread.sleep(5000); - - } -} +package org.apache.catalina.tribes.test.transport; + +import java.io.OutputStream; +import java.net.Socket; +import java.text.DecimalFormat; +import org.apache.catalina.tribes.membership.MemberImpl; +import org.apache.catalina.tribes.io.XByteBuffer; +import org.apache.catalina.tribes.Member; +import org.apache.catalina.tribes.io.ChannelData; +import org.apache.catalina.tribes.Channel; +import java.math.BigDecimal; + +public class SocketSend { + + public static void main(String[] args) throws Exception { + + + Member mbr = new MemberImpl("localhost", 9999, 0); + ChannelData data = new ChannelData(); + data.setOptions(Channel.SEND_OPTIONS_BYTE_MESSAGE); + data.setAddress(mbr); + byte[] buf = new byte[8192 * 4]; + data.setMessage(new XByteBuffer(buf,false)); + buf = XByteBuffer.createDataPackage(data); + int len = buf.length; + System.out.println("Message size:"+len+" bytes"); + BigDecimal total = new BigDecimal((double)0); + BigDecimal bytes = new BigDecimal((double)len); + Socket socket = new Socket("localhost",9999); + System.out.println("Writing to 9999"); + OutputStream out = socket.getOutputStream(); + long start = 0; + double mb = 0; + boolean first = true; + int count = 0; + DecimalFormat df = new DecimalFormat("##.00"); + while ( count<100000 ) { + if ( first ) { first = false; start = System.currentTimeMillis();} + out.write(buf,0,buf.length); + mb += ( (double) buf.length) / 1024 / 1024; + total = total.add(bytes); + if ( ((++count) % 10000) == 0 ) { + long time = System.currentTimeMillis(); + double seconds = ((double)(time-start))/1000; + System.out.println("Throughput "+df.format(mb/seconds)+" MB/seconds messages "+count+", total "+mb+" MB, total "+total+" bytes."); + } + } + out.flush(); + System.out.println("Complete, sleeping 5 seconds"); + Thread.sleep(5000); + + } +} -- 2.11.0