Method run

benchmark/bench/echo.java:33–56

()

    }

    public void run() {
        Socket socketFromServer = null;
        try {
            socketFromServer = new Socket(inetaServer, iPort);
            BufferedReader in = new BufferedReader(new InputStreamReader(socketFromServer.getInputStream()));
            OutputStream out = socketFromServer.getOutputStream();

            byte[] bytesOut = GREETING.getBytes();
            String strIn = GREETING.trim();
            for(int i = 0; i < iIterations; ++i) {
            out.write(bytesOut);
            out.flush();
            String strRead = in.readLine();
            if(!strRead.equals(strIn))
                throw new RuntimeException("client: \"" + strIn + "\" ne \"" + strRead + "\"");
            }
        } catch(Exception e) {
            e.printStackTrace();
        }

        try {
            socketFromServer.close();
        } catch(Exception e) { }
    }
}

class EchoServer extends Thread {