From 05f6fdfc09e42bc3da6f4bfcba55f600b019276b Mon Sep 17 00:00:00 2001
From: bdemsky <bdemsky>
Date: Wed, 7 Mar 2007 20:00:15 +0000
Subject: [PATCH] test client

---
 Robust/src/Benchmarks/Chat/NetsClient.java | 129 +++++++++++++++++++++
 1 file changed, 129 insertions(+)
 create mode 100644 Robust/src/Benchmarks/Chat/NetsClient.java

diff --git a/Robust/src/Benchmarks/Chat/NetsClient.java b/Robust/src/Benchmarks/Chat/NetsClient.java
new file mode 100644
index 00000000..df038e8f
--- /dev/null
+++ b/Robust/src/Benchmarks/Chat/NetsClient.java
@@ -0,0 +1,129 @@
+import java.awt.*;
+import java.io.*;
+import java.net.*;
+import java.util.*;
+
+public class NetsClient extends Thread {
+
+    static boolean debug;
+    static int sendoption=0;
+
+    public static void main(String argv[]) {
+
+	String host=null;
+	int numberofclients=0;
+	int numberofmessages=0;
+	int port=4321;
+
+	NetsClient.debug=false;
+	try {
+	    host=argv[0];
+	    port=Integer.parseInt(argv[1]);
+	    numberofclients=Integer.parseInt(argv[2]);
+	    numberofmessages=Integer.parseInt(argv[3]);
+	}
+	catch (Exception e) {
+	    System.out.println("NetsClient host port numberofclients numberofmessages debugflag");
+	}
+	try {
+	    NetsClient.debug=(Integer.parseInt(argv[4])==1);
+	    NetsClient.sendoption=Integer.parseInt(argv[5]);
+	} catch (Exception e) {}
+
+	NetsClient[] tarray=new NetsClient[numberofclients];
+	for (int i = 0; i < numberofclients; i++) {
+	    String room="room";
+	    tarray[i] = new NetsClient(i, host, port,
+				       numberofmessages, numberofclients, room);
+	    if (debug)
+		System.out.println("Attempting to start "+i);
+	    tarray[i].connectt();
+	}
+
+	long starttime=System.currentTimeMillis();
+	for (int i = 0; i < numberofclients; i++)
+	    tarray[i].start();
+	try {
+	    for (int i = 0; i < numberofclients; i++) {
+		tarray[i].join();
+	    }
+	} catch (InterruptedException e) {
+	    e.printStackTrace();
+	    System.out.println(e);
+	}
+	long endtime=System.currentTimeMillis();
+
+	System.out.println("ChatClient");
+	System.out.println("numclients:" + numberofclients);
+	System.out.println("port:" + port);
+	System.out.println("number of messages:" + numberofmessages);
+	System.out.println("Elapsed time:(mS)" + (endtime - starttime));
+	System.out.println("Throughput:" + (double) numberofclients*
+			   ((sendoption==4) ? 1 : numberofclients) *
+			   numberofmessages/((double) (endtime-starttime)));
+    }
+
+    public NetsClient(int clientnumber, String host,
+		      int port, int nom, int noc, String room) {
+	this.port=port;
+	this.clientnumber=clientnumber;
+	this.host=host;
+	this.nom=nom;
+	this.noc=noc;
+	this.room=room;
+    }
+
+    String room;
+    int nom, noc,clientnumber,port;
+    String host;
+    Socket sock;
+    PrintStream pout;
+    InputStream in;
+    OutputStream out;
+    //DataInputStream din;
+    BufferedReader d;
+
+    public void connectt() {
+	try{
+	    sock = new Socket(host, port); // unix server
+	    if (debug)
+		System.out.println("connection made");
+	    in = sock.getInputStream();
+	    out = sock.getOutputStream();
+	    pout = new PrintStream(out);
+	    //din = new DataInputStream(in);
+	    d = new BufferedReader(new InputStreamReader(in));  
+	    pout.println(room);
+	}
+	catch (UnknownHostException e ) {
+	    System.out.println("can't find host");
+	}
+	catch (IOException e) {
+	    System.out.println("Error connecting to host");
+	}
+    }
+
+    public void run() {
+	if (debug)
+	    System.out.println("client thread started");
+	int ns=0;
+
+        try {
+	    for(int nr=0;nr<noc*nom;) {
+		if ((ns<nom)&&((nr%noc)==clientnumber)) {
+		    ns++;
+		    pout.println("0|"+clientnumber+"|hello#"+ns+"**");
+		}
+		String request = d.readLine();
+		if (debug)
+		    System.out.println(request+nr);
+            }
+	    pout.flush();
+	}
+
+        catch (UnknownHostException e ) {System.out.println("can't find host"); }
+        catch ( IOException e ) {System.out.println("Error connecting to host");}
+
+    }
+
+} // end of client class
-- 
2.34.1