import java.io.*;
import java.net.*;
import java.util.Date;

public class Main {
    public static void main(String argv[]) throws Exception {
        String clientSentence;
        String capitalizedSentence;
        ServerSocket welcomeSocket = new ServerSocket(3010);
        Integer cycles = 10;

        long elapsedTime = 0L;
        int total_bytes=0;
        long startTime=0;
        boolean once=true;
        int interval=60;
        while (elapsedTime < interval*1000) {
            //perform db poll/check
            cycles--;
            Socket connectionSocket = welcomeSocket.accept();
            BufferedReader inFromClient =
                    new BufferedReader(new InputStreamReader(connectionSocket.getInputStream()));
            DataOutputStream outToClient = new DataOutputStream(connectionSocket.getOutputStream());
            clientSentence = inFromClient.readLine();
            if(once)startTime = System.currentTimeMillis();
            once=false;
            System.out.println("Received: " + clientSentence);
            total_bytes=total_bytes+1024;
            elapsedTime = (new Date()).getTime() - startTime;
        }

        System.out.println("Total Bytes Recvd: "+ total_bytes );
        System.out.println("Average Throughput: "+ total_bytes/interval + " B/s\t"+total_bytes*8/interval+" b/s");
/*

        while (cycles>0) {
            cycles--;
            Socket connectionSocket = welcomeSocket.accept();
            BufferedReader inFromClient =
                    new BufferedReader(new InputStreamReader(connectionSocket.getInputStream()));
            DataOutputStream outToClient = new DataOutputStream(connectionSocket.getOutputStream());
            clientSentence = inFromClient.readLine();
            System.out.println("Received: " + clientSentence);
            capitalizedSentence = clientSentence.toUpperCase() + '\n';
            //outToClient.writeBytes(capitalizedSentence);
        }*/
    }
}