Subversion Repositories fpga-cf

/**

 *

 */

package edu.byu.cc.plieber.fpgaenet.examples;

import java.io.IOException;

import java.net.InetAddress;

import java.util.ArrayList;

import edu.byu.cc.plieber.fpgaenet.fcp.FCPException;

import edu.byu.cc.plieber.fpgaenet.fcp.FCPProtocol;

/**

 * @author Peter Lieber

 *

 */

public class ThroughputTest {

        /**

         * @param args

         */

        public static void main(String[] args) {

                FCPProtocol p = null;

                try {

                        p = new FCPProtocol();

                        p.setSendWindow(10);

                        p.connect(InetAddress.getByName("10.0.1.42"));

                } catch (IOException e) {

                        // TODO Auto-generated catch block

                        e.printStackTrace();

                }

                while (!p.isConnected())

                        ;

                ArrayList<Byte> data = new ArrayList<Byte>();

                for (int i = 0; i < 1024; i++) {

                        data.add(new Byte((byte) 0x0));

                }

                long totaltime = 0;

                for (int j = 0; j < 10; j++) {

                        long time = System.currentTimeMillis();

                        for (int i = 0; i < 4096; i++) {

                                //data.set(1023, new Byte((byte)i));

                                try {

                                        p.sendData(1, data, 1024);

                                } catch (FCPException e) {

                                        // TODO Auto-generated catch block

                                        e.printStackTrace();

                                }

                        }

                        while (p.packetsPending())

                                ;

                        time = System.currentTimeMillis() - time;

                        System.out.println("4 MB time: " + time);

                        System.out.println("While Count: " + p.getWhileCount());

                        p.resetWhileCount();

                        totaltime += time;

                }

                System.out.println("Total Time: " + totaltime + " ms");

                System.out.println("Average Throughput: " + 40.0 / ((double)totaltime/ 1000.0) + " MB/s");

                System.out.println("Average Throughput: " + 320.0 / ((double)totaltime/ 1000.0) + " Mb/s");

                p.disconnect();

        }

}