java/src/main/com/google/appengine/tools/admin/OutputPump.java

   1 package com.google.appengine.tools.admin;
   2
   3 import java.io.BufferedReader;
   4 import java.io.IOException;
   5 import java.io.InputStream;
   6 import java.io.InputStreamReader;
   7 import java.io.PrintWriter;
   8 import java.util.logging.Level;
   9 import java.util.logging.Logger;
  10
  11 /**
  12  * Pumps lines from one stream onto another, used specifically for getting
  13  * the stdout/stderr of a child process onto the parent's.
  14  *
  15  *
  16  */
  17 public class OutputPump implements Runnable {
  18
  19   private BufferedReader stream;
  20   private PrintWriter output;
  21   private Logger logger = Logger.getLogger(OutputPump.class.getName());
  22
  23   public OutputPump(InputStream instream, PrintWriter outstream) {
  24     stream = new BufferedReader(new InputStreamReader(instream));
  25     output = outstream;
  26   }
  27
  28   @Override
  29   public void run() {
  30     String line = null;
  31     try {
  32       while ((line = stream.readLine()) != null) {
  33         output.println(line);
  34       }
  35     } catch (IOException ix) {
  36       logger.log(Level.SEVERE, "Unexpected failure while trying to record errors.", ix);
  37     }
  38   }
  39 }