Subversion Repositories fpga-cf

/**
 * 
 */
package edu.byu.cc.plieber.fpgaenet.icapif;
 
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.InetAddress;
import java.util.ArrayList;
 
import edu.byu.cc.plieber.fpgaenet.fcp.FCPException;
import edu.byu.cc.plieber.fpgaenet.fcp.FCPProtocol;
import edu.byu.cc.plieber.util.StringUtil;
 
/**
 * @author Peter Lieber
 *
 */
public class IcapInterfaceTest {
 
	/**
	 * @param args
	 */
	public static void main(String[] args) {
 
		if (args.length != 3) {
			System.out.println("usage: IcapInterfaceTest <IP Address> <input file> <num to read>");
			return;
		}
		int numToRead = Integer.parseInt(args[2]);
 
		FCPProtocol protocol = null;
 
		try {
			protocol = new FCPProtocol();
			protocol.connect(InetAddress.getByName(args[0]), 0x3001);
		} catch (IOException e) {
			System.err.println("IO Error, Exiting...");
			return;
		} finally {
			if (protocol == null) {
				System.err.println("Error creating FCP, Exiting...");
				return;
			}
		}
		while (!protocol.isConnected());
		IcapInterface icapif = new IcapInterface(protocol);
 
		File file = new File(args[1]);
		InputStream is = null;
		try {
			is = new FileInputStream(file);
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			if (is == null) {
				System.err.println("input stream null");
				return;
			}
		}
		long length = file.length();
		byte[] bytes = new byte[(int)length];
		try {
			is.read(bytes);
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			return;
		}
 
		try {
			icapif.sendIcapData(bytes, (int) length);
		} catch (FCPException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
 
		if (numToRead > 0) {
			ArrayList<Byte> readBytes = null;
			try {
				icapif.requestIcapData(numToRead);
				readBytes = icapif.receiveIcapData();
			} catch (FCPException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			System.out.println("Data received from ICAP: \n" + StringUtil.listToString(readBytes));
		}
 
		BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
		try {
			in.readLine();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		protocol.disconnect();
	}
 
}