Subversion Repositories mod_mult_exp

package webexponentiator.util;

import java.io.InputStream;

import java.io.OutputStream;

import java.math.BigInteger;

import java.util.ArrayList;

import java.util.HashMap;

import org.apache.commons.lang3.ArrayUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import com.fazecast.jSerialComm.SerialPort;

import com.fazecast.jSerialComm.SerialPortDataListener;

import com.fazecast.jSerialComm.SerialPortEvent;

public class Communication implements SerialPortDataListener {

        protected final Log logger = LogFactory.getLog(getClass());

        String selectedPort = "COM3";

        // just a boolean flag that i use for enabling

        // and disabling buttons depending on whether the program

        // is connected to a serial port or not

        private boolean bConnected = false;

        // the timeout value for connecting with the port

        final static int TIMEOUT = 2000;

        // for containing the ports that will be found

        private SerialPort[] ports = null;

        // map the port names to CommPortIdentifiers

        private HashMap<String, SerialPort> portMap = new HashMap<String, SerialPort>();

        // this is the object that contains the opened port

        private SerialPort serialPort = null;

        // input and output streams for sending and receiving data

        private InputStream input = null;

        private OutputStream output = null;

        public Communication() {

        }

        // a string for recording what goes on in the program

        // this string is written to the GUI

        String logText = "";

        // search for all the serial ports

        // pre style="font-size: 11px;": none

        // post: adds all the found ports to a combo box on the GUI

        public ArrayList<String> searchForPorts() {

                ArrayList<String> result = new ArrayList<String>();

                ports = SerialPort.getCommPorts();

                logger.info("COM ports identified");

                for (SerialPort port:ports) {

                        String portName = port.getDescriptivePortName();

                        if (portName.contains("COM3")) {

                                selectedPort = portName;

                        }

                        // get only serial ports

                        result.add(portName);

                        portMap.put(portName, port);

                }

                return result;

        }

        public String connect() {

                serialPort = (SerialPort) portMap.get(selectedPort);

                serialPort.setBaudRate(115200);

                serialPort.setNumDataBits(8);

                serialPort.setNumStopBits(1);

                serialPort.setParity(SerialPort.ODD_PARITY);

                        // the method below returns an object of type CommPort

                        setConnected(serialPort.openPort());

                        // for controlling GUI elements

                        // logging

                        logger.info(selectedPort + " opened successfully.");

                        return "COM3 connected ok";

        }

        public boolean initIOStream() {

                // return value for whether opening the streams is successful or not

                boolean successful = false;

                        input = serialPort.getInputStream();

                        output = serialPort.getOutputStream();

                        successful = true;

                        return successful;

        }

        public void initListener() {

                        serialPort.addDataListener(this);

        }

        public void disconnect() {

                // close the serial port

                try {

                        serialPort.removeDataListener();

                        input.close();

                        output.close();

                        serialPort.closePort();

                        setConnected(false);

                        logger.info("Disconnected.");

                } catch (Exception e) {

                        logger.error("Failed to close " + serialPort.getDescriptivePortName() + "("

                                        + e.toString() + ")");

                }

        }

        public String readData() {

                try {

                        byte[] buffer = new byte[65];

                        int n = input.read(buffer);

                        if (n > 0) {

                                if (n == 1) {

                                        BigInteger command = new BigInteger(new byte[] { 0,

                                                        buffer[0] });

                                        String s = "Command = " + command.toString(16);

                                        return s;

                                } else {

                                        buffer = ArrayUtils.subarray(buffer, 0, buffer.length - 1);

                        buffer = ArrayUtils.add(buffer, (byte)0);

                        ArrayUtils.reverse(buffer);

                        BigInteger data = new BigInteger(buffer);

                                        return data.toString(16);

                                }

                        }

                } catch (Exception e) {

                        logger.error("Failed to read data. (" + e.toString() + ")");

                }

                return null;

        }

        @Override

        public int getListeningEvents() {

                return SerialPort.LISTENING_EVENT_DATA_AVAILABLE;

        }

        @Override

        public void serialEvent(SerialPortEvent evt) {

                if (evt.getEventType() != SerialPort.LISTENING_EVENT_DATA_AVAILABLE) {

                        try {

                                byte[] buffer = new byte[10];

                                int n = input.read(buffer);

                                if (n > 0) {

                                        if (n == 1) {

                                                BigInteger command = new BigInteger(new byte[] { 0,

                                                                buffer[0] });

                                                final String s = "Command = " + command.toString(16)

                                                                + "\n";

                                                //TODO Something for retrieve data

                                                //window.appendText(s);

                                        } else {

                                                ArrayUtils.reverse(buffer);

                                                BigInteger data = new BigInteger(buffer);

                                                //TODO Something for retrieve data

                                                //window.appendText(data.toString(10) + "\n");

                                        }

                                }

                        } catch (Exception e) {

                                logger.error("Failed to read data. (" + e.toString() + ")");

                        }

                }

        }

        public void writeByte(byte b) {

                try {

                        output.write(b);

                        Thread.sleep(1);

                } catch (Exception e) {

                        logger.error("Failed to write data. (" + e.toString() + ")");

                }

        }

        // method that can be called to send data

        // pre style="font-size: 11px;": open serial port

        // post: data sent to the other device

        public void writeData(String str) {

                try {

                        BigInteger bi = new BigInteger(str, 2);

                        byte[] b = bi.toByteArray();

                        if (b.length == 2) {

                                output.write(b[1]);

                        } else {

                                output.write(b);

                        }

                        Thread.sleep(1);

                } catch (Exception e) {

                        logger.error("Failed to write data. (" + e.toString() + ")");

                }

        }

        final public boolean getConnected() {

                return bConnected;

        }

        private void setConnected(boolean bConnected) {

                this.bConnected = bConnected;

        }

}