diff src/org/eclipse/jetty/util/IO.java @ 862:2bb375e94f64

simplify jetty.util.IO
author Franklin Schmidt <fschmidt@gmail.com>
date Sun, 02 Oct 2016 05:17:11 -0600
parents 8e9db0bbf4f9
children
line wrap: on
line diff
--- a/src/org/eclipse/jetty/util/IO.java	Wed Sep 28 13:50:22 2016 -0600
+++ b/src/org/eclipse/jetty/util/IO.java	Sun Oct 02 05:17:11 2016 -0600
@@ -33,7 +33,6 @@
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.eclipse.jetty.util.thread.QueuedThreadPool;
 
 /* ======================================================================== */
 /** IO Utilities.
@@ -42,515 +41,273 @@
  */
 public class IO 
 {
-    private static final Logger LOG = LoggerFactory.getLogger(IO.class);
-    
-    /* ------------------------------------------------------------------- */
-    public final static String
-        CRLF      = "\015\012";
-
-    /* ------------------------------------------------------------------- */
-    public final static byte[]
-        CRLF_BYTES    = {(byte)'\015',(byte)'\012'};
-
-    /* ------------------------------------------------------------------- */
-    public static int bufferSize = 64*1024;
-    
-    /* ------------------------------------------------------------------- */
-    // TODO get rid of this singleton!
-    private static class Singleton {
-        static final QueuedThreadPool __pool=new QueuedThreadPool();
-        static
-        {
-            try{__pool.start();}
-            catch(Exception e){LOG.warn("",e); System.exit(1);}
-        }
-    }
-
-    /* ------------------------------------------------------------------- */
-    static class Job implements Runnable
-    {
-        InputStream in;
-        OutputStream out;
-        Reader read;
-        Writer write;
+	private static final Logger LOG = LoggerFactory.getLogger(IO.class);
+	
+	/* ------------------------------------------------------------------- */
+	private static int bufferSize = 64*1024;
+	
+	/* ------------------------------------------------------------------- */
+	/** Copy Stream in to Stream out until EOF or exception.
+	 */
+	public static void copy(InputStream in, OutputStream out)
+		 throws IOException
+	{
+		copy(in,out,-1);
+	}
+	
+	/* ------------------------------------------------------------------- */
+	/** Copy Reader to Writer out until EOF or exception.
+	 */
+	public static void copy(Reader in, Writer out)
+		 throws IOException
+	{
+		copy(in,out,-1);
+	}
+	
+	/* ------------------------------------------------------------------- */
+	/** Copy Stream in to Stream for byteCount bytes or until EOF or exception.
+	 */
+	public static void copy(InputStream in,
+							OutputStream out,
+							long byteCount)
+		 throws IOException
+	{     
+		byte buffer[] = new byte[bufferSize];
+		int len=bufferSize;
+		
+		if (byteCount>=0)
+		{
+			while (byteCount>0)
+			{
+				int max = byteCount<bufferSize?(int)byteCount:bufferSize;
+				len=in.read(buffer,0,max);
+				
+				if (len==-1)
+					break;
+				
+				byteCount -= len;
+				out.write(buffer,0,len);
+			}
+		}
+		else
+		{
+			while (true)
+			{
+				len=in.read(buffer,0,bufferSize);
+				if (len<0 )
+					break;
+				out.write(buffer,0,len);
+			}
+		}
+	}  
+	
+	/* ------------------------------------------------------------------- */
+	/** Copy Reader to Writer for byteCount bytes or until EOF or exception.
+	 */
+	public static void copy(Reader in,
+							Writer out,
+							long byteCount)
+		 throws IOException
+	{  
+		char buffer[] = new char[bufferSize];
+		int len=bufferSize;
+		
+		if (byteCount>=0)
+		{
+			while (byteCount>0)
+			{
+				if (byteCount<bufferSize)
+					len=in.read(buffer,0,(int)byteCount);
+				else
+					len=in.read(buffer,0,bufferSize);                   
+				
+				if (len==-1)
+					break;
+				
+				byteCount -= len;
+				out.write(buffer,0,len);
+			}
+		}
+		else if (out instanceof PrintWriter)
+		{
+			PrintWriter pout=(PrintWriter)out;
+			while (!pout.checkError())
+			{
+				len=in.read(buffer,0,bufferSize);
+				if (len==-1)
+					break;
+				out.write(buffer,0,len);
+			}
+		}
+		else
+		{
+			while (true)
+			{
+				len=in.read(buffer,0,bufferSize);
+				if (len==-1)
+					break;
+				out.write(buffer,0,len);
+			}
+		}
+	}
 
-        Job(InputStream in,OutputStream out)
-        {
-            this.in=in;
-            this.out=out;
-            this.read=null;
-            this.write=null;
-        }
-        Job(Reader read,Writer write)
-        {
-            this.in=null;
-            this.out=null;
-            this.read=read;
-            this.write=write;
-        }
-        
-        /* ------------------------------------------------------------ */
-        /* 
-         * @see java.lang.Runnable#run()
-         */
-        public void run()
-        {
-            try {
-                if (in!=null)
-                    copy(in,out,-1);
-                else
-                    copy(read,write,-1);
-            }
-            catch(IOException e)
-            {
-                LOG.trace("",e);
-                try{
-                    if (out!=null)
-                        out.close();
-                    if (write!=null)
-                        write.close();
-                }
-                catch(IOException e2)
-                {
-                    LOG.trace("",e2);
-                }
-            }
-        }
-    }
-    
-    /* ------------------------------------------------------------------- */
-    /** Copy Stream in to Stream out until EOF or exception.
-     * in own thread
-     */
-    public static void copyThread(InputStream in, OutputStream out)
-    {
-        try{
-            Job job=new Job(in,out);
-            if (!Singleton.__pool.dispatch(job))
-                job.run();
-        }
-        catch(Exception e)
-        {
-            LOG.warn("",e);
-        }
-    }
-    
-    /* ------------------------------------------------------------------- */
-    /** Copy Stream in to Stream out until EOF or exception.
-     */
-    public static void copy(InputStream in, OutputStream out)
-         throws IOException
-    {
-        copy(in,out,-1);
-    }
-    
-    /* ------------------------------------------------------------------- */
-    /** Copy Stream in to Stream out until EOF or exception
-     * in own thread
-     */
-    public static void copyThread(Reader in, Writer out)
-    {
-        try
-        {
-            Job job=new Job(in,out);
-            if (!Singleton.__pool.dispatch(job))
-                job.run();
-        }
-        catch(Exception e)
-        {
-            LOG.warn("",e);
-        }
-    }
-    
-    /* ------------------------------------------------------------------- */
-    /** Copy Reader to Writer out until EOF or exception.
-     */
-    public static void copy(Reader in, Writer out)
-         throws IOException
-    {
-        copy(in,out,-1);
-    }
-    
-    /* ------------------------------------------------------------------- */
-    /** Copy Stream in to Stream for byteCount bytes or until EOF or exception.
-     */
-    public static void copy(InputStream in,
-                            OutputStream out,
-                            long byteCount)
-         throws IOException
-    {     
-        byte buffer[] = new byte[bufferSize];
-        int len=bufferSize;
-        
-        if (byteCount>=0)
-        {
-            while (byteCount>0)
-            {
-                int max = byteCount<bufferSize?(int)byteCount:bufferSize;
-                len=in.read(buffer,0,max);
-                
-                if (len==-1)
-                    break;
-                
-                byteCount -= len;
-                out.write(buffer,0,len);
-            }
-        }
-        else
-        {
-            while (true)
-            {
-                len=in.read(buffer,0,bufferSize);
-                if (len<0 )
-                    break;
-                out.write(buffer,0,len);
-            }
-        }
-    }  
-    
-    /* ------------------------------------------------------------------- */
-    /** Copy Reader to Writer for byteCount bytes or until EOF or exception.
-     */
-    public static void copy(Reader in,
-                            Writer out,
-                            long byteCount)
-         throws IOException
-    {  
-        char buffer[] = new char[bufferSize];
-        int len=bufferSize;
-        
-        if (byteCount>=0)
-        {
-            while (byteCount>0)
-            {
-                if (byteCount<bufferSize)
-                    len=in.read(buffer,0,(int)byteCount);
-                else
-                    len=in.read(buffer,0,bufferSize);                   
-                
-                if (len==-1)
-                    break;
-                
-                byteCount -= len;
-                out.write(buffer,0,len);
-            }
-        }
-        else if (out instanceof PrintWriter)
-        {
-            PrintWriter pout=(PrintWriter)out;
-            while (!pout.checkError())
-            {
-                len=in.read(buffer,0,bufferSize);
-                if (len==-1)
-                    break;
-                out.write(buffer,0,len);
-            }
-        }
-        else
-        {
-            while (true)
-            {
-                len=in.read(buffer,0,bufferSize);
-                if (len==-1)
-                    break;
-                out.write(buffer,0,len);
-            }
-        }
-    }
-
-    /* ------------------------------------------------------------ */
-    /** Copy files or directories
-     * @param from
-     * @param to
-     * @throws IOException
-     */
-    public static void copy(File from,File to) throws IOException
-    {
-        if (from.isDirectory())
-            copyDir(from,to);
-        else
-            copyFile(from,to);
-    }
+	/* ------------------------------------------------------------ */
+	/** Copy files or directories
+	 * @param from
+	 * @param to
+	 * @throws IOException
+	 */
+	public static void copy(File from,File to) throws IOException
+	{
+		if (from.isDirectory())
+			copyDir(from,to);
+		else
+			copyFile(from,to);
+	}
 
-    /* ------------------------------------------------------------ */
-    public static void copyDir(File from,File to) throws IOException
-    {
-        if (to.exists())
-        {
-            if (!to.isDirectory())
-                throw new IllegalArgumentException(to.toString());
-        }
-        else
-            to.mkdirs();
-        
-        File[] files = from.listFiles();
-        if (files!=null)
-        {
-            for (int i=0;i<files.length;i++)
-            {
-                String name = files[i].getName();
-                if (".".equals(name) || "..".equals(name))
-                    continue;
-                copy(files[i],new File(to,name));
-            }
-        }
-    }
-    
-    /* ------------------------------------------------------------ */
-    public static void copyFile(File from,File to) throws IOException
-    {
-        FileInputStream in=new FileInputStream(from);
-        FileOutputStream out=new FileOutputStream(to);
-        copy(in,out);
-        in.close();
-        out.close();
-    }
-    
-    /* ------------------------------------------------------------ */
-    /** Read input stream to string.
-     */
-    public static String toString(InputStream in)
-        throws IOException
-    {
-        return toString(in,null);
-    }
-    
-    /* ------------------------------------------------------------ */
-    /** Read input stream to string.
-     */
-    public static String toString(InputStream in,String encoding)
-        throws IOException
-    {
-        StringWriter writer=new StringWriter();
-        InputStreamReader reader = encoding==null?new InputStreamReader(in):new InputStreamReader(in,encoding);
-        
-        copy(reader,writer);
-        return writer.toString();
-    }
-    
-    /* ------------------------------------------------------------ */
-    /** Read input stream to string.
-     */
-    public static String toString(Reader in)
-        throws IOException
-    {
-        StringWriter writer=new StringWriter();
-        copy(in,writer);
-        return writer.toString();
-    }
-
+	/* ------------------------------------------------------------ */
+	public static void copyDir(File from,File to) throws IOException
+	{
+		if (to.exists())
+		{
+			if (!to.isDirectory())
+				throw new IllegalArgumentException(to.toString());
+		}
+		else
+			to.mkdirs();
+		
+		File[] files = from.listFiles();
+		if (files!=null)
+		{
+			for (int i=0;i<files.length;i++)
+			{
+				String name = files[i].getName();
+				if (".".equals(name) || "..".equals(name))
+					continue;
+				copy(files[i],new File(to,name));
+			}
+		}
+	}
+	
+	/* ------------------------------------------------------------ */
+	public static void copyFile(File from,File to) throws IOException
+	{
+		FileInputStream in=new FileInputStream(from);
+		FileOutputStream out=new FileOutputStream(to);
+		copy(in,out);
+		in.close();
+		out.close();
+	}
+	
 
-    /* ------------------------------------------------------------ */
-    /** Delete File.
-     * This delete will recursively delete directories - BE CAREFULL
-     * @param file The file to be deleted.
-     */
-    public static boolean delete(File file)
-    {
-        if (!file.exists())
-            return false;
-        if (file.isDirectory())
-        {
-            File[] files = file.listFiles();
-            for (int i=0;files!=null && i<files.length;i++)
-                delete(files[i]);
-        }
-        return file.delete();
-    }
-
-    /* ------------------------------------------------------------ */
-    /**
-     * closes any {@link Closeable}
-     *
-     * @param c the closeable to close
-     */
-    public static void close(Closeable c)
-    {
-        try
-        {
-            if (c != null)
-                c.close();
-        }
-        catch (IOException e)
-        {
-            LOG.trace("",e);
-        }
-    }
-    
-    /**
-     * closes an input stream, and logs exceptions
-     *
-     * @param is the input stream to close
-     */
-    public static void close(InputStream is)
-    {
-        try
-        {
-            if (is != null)
-                is.close();
-        }
-        catch (IOException e)
-        {
-            LOG.trace("",e);
-        }
-    }
-
-    /**
-     * closes a reader, and logs exceptions
-     * 
-     * @param reader the reader to close
-     */
-    public static void close(Reader reader)
-    {
-        try
-        {
-            if (reader != null)
-                reader.close();
-        } catch (IOException e)
-        {
-            LOG.trace("",e);
-        }
-    }
+	/* ------------------------------------------------------------ */
+	/**
+	 * closes any {@link Closeable}
+	 *
+	 * @param c the closeable to close
+	 */
+	public static void close(Closeable c)
+	{
+		try
+		{
+			if (c != null)
+				c.close();
+		}
+		catch (IOException e)
+		{
+			LOG.trace("",e);
+		}
+	}
+	
+	/**
+	 * closes an input stream, and logs exceptions
+	 *
+	 * @param is the input stream to close
+	 */
+	public static void close(InputStream is)
+	{
+		try
+		{
+			if (is != null)
+				is.close();
+		}
+		catch (IOException e)
+		{
+			LOG.trace("",e);
+		}
+	}
 
-    /**
-     * closes a writer, and logs exceptions
-     * 
-     * @param writer the writer to close
-     */
-    public static void close(Writer writer)
-    {
-        try
-        {
-            if (writer != null)
-                writer.close();
-        } catch (IOException e)
-        {
-            LOG.trace("",e);
-        }
-    }
-    
-    /* ------------------------------------------------------------ */
-    public static byte[] readBytes(InputStream in)
-        throws IOException
-    {
-        ByteArrayOutputStream bout = new ByteArrayOutputStream();
-        copy(in,bout);
-        return bout.toByteArray();
-    }
-    
-    /* ------------------------------------------------------------ */
-    /**
-     * closes an output stream, and logs exceptions
-     *
-     * @param os the output stream to close
-     */
-    public static void close(OutputStream os)
-    {
-        try
-        {
-            if (os != null)
-                os.close();
-        }
-        catch (IOException e)
-        {
-            LOG.trace("",e);
-        }
-    }
-
-    /* ------------------------------------------------------------ */
-    /** 
-     * @return An outputstream to nowhere
-     */
-    public static OutputStream getNullStream()
-    {
-        return __nullStream;
-    }
+	/**
+	 * closes a reader, and logs exceptions
+	 * 
+	 * @param reader the reader to close
+	 */
+	public static void close(Reader reader)
+	{
+		try
+		{
+			if (reader != null)
+				reader.close();
+		} catch (IOException e)
+		{
+			LOG.trace("",e);
+		}
+	}
 
-    /* ------------------------------------------------------------ */
-    /** 
-     * @return An outputstream to nowhere
-     */
-    public static InputStream getClosedStream()
-    {
-        return __closedStream;
-    }
-    
-    /* ------------------------------------------------------------ */
-    /* ------------------------------------------------------------ */
-    private static class NullOS extends OutputStream                                    
-    {
-        @Override
-        public void close(){}
-        @Override
-        public void flush(){}
-        @Override
-        public void write(byte[]b){}
-        @Override
-        public void write(byte[]b,int i,int l){}
-        @Override
-        public void write(int b){}
-    }
-    private static NullOS __nullStream = new NullOS();
+	/**
+	 * closes a writer, and logs exceptions
+	 * 
+	 * @param writer the writer to close
+	 */
+	public static void close(Writer writer)
+	{
+		try
+		{
+			if (writer != null)
+				writer.close();
+		} catch (IOException e)
+		{
+			LOG.trace("",e);
+		}
+	}
+	
+	/* ------------------------------------------------------------ */
+	/**
+	 * closes an output stream, and logs exceptions
+	 *
+	 * @param os the output stream to close
+	 */
+	public static void close(OutputStream os)
+	{
+		try
+		{
+			if (os != null)
+				os.close();
+		}
+		catch (IOException e)
+		{
+			LOG.trace("",e);
+		}
+	}
 
-    
-    /* ------------------------------------------------------------ */
-    /* ------------------------------------------------------------ */
-    private static class ClosedIS extends InputStream                                    
-    {
-        @Override
-        public int read() throws IOException
-        {
-            return -1;
-        }
-    }
-    private static ClosedIS __closedStream = new ClosedIS();
-    
-    /* ------------------------------------------------------------ */
-    /** 
-     * @return An writer to nowhere
-     */
-    public static Writer getNullWriter()
-    {
-        return __nullWriter;
-    }
-    
-    /* ------------------------------------------------------------ */
-    /** 
-     * @return An writer to nowhere
-     */
-    public static PrintWriter getNullPrintWriter()
-    {
-        return __nullPrintWriter;
-    }
-    
-    /* ------------------------------------------------------------ */
-    /* ------------------------------------------------------------ */
-    private static class NullWrite extends Writer                                    
-    {
-        @Override
-        public void close(){}
-        @Override
-        public void flush(){}
-        @Override
-        public void write(char[]b){}
-        @Override
-        public void write(char[]b,int o,int l){}
-        @Override
-        public void write(int b){}
-        @Override
-        public void write(String s){}
-        @Override
-        public void write(String s,int o,int l){}
-    }
-    private static NullWrite __nullWriter = new NullWrite();
-    private static PrintWriter __nullPrintWriter = new PrintWriter(__nullWriter);
+	/* ------------------------------------------------------------ */
+	/** 
+	 * @return An outputstream to nowhere
+	 */
+	public static InputStream getClosedStream()
+	{
+		return __closedStream;
+	}
+	
+	/* ------------------------------------------------------------ */
+	/* ------------------------------------------------------------ */
+	private static class ClosedIS extends InputStream                                    
+	{
+		@Override
+		public int read() throws IOException
+		{
+			return -1;
+		}
+	}
+	private static ClosedIS __closedStream = new ClosedIS();
 }
-
-
-
-
-
-
-
-
-