execoutputhandler.java

无线传感器网络节点Sun SPOT管理工具

/*
 * Copyright (c) 2007 Sun Microsystems, Inc. All rights reserved. 
 * 
 * Sun Microsystems, Inc. has intellectual property rights relating to technology embodied in the product that is
 * described in this document. In particular, and without limitation, these intellectual property rights may
 * include one or more of the U.S. patents listed at http://www.sun.com/patents and one or more additional patents
 * or pending patent applications in the U.S. and in other countries.
 * 
 * U.S. Government Rights - Commercial software. Government users are subject to the Sun Microsystems, Inc.
 * standard license agreement and applicable provisions of the FAR and its supplements.
 * 
 * Use is subject to license terms. 
 * 
 * This distribution may include materials developed by third parties. Sun, Sun Microsystems, the Sun logo and
 * Java are trademarks or registered trademarks of Sun Microsystems, Inc. in the U.S. and other countries. 
 * 
 * Copyright (c) 2006 Sun Microsystems, Inc. Tous droits r?serv?s.
 * 
 * Sun Microsystems, Inc. d?tient les droits de propri?t? intellectuels relatifs ? la technologie incorpor?e dans
 * le produit qui est d?crit dans ce document. En particulier, et ce sans limitation, ces droits de propri?t?
 * intellectuelle peuvent inclure un ou plus des brevets am?ricains list?s ? l'adresse http://www.sun.com/patents
 * et un ou les brevets suppl?mentaires ou les applications de brevet en attente aux Etats - Unis et dans les
 * autres pays.
 * 
 * L'utilisation est soumise aux termes du contrat de licence.
 * 
 * Cette distribution peut comprendre des composants d?velopp?s par des tierces parties.
 * Sun, Sun Microsystems, le logo Sun et Java sont des marques de fabrique ou des marques d?pos?es de Sun
 * Microsystems, Inc. aux Etats-Unis et dans d'autres pays.
 */
package com.sun.spot.spotworld.usb.spotselector;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

/**
 * The ExecOutputHandler class is responsible for handling the output of the 
 * CheckBaseStation which is executed as a external process.  
 * 
 * @author Christian P黨ringer
 */
public class ExecOutputHandler extends Thread {
    private InputStream processOutput;

    private boolean isVerbose;

    private Thread watchDogThread;

    public ExecOutputHandler(InputStream processOutput) {
	this(processOutput, null, false);
    }

    public ExecOutputHandler(InputStream processOutput, Thread watchDog,
	    boolean isVerbose) {
	this.processOutput = processOutput;
	this.isVerbose = isVerbose;
	this.watchDogThread = watchDog;
    }

    public void run() {

	BufferedReader outputBr = new BufferedReader(new InputStreamReader(
		processOutput));
	if (isVerbose)
	    SpotSelector.infoOut.println("ExceIO Thread started");

	String line = null;
	try {
	    while ((line = outputBr.readLine()) != null) {

		// Reset the watchdogs timeout if the process generates an
		// an input. (This means that the timeout will restart when the
		// checkbasestation
		// process finished initialization (including the hostagent
		// stack) and is really waiting for a
		// basestation response)
		//
		// However, in the case that no spot is connected to the port,
		// the code used by checkbasestation
		// will echo repeatedly that it is retrying to connect to the
		// port. In this case we don't
		// want to reset the watchdogs time out.
		// 
		// TODO: exit thread if process exited normally. (use barrier)

		if (!line.endsWith("retrying..."))
		    ;
		watchDogThread.interrupt();

		if (isVerbose)
		    SpotSelector.infoOut.println(">" + line);
	    }

	} catch (IOException ioe) {
	    if (isVerbose)
		ioe.printStackTrace();
	}
    }
}