Subversion Repositories fpga-cf

/**
 * 
 */
package edu.byu.cc.plieber.fpgaenet.fcp;
 
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.InetAddress;
 
/**
 * @author plieber
 * 
 */
public class FCPTest {
 
	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		if (args.length != 5) {
			System.out
					.println("usage: FCPTest <destaddr> <selfport> <destport> <datafile> <numToRead>");
			return;
		}
		String addr = args[0];
		int port = Integer.parseInt(args[1]);
		int port2 = Integer.parseInt(args[2]);
		int numToRead = Integer.parseInt(args[4]);
 
		FCPProtocol protocol = null;
		try {
			protocol = new FCPProtocol(port, port2);
			if (args.length == 5) {
				protocol.connect(InetAddress.getByName(addr), port2);
				while (!protocol.connected)
					;
				// byte[] data = new byte[] { 0, 1, 2, 3 };
				// for (int i = 8; i <= 10; i++) {
				// protocol.send(i, data);
				// }
				// protocol.sendDataRequest(1, 5);
				File file = new File(args[3]);
				InputStream is = new FileInputStream(file);
				long length = file.length();
				if (length > Integer.MAX_VALUE) {
 
				}
 
				byte[] writereg = new byte[1024];
				int offset = 0;
				int numRead = 0;
				while (offset < file.length()
						&& (numRead = is.read(writereg, 0, 1024)) >= 0) {
					offset += numRead;
					try {
						protocol.send(3, writereg, numRead);
					} catch (FCPException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}
				if (numToRead > 0) {
					byte[] read4 = new byte[] { (byte) ((numToRead >> 8) & 0xff), (byte) (numToRead & 0xff) };
					try {
						protocol.send(4, read4, read4.length);
						protocol.sendDataRequest(4, numToRead);
					} catch (FCPException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
		try {
			in.readLine();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		protocol.disconnect();
	}
}