Subversion Repositories fpga-cf

/**

 *

 */

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

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.io.InputStream;

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 plieber

 *

 * @version 0.1

 */

public class IcapInterface {

        protected FCPProtocol fcpprotocol;

        protected int icapWritePort = 3;

        protected int icapReadPort = 4;

        /**

         * Create IcapInterface, attached to the given FCP layer, with the default

         * FCP ports for the ICAP functions.

         *

         * @param fcpprotocol

         */

        public IcapInterface(FCPProtocol fcpprotocol) {

                this.init(fcpprotocol, 3, 4);

        }

        /**

         * Create IcapInterface, attached to the given FCP layer, with the given

         * FCP ports for the ICAP functions.

         *

         * @param fcpprotocol

         * @param icapWritePort

         * @param icapReadPort

         */

        public IcapInterface(FCPProtocol fcpprotocol, int icapWritePort,

                        int icapReadPort) {

                this.init(fcpprotocol, icapWritePort, icapReadPort);

        }

        /**

         * Initialize this object

         * @param fcpprotocol

         * @param icapWritePort

         * @param icapReadPort

         */

        private void init(FCPProtocol fcpprotocol, int icapWritePort,

                        int icapReadPort) {

                this.fcpprotocol = fcpprotocol;

                this.icapReadPort = icapReadPort;

                this.icapWritePort = icapWritePort;

        }

        @Override

        public String toString() {

                return "ICAP Interface< " + this.fcpprotocol.toString() + " >";

        }

        /**

         * Send a list of bytes to the ICAP.

         * @param bytes

         * @throws FCPException

         */

        public void sendIcapData(java.util.List<Byte> bytes) throws FCPException {

                this.fcpprotocol.send(this.icapWritePort, bytes, bytes.size());

        }

        /**

         * Send an array of byte to the ICAP.

         * @param bytes

         * @throws FCPException

         */

        public void sendIcapData(byte[] bytes, int numBytes) throws FCPException {

                byte[] writereg = new byte[1024];

                int offset = 0;

                int numRead = 0;

                while (offset < numBytes) {

                        for (int i = 0; i < 1024 && offset < numBytes; i++, offset++) {

                                writereg[i] = bytes[offset];

                                numRead++;

                        }

                        this.fcpprotocol.send(3, writereg, numRead);

                }

        }

        public void sendIcapFile(String fileName) throws FCPException {

                try {

                        File file = new File(fileName);

                        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;

                                fcpprotocol.send(3, writereg, numRead);

                        }

                } catch (FileNotFoundException e) {

                        throw new FCPException("File not found: " + fileName);

                } catch (IOException e) {

                        throw new FCPException("Error reading file: " + fileName);

                }

        }

        /**

         * Send a data request for ICAP data from the ICAP controller.

         * @param numBytes The number of bytes expected at the next receiveIcapData function call.

         * @throws FCPException

         */

        public void requestIcapData(int numBytes) throws FCPException {

                byte[] read4 = new byte[] { (byte) ((numBytes >> 8) & 0xff), (byte) (numBytes & 0xff) };

                this.fcpprotocol.send(this.icapReadPort, read4, read4.length);

                this.fcpprotocol.sendDataRequest(this.icapReadPort, numBytes);

        }

        /**

         * Receive a list of bytes from the ICAP.

         * @return List of bytes returned from the ICAP.

         */

        public ArrayList<Byte> receiveIcapData() {

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

                byte[] bytes = this.fcpprotocol.getDataResponse();

                for (int i = 0; i < bytes.length; i++) {

                        ret.add(bytes[i]);

                }

                return ret;

        }

        /**

         * Read a certain number of bytes from the ICAP. This function encapsulates calls to both requestIcapData and receiveIcapData.

         * @param numBytes The number of bytes expected

         * @return List of bytes returned from the ICAP

         * @throws FCPException

         */

        public ArrayList<Byte> read(int numBytes) throws FCPException {

                this.requestIcapData(numBytes);

                return this.receiveIcapData();

        }

}