Subversion Repositories adv_debug_sys

// The reference to mainControl is only used for log messages and

// network status.  It could easily be replace with a dedicated

// log-handling object.

package advancedWatchpointControl;

import java.io.BufferedReader;

import java.io.DataOutputStream;

import java.io.IOException;

import java.io.InputStreamReader;

import java.net.Socket;

import java.net.UnknownHostException;

import java.nio.charset.Charset;

public class networkSystem /*implements Runnable*/ {

        private Socket sockfd = null;

        private DataOutputStream ostream = null;

        private BufferedReader istream = null;

        private boolean isValid = false;

        // We use mainControl for logging / displaying network state

        private mainControl mCtrl = null;

        public networkSystem(mainControl mc) {

                mCtrl = mc;

        }

        protected void finalize() throws Throwable {

                disconnect(true);

        }

        public void connect(String hostname, int portNumber) {

                disconnect(true);

                System.out.println("Network connecting");

                try {

                        sockfd = new Socket(hostname, portNumber);

                        sockfd.setSoLinger(false, 1);

                    istream = new BufferedReader(new InputStreamReader(sockfd.getInputStream(), Charset.forName("US-ASCII")));

                    ostream = new DataOutputStream(sockfd.getOutputStream());

            }

                catch (UnknownHostException e) {

                        disconnect(false);

                mCtrl.setNetworkStatus(mainControl.connectionStatus.CONNECT_ERROR);

            mCtrl.setLogMessage("Unknown host: " + e);

            return;

        }

            catch (IOException e) {

                disconnect(false);

                mCtrl.setNetworkStatus(mainControl.connectionStatus.CONNECT_ERROR);

                mCtrl.setLogMessage("Connect error: " + e.getMessage());

                return;

            }

            isValid = true;

        mCtrl.setNetworkStatus(mainControl.connectionStatus.CONNECTED);

        String msg = "Connected to server \"" + hostname + "\", port " + portNumber;

        mCtrl.setLogMessage(msg);

        System.out.println("Network connected");

        mCtrl.doReadAllRegisters();  // Gets regs from target, sets GUI

        }

        public void disconnect(boolean waitForReaderExit) {

                System.out.println("Network disconnecting");

                isValid = false;

                try {

                        if(sockfd != null)

                                sockfd.shutdownInput();

                        if(sockfd != null)

                                sockfd.close();

                }

                catch (IOException e) {

                        // Ignore errors when closing socket

                }

        sockfd = null;

        istream = null;

        ostream = null;

        }

        public boolean isConnected() {

                return isValid;

        }

        public boolean sendData(String outdata) {

                if(isValid) {

                        try {

                                ostream.writeBytes(outdata);

                        }

                        catch (IOException e) {

                        mCtrl.setNetworkStatus(mainControl.connectionStatus.CONNECT_ERROR);

                        mCtrl.setLogMessage(e.getMessage());

                        disconnect(true);

                        return false;

                        }

                }

                else {

                        mCtrl.setLogMessage("Not connected: connect to server first.");

                        return false;

                }

                return true;

        }

        public int getChar() throws IOException {

                if(istream != null)

                        return istream.read();

                throw(new IOException("Network reader is null!"));

        }

}