View Javadoc
1   package org.codehaus.plexus.compiler.util;
2   
3   /**
4    * The MIT License
5    *
6    * Copyright (c) 2005, The Codehaus
7    *
8    * Permission is hereby granted, free of charge, to any person obtaining a copy of
9    * this software and associated documentation files (the "Software"), to deal in
10   * the Software without restriction, including without limitation the rights to
11   * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies
12   * of the Software, and to permit persons to whom the Software is furnished to do
13   * so, subject to the following conditions:
14   *
15   * The above copyright notice and this permission notice shall be included in all
16   * copies or substantial portions of the Software.
17   *
18   * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
19   * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
20   * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
21   * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
22   * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
23   * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
24   * SOFTWARE.
25   */
26  
27  import java.io.BufferedInputStream;
28  import java.io.IOException;
29  import java.io.OutputStream;
30  
31  /**
32   * @author <a href="mailto:jason@maven.org">Jason van Zyl</a>
33   */
34  public class StreamPumper
35      extends Thread
36  {
37      private static final int BUFFER_SIZE = 512;
38  
39      private BufferedInputStream stream;
40  
41      private boolean endOfStream = false;
42  
43      private int SLEEP_TIME = 5;
44  
45      private OutputStream out;
46  
47      public StreamPumper( BufferedInputStream is, OutputStream out )
48      {
49          this.stream = is;
50          this.out = out;
51      }
52  
53      public void pumpStream()
54          throws IOException
55      {
56          byte[] buf = new byte[BUFFER_SIZE];
57          if ( !endOfStream )
58          {
59              int bytesRead = stream.read( buf, 0, BUFFER_SIZE );
60  
61              if ( bytesRead > 0 )
62              {
63                  out.write( buf, 0, bytesRead );
64              }
65              else if ( bytesRead == -1 )
66              {
67                  endOfStream = true;
68              }
69          }
70      }
71  
72      public void run()
73      {
74          try
75          {
76              while ( !endOfStream )
77              {
78                  pumpStream();
79                  sleep( SLEEP_TIME );
80              }
81          }
82          catch ( Exception e )
83          {
84              // getLogger().warn("Jikes.run()", e);
85          }
86      }
87  }