Hey Danny, you haven't got javadocs on your methods. Peter are you going to remove this class too ?
Harmeet ----- Original Message ----- From: <[EMAIL PROTECTED]> To: <[EMAIL PROTECTED]> Sent: Sunday, October 13, 2002 1:17 AM Subject: cvs commit: jakarta-james/src/java/org/apache/james/testing EndToEnd.java SMTPDeliveryWorker.java > danny 2002/10/13 01:17:04 > > Added: src/java/org/apache/james/testing EndToEnd.java > SMTPDeliveryWorker.java > Log: > not pretty, but effective, load test for scheduler issue > > Revision Changes Path > 1.1 jakarta-james/src/java/org/apache/james/testing/EndToEnd.java > > Index: EndToEnd.java > =================================================================== > /** > * RemoteManagerEndToEnd.java > * > * Copyright (C) 27-Sep-2002 The Apache Software Foundation. All rights reserved. > * > * This software is published under the terms of the Apache Software License > * version 1.1, a copy of which has been included with this distribution in > * the LICENSE file. > * > * Danny Angus > */ > package org.apache.james.testing; > import java.io.BufferedInputStream; > import java.io.BufferedReader; > import java.io.IOException; > import java.io.InputStream; > import java.io.InputStreamReader; > import java.io.OutputStream; > import java.io.OutputStreamWriter; > import java.net.SocketException; > import java.util.Date; > import junit.framework.TestCase; > import org.apache.commons.net.pop3.POP3Client; > import org.apache.commons.net.smtp.SMTPClient; > import org.apache.commons.net.telnet.TelnetClient; > import examples.IOUtil; > /** > * @author <A href="mailto:[EMAIL PROTECTED]";>Danny Angus</a> > * > * $Id: EndToEnd.java,v 1.1 2002/10/13 08:17:03 danny Exp $ > */ > public class EndToEnd extends TestCase { > /** > * Constructor for RemoteManagerEndToEnd. > * @param arg0 > */ > private int numworkers = 10; > private int messagesize = 1024*10; > private int workingworkers; > private Date start; > private String[] script1 = > { "root", "root", "help", "adduser test test", "listusers", "quit" }; > private String[] script2 = > { "root", "root", "listusers", "deluser test", "listusers", "quit" }; > private boolean finished = false; > private int delivered = 0; > public EndToEnd(String arg0) { > super(arg0); > } > public static void main(String[] args) { > junit.textui.TestRunner.run(EndToEnd.class); > } > public void testEndToEnd() { > TelnetClient client = new TelnetClient(); > BufferedReader in; > OutputStreamWriter out; > try { > client.setDefaultTimeout(500); > client.connect("127.0.0.1", 4555); > in = new BufferedReader(new InputStreamReader(client.getInputStream())); > OutputStream oo = client.getOutputStream(); > out = new OutputStreamWriter(oo); > print(in, System.out); > for (int i = 0; i < script1.length; i++) { > out.write(script1[i] + "\n"); > System.out.println(" " + script1[i] + " \n"); > out.flush(); > print(in, System.out); > } > mailTest(); > client.disconnect(); > } catch (SocketException e) { > e.printStackTrace(); > assertTrue(false); > } catch (IOException e) { > e.printStackTrace(); > assertTrue(false); > } > } > private void echo(OutputStreamWriter out) { > } > private String print(BufferedReader in, OutputStream output) { > String outString = ""; > try { > String readString = in.readLine(); > while (readString != null) { > outString += readString + "\n"; > readString = in.readLine(); > } > } catch (IOException e) { > //e.printStackTrace(); > //assertTrue(false); > } > System.out.println(outString); > return outString + "=="; > } > private void mailTest() { > start = new Date(); > StringBuffer mail1 = new StringBuffer(); > mail1.append( > "Subject: test\nFrom: postmaster@localhost\nTo: test@localhost\n\nTHIS IS A TEST"); > for (int kb = 0; kb < messagesize; kb++) { > mail1.append("m"); > } > String mail = mail1.toString(); > SMTPDeliveryWorker[] workers = new SMTPDeliveryWorker[numworkers]; > Thread[] threads = new Thread[workers.length]; > for (int i = 0; i < workers.length; i++) { > workers[i] = new SMTPDeliveryWorker(new SMTPClient(), mail, this); > workers[i].setWorkerid(i); > threads[i] = new Thread((SMTPDeliveryWorker) workers[i]); > } > for (int i = 0; i < workers.length; i++) { > System.out.println("starting worker:" + i); > ((Thread) threads[i]).start(); > workingworkers++; > } > while (!finished) { > } > try { > POP3Client pclient = new POP3Client(); > pclient.connect("127.0.0.1", 110); > System.out.println(pclient.getReplyString()); > pclient.login("test", "test"); > System.out.println(pclient.getReplyString()); > pclient.setState(pclient.TRANSACTION_STATE); > pclient.listMessages(); > System.out.println(pclient.getReplyString()); > pclient.disconnect(); > System.out.println(pclient.getReplyString()); > } catch (SocketException e) { > } catch (IOException e) { > } > long time = (new Date()).getTime() - start.getTime(); > System.err.println("time total " + (int) time); > } > public void finished(int workerid) { > workingworkers--; > System.out.println("workers still working.." + workingworkers); > if (workingworkers == 0) { > long time = (new Date()).getTime() - start.getTime(); > System.err.println("time to deliver set " + (int) (time/1000)); > //System.err.println("messages per second " + (int)(1000/(time/1000))); > //System.err.println("data rate="+((messagesize*1000)/(time/1000))); > finished = true; > } > } > public void delivered() { > System.out.println("-" + (++delivered)); > } > } > > > > 1.1 jakarta-james/src/java/org/apache/james/testing/SMTPDeliveryWorker.java > > Index: SMTPDeliveryWorker.java > =================================================================== > /** > * SMTPDeliveryWorker.java > * > * Copyright (C) 11-Oct-2002 The Apache Software Foundation. All rights reserved. > * > * This software is published under the terms of the Apache Software License > * version 1.1, a copy of which has been included with this distribution in > * the LICENSE file. > * > * Danny Angus > */ > package org.apache.james.testing; > import java.io.IOException; > import org.apache.commons.net.smtp.SMTPClient; > /** > * @author <A href="mailto:[EMAIL PROTECTED]";>Danny Angus</a> > * > * $Id: SMTPDeliveryWorker.java,v 1.1 2002/10/13 08:17:04 danny Exp $ > */ > public class SMTPDeliveryWorker implements Runnable { > /** > * Constructor for SMTPDeliveryWorker. > */ > private SMTPClient client; > private String mail; > private int workerid; > EndToEnd boss; > public SMTPDeliveryWorker(SMTPClient client, String mail, EndToEnd boss) { > this.boss = boss; > this.client = client; > this.mail = mail; > } > /** > * @see java.lang.Runnable#run() > */ > public void run() { > try { > > //move the connect and disconnect into the loop to make a new connection for every mail > client.connect("127.0.0.1", 25); > for (int run = 0; run < 100; run++) { > //System.out.println(client.getReplyString()); > client.sendSimpleMessage("postmaster@localhost", "test@localhost", mail); > boss.delivered(); > } > client.disconnect(); > String[] outs = client.getReplyStrings(); > for (int i = 0; i < outs.length; i++) { > System.out.println(outs[i]); > } > } catch (IOException e) { > System.err.println("argh! "+workerid+" "+e.getMessage()); > } > boss.finished(workerid); > } > public void setWorkerid(int workerid) { > this.workerid = workerid; > } > public int getWorkerid() { > return workerid; > } > } > > > > > -- > To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]> > For additional commands, e-mail: <mailto:[EMAIL PROTECTED]> -- To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]> For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
