---

StreamForwarder.java

package gov.nasa.arc.ase.jpf;

import java.io.*;
import gov.nasa.arc.ase.util.Debug;

class StreamForwarder implements Runnable {
  InputStream   input;
  OutputStream  output;
  OutputStream  log;
  int       id;

  public StreamForwarder(int n, InputStream i) {
    init(n, i, null);
  }  
  public StreamForwarder(int n, InputStream i, OutputStream o) {
    init(n, i, o);
  }  
  private void init(int n, InputStream i, OutputStream o) {
    id = n;
    input = i;
    output = o;
    try {
      log = new FileOutputStream("jpf" + id + ".log");
    } catch(FileNotFoundException e) {
      log = null;
      Debug.println(Debug.WARNING, "warning: can't write log file -- jpf " + id + ".log");
    }
  }  
  public void run() {
    if(output == null)
      if(log == null)
    return;
      else
    runFile();
    else
      if(log == null)
    runScreen();
      else
    runFileAndScreen();
  }  
  public void runFile() {
    byte[] bytes = new byte[1024];
    int l;

    try {
      while((l = input.read(bytes)) > 0)
    log.write(bytes, 0, l);
    } catch(IOException e) {};
  }  
  public void runFileAndScreen() {
    String ids = "[" + id + "] ";
    byte[] bytes = new byte[1024];
    StringBuffer sb = new StringBuffer(ids);
    int l;

    try {
      while((l = input.read(bytes)) > 0) {
    String s = new String(bytes, 0, l);
    int from = 0;
    int to = s.indexOf('\012');

    while(from < l && to != -1) {
      sb.append(s.substring(from, to+1));
      output.write(sb.toString().getBytes());
      sb = new StringBuffer(ids);
      from = to+1;
      to = s.indexOf('\012', from);
    }
    if(from < l) sb.append(s.substring(from));
    log.write(bytes, 0, l);
      }
    } catch(IOException e) {};
  }  
  public void runScreen() {
    String ids = "[" + id + "] ";
    byte[] bytes = new byte[1024];
    StringBuffer sb = new StringBuffer(ids);
    int l;

    try {
      while((l = input.read(bytes)) > 0) {
    String s = new String(bytes, 0, l);
    int from = 0;
    int to = s.indexOf('\012');

    while(from < l && to != -1) {
      sb.append(s.substring(from, to));
      output.write(sb.toString().getBytes());
      sb = new StringBuffer(ids);
      from = to+1;
      to = s.indexOf('\012', from);
    }
    if(from < l) sb.append(s.substring(from));
      }
    } catch(IOException e) {};
  }  
}

---