Coverage Report - org.codehaus.plexus.util.cli.StreamFeeder
 
Classes in this File Line Coverage Branch Coverage Complexity
StreamFeeder
0%
0/48
0%
0/18
3.4
 
 1  
 package org.codehaus.plexus.util.cli;
 2  
 
 3  
 /*
 4  
  * Copyright The Codehaus Foundation.
 5  
  *
 6  
  * Licensed under the Apache License, Version 2.0 (the "License");
 7  
  * you may not use this file except in compliance with the License.
 8  
  * You may obtain a copy of the License at
 9  
  *
 10  
  *     http://www.apache.org/licenses/LICENSE-2.0
 11  
  *
 12  
  * Unless required by applicable law or agreed to in writing, software
 13  
  * distributed under the License is distributed on an "AS IS" BASIS,
 14  
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 15  
  * See the License for the specific language governing permissions and
 16  
  * limitations under the License.
 17  
  */
 18  
 
 19  
 import java.io.IOException;
 20  
 import java.io.InputStream;
 21  
 import java.io.OutputStream;
 22  
 
 23  
 /**
 24  
  * Read from an InputStream and write the output to an OutputStream.
 25  
  *
 26  
  * @author <a href="mailto:trygvis@inamo.no">Trygve Laugst&oslash;l</a>
 27  
  * @version $Id$
 28  
  */
 29  
 public class StreamFeeder
 30  
     extends AbstractStreamHandler
 31  
 {
 32  
 
 33  
     private InputStream input;
 34  
 
 35  
     private OutputStream output;
 36  
 
 37  0
     private volatile Throwable exception = null;
 38  
 
 39  
     /**
 40  
      * Create a new StreamFeeder
 41  
      *
 42  
      * @param input Stream to read from
 43  
      * @param output Stream to write to
 44  
      */
 45  
     public StreamFeeder( InputStream input, OutputStream output )
 46  
     {
 47  0
         super();
 48  0
         this.input = input;
 49  0
         this.output = output;
 50  0
     }
 51  
 
 52  
     @Override
 53  
     public void run()
 54  
     {
 55  
         try
 56  
         {
 57  0
             feed();
 58  
         }
 59  0
         catch ( Throwable ex )
 60  
         {
 61  0
             if ( exception == null )
 62  
             {
 63  0
                 exception = ex;
 64  
             }
 65  
         }
 66  
         finally
 67  
         {
 68  0
             close();
 69  
 
 70  0
             synchronized ( this )
 71  
             {
 72  0
                 setDone();
 73  
 
 74  0
                 this.notifyAll();
 75  0
             }
 76  0
         }
 77  0
     }
 78  
 
 79  
     public void close()
 80  
     {
 81  0
         if ( input != null )
 82  
         {
 83  0
             synchronized ( input )
 84  
             {
 85  
                 try
 86  
                 {
 87  0
                     input.close();
 88  
                 }
 89  0
                 catch ( IOException ex )
 90  
                 {
 91  0
                     if ( exception == null )
 92  
                     {
 93  0
                         exception = ex;
 94  
                     }
 95  0
                 }
 96  
 
 97  0
                 input = null;
 98  0
             }
 99  
         }
 100  
 
 101  0
         if ( output != null )
 102  
         {
 103  0
             synchronized ( output )
 104  
             {
 105  
                 try
 106  
                 {
 107  0
                     output.close();
 108  
                 }
 109  0
                 catch ( IOException ex )
 110  
                 {
 111  0
                     if ( exception == null )
 112  
                     {
 113  0
                         exception = ex;
 114  
                     }
 115  0
                 }
 116  
 
 117  0
                 output = null;
 118  0
             }
 119  
         }
 120  0
     }
 121  
 
 122  
     /**
 123  
      * @since 3.1.0
 124  
      */
 125  
     public Throwable getException()
 126  
     {
 127  0
         return exception;
 128  
     }
 129  
 
 130  
     private void feed()
 131  
         throws IOException
 132  
     {
 133  0
         boolean flush = false;
 134  0
         int data = input.read();
 135  
 
 136  0
         while ( !isDone() && data != -1 )
 137  
         {
 138  0
             synchronized ( output )
 139  
             {
 140  0
                 if ( !isDisabled() )
 141  
                 {
 142  0
                     output.write( data );
 143  0
                     flush = true;
 144  
                 }
 145  
 
 146  0
                 data = input.read();
 147  0
             }
 148  
         }
 149  
 
 150  0
         if ( flush )
 151  
         {
 152  0
             output.flush();
 153  
         }
 154  0
     }
 155  
 
 156  
 }