Subversion Repositories adv_debug_sys

////////////////////////////////////////////////////////////////
//
// networkSystem.java
//
// Copyright (C) 2010 Nathan Yawn 
//                    (nyawn@opencores.org)
//
// This class performs the low-level network I/O.
//
////////////////////////////////////////////////////////////////
//
// This source file may be used and distributed without
// restriction provided that this copyright statement is not
// removed from the file and that any derivative work contains
// the original copyright notice and the associated disclaimer.
// 
// This source file is free software; you can redistribute it
// and/or modify it under the terms of the GNU General
// Public License as published by the Free Software Foundation;
// either version 3.0 of the License, or (at your option) any
// later version.
//
// This source is distributed in the hope that it will be
// useful, but WITHOUT ANY WARRANTY; without even the implied 
// warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
// PURPOSE.  See the GNU Lesser General Public License for more
// details.
// 
// You should have received a copy of the GNU General
// Public License along with this source; if not, download it 
// from http://www.gnu.org/licenses/gpl.html
//
////////////////////////////////////////////////////////////////
 
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 {
 
	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!"));
	}
 
}