15f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes/* 25f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * Licensed to the Apache Software Foundation (ASF) under one or more 35f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * contributor license agreements. See the NOTICE file distributed with 45f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * this work for additional information regarding copyright ownership. 55f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * The ASF licenses this file to You under the Apache License, Version 2.0 65f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * (the "License"); you may not use this file except in compliance with 75f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * the License. You may obtain a copy of the License at 85f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * 95f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * http://www.apache.org/licenses/LICENSE-2.0 105f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * 115f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * Unless required by applicable law or agreed to in writing, software 125f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * distributed under the License is distributed on an "AS IS" BASIS, 135f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 145f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * 155f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * See the License for the specific language governing permissions and 165f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * limitations under the License. 175f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes */ 185f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes 195f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes/** 205f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * @author Vitaly A. Provodin 215f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes */ 225f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes 235f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes/** 245f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * Created on 29.01.2005 255f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes */ 265f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughespackage org.apache.harmony.jpda.tests.framework; 275f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes 285f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughesimport java.io.InputStreamReader; 295f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughesimport java.io.BufferedReader; 305f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughesimport java.io.InputStream; 315f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughesimport java.io.IOException; 325f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes 335f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes/** 345f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * <p>This class provides redirection of debuggee output and error streams to logWriter. 355f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes */ 365f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughespublic class StreamRedirector extends Thread { 375f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes 385f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes String name; 395f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes LogWriter logWriter; 405f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes BufferedReader br; 415f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes boolean doExit; 425f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes 435f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes /** 445f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * Creates new redirector for the specified stream. 455f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * 465f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * @param is stream to be redirected 475f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * @param logWriter logWriter to redirect stream to 485f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * @param name stream name used as prefix for redirected output 495f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes */ 505f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes public StreamRedirector(InputStream is, LogWriter logWriter, String name) { 515f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes super("Redirector for " + name); 525f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes this.name = name; 535f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes this.logWriter = logWriter; 545f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes InputStreamReader isr = new InputStreamReader(is); 555f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes br = new BufferedReader(isr, 1024); 565f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes doExit = false; 575f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes } 585f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes 595f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes /** 605f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * Reads all lines from stream and puts them to logWriter. 615f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes */ 625f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes public void run() { 635f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes logWriter.println("Redirector started: " + name); 645f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes try { 655f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes String line = ""; 665f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes while (!doExit) { 675f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes try { 685f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes line = br.readLine(); 695f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes if (line == null) 705f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes break; 715f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes 725f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes logWriter.println(name + "> " + line); 735f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes } catch (IllegalStateException e) { 745f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes //logWriter.printError("Illegal state exception! " + e); 755f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes //ignore 765f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes } 775f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes 785f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes } 795f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes logWriter.println("Redirector completed: " + name); 805f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes } catch (IOException e) { 815f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes logWriter.printError(e); 825f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes } 835f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes } 845f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes 855f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes /** 865f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes * Notifies redirector to stop stream redirection. 875f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes */ 885f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes public void exit() { 895f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes doExit = true; 905f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes } 915f0a23683aa603d8c50b6dd071a565821b76067bElliott Hughes} 92