Clover coverage report - Ant Coverage
Coverage timestamp: Tue Apr 8 2003 20:43:55 EST
file stats: LOC: 158   Methods: 5
NCLOC: 53   Classes: 1
 
 Source file Conditionals Statements Methods TOTAL
StreamPumper.java 16.7% 70% 40% 54.8%
 1   
 /*
 2   
  * The Apache Software License, Version 1.1
 3   
  *
 4   
  * Copyright (c) 2000,2002-2003 The Apache Software Foundation.  All rights
 5   
  * reserved.
 6   
  *
 7   
  * Redistribution and use in source and binary forms, with or without
 8   
  * modification, are permitted provided that the following conditions
 9   
  * are met:
 10   
  *
 11   
  * 1. Redistributions of source code must retain the above copyright
 12   
  *    notice, this list of conditions and the following disclaimer.
 13   
  *
 14   
  * 2. Redistributions in binary form must reproduce the above copyright
 15   
  *    notice, this list of conditions and the following disclaimer in
 16   
  *    the documentation and/or other materials provided with the
 17   
  *    distribution.
 18   
  *
 19   
  * 3. The end-user documentation included with the redistribution, if
 20   
  *    any, must include the following acknowlegement:
 21   
  *       "This product includes software developed by the
 22   
  *        Apache Software Foundation (http://www.apache.org/)."
 23   
  *    Alternately, this acknowlegement may appear in the software itself,
 24   
  *    if and wherever such third-party acknowlegements normally appear.
 25   
  *
 26   
  * 4. The names "Ant" and "Apache Software
 27   
  *    Foundation" must not be used to endorse or promote products derived
 28   
  *    from this software without prior written permission. For written
 29   
  *    permission, please contact apache@apache.org.
 30   
  *
 31   
  * 5. Products derived from this software may not be called "Apache"
 32   
  *    nor may "Apache" appear in their names without prior written
 33   
  *    permission of the Apache Group.
 34   
  *
 35   
  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
 36   
  * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 37   
  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 38   
  * DISCLAIMED.  IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
 39   
  * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 40   
  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 41   
  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
 42   
  * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
 43   
  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
 44   
  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
 45   
  * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 46   
  * SUCH DAMAGE.
 47   
  * ====================================================================
 48   
  *
 49   
  * This software consists of voluntary contributions made by many
 50   
  * individuals on behalf of the Apache Software Foundation.  For more
 51   
  * information on the Apache Software Foundation, please see
 52   
  * <http://www.apache.org/>.
 53   
  */
 54   
 
 55   
 package org.apache.tools.ant.taskdefs;
 56   
 
 57   
 import java.io.IOException;
 58   
 import java.io.InputStream;
 59   
 import java.io.OutputStream;
 60   
 
 61   
 /**
 62   
  * Copies all data from an input stream to an output stream.
 63   
  *
 64   
  * @author thomas.haas@softwired-inc.com
 65   
  * @since Ant 1.2
 66   
  */
 67   
 public class StreamPumper implements Runnable {
 68   
 
 69   
     // TODO: make SIZE an instance variable.
 70   
     // TODO: add a status flag to note if an error occured in run.
 71   
 
 72   
     private static final int SIZE = 128;
 73   
     private InputStream is;
 74   
     private OutputStream os;
 75   
     private boolean finished;
 76   
     private boolean closeWhenExhausted;
 77   
 
 78   
     /**
 79   
      * Create a new stream pumper.
 80   
      *
 81   
      * @param is input stream to read data from
 82   
      * @param os output stream to write data to.
 83   
      * @param closeWhenExhausted if true, the output stream will be closed when
 84   
      *        the input is exhausted.
 85   
      */
 86  60
     public StreamPumper(InputStream is, OutputStream os, 
 87   
                         boolean closeWhenExhausted) {
 88  60
         this.is = is;
 89  60
         this.os = os;
 90  60
         this.closeWhenExhausted = closeWhenExhausted;        
 91   
     }
 92   
     
 93   
     /**
 94   
      * Create a new stream pumper.
 95   
      *
 96   
      * @param is input stream to read data from
 97   
      * @param os output stream to write data to.
 98   
      */
 99  0
     public StreamPumper(InputStream is, OutputStream os) {
 100  0
         this(is, os, false);
 101   
     }
 102   
 
 103   
 
 104   
     /**
 105   
      * Copies data from the input stream to the output stream.
 106   
      *
 107   
      * Terminates as soon as the input stream is closed or an error occurs.
 108   
      */
 109  60
     public void run() {
 110  60
         synchronized (this) {
 111   
             // Just in case this object is reused in the future
 112  60
             finished = false;
 113   
         }
 114   
 
 115  60
         final byte[] buf = new byte[SIZE];
 116   
 
 117  60
         int length;
 118  60
         try {
 119  ?
             while ((length = is.read(buf)) > 0) {
 120  152
                 os.write(buf, 0, length);
 121   
             }
 122   
         } catch (Exception e) {
 123   
             // ignore errors
 124   
         } finally {
 125  60
             if (closeWhenExhausted) {
 126  0
                 try {
 127  0
                     os.close();
 128   
                 } catch (IOException e) {
 129   
                     // ignore
 130   
                 }
 131   
             }
 132  60
             synchronized (this) {
 133  60
                 finished = true;
 134  60
                 notify();
 135   
             }
 136   
         }
 137   
     }
 138   
 
 139   
     /**
 140   
      * Tells whether the end of the stream has been reached.
 141   
      * @return true is the stream has been exhausted.
 142   
      **/
 143  0
     public synchronized boolean isFinished() {
 144  0
         return finished;
 145   
     }
 146   
 
 147   
     /**
 148   
      * This method blocks until the stream pumper finishes.
 149   
      * @see #isFinished()
 150   
      **/
 151  0
     public synchronized void waitFor()
 152   
         throws InterruptedException {
 153  0
         while (!isFinished()) {
 154  0
             wait();
 155   
         }
 156   
     }
 157   
 }
 158