Changeset 42efed5 for core


Ignore:
Timestamp:
Dec 3, 2016 4:00:09 PM (4 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
176ecaa
Parents:
f461d48
Message:

Clean up single char indexOf()

Location:
core/java/src
Files:
7 edited

Legend:

Unmodified
Added
Removed
  • core/java/src/freenet/support/CPUInformation/CPUID.java

    rf461d48 r42efed5  
    1919
    2020import net.i2p.I2PAppContext;
     21import net.i2p.data.DataHelper;
    2122import net.i2p.util.FileUtil;
    2223import net.i2p.util.SystemVersion;
     
    536537            outFile = new File(I2PAppContext.getGlobalContext().getTempDir(), filename);
    537538            fos = new FileOutputStream(outFile);
    538             byte buf[] = new byte[4096];
    539             while (true) {
    540                 int read = libStream.read(buf);
    541                 if (read < 0) break;
    542                 fos.write(buf, 0, read);
    543             }
     539            DataHelper.copy(libStream, fos);
    544540            fos.close();
    545541            fos = null;
  • core/java/src/net/i2p/data/Base32.java

    rf461d48 r42efed5  
    103103    private static byte[] read(InputStream in) throws IOException {
    104104        ByteArrayOutputStream baos = new ByteArrayOutputStream(64);
    105         byte buf[] = new byte[64];
    106         while (true) {
    107             int read = in.read(buf);
    108             if (read < 0) break;
    109             baos.write(buf, 0, read);
    110         }
     105        DataHelper.copy(in, baos);
    111106        return baos.toByteArray();
    112107    }
  • core/java/src/net/i2p/data/Base64.java

    rf461d48 r42efed5  
    259259    private static byte[] read(InputStream in) throws IOException {
    260260        ByteArrayOutputStream baos = new ByteArrayOutputStream(1024);
    261         byte buf[] = new byte[1024];
    262         while (true) {
    263             int read = in.read(buf);
    264             if (read < 0) break;
    265             baos.write(buf, 0, read);
    266         }
     261        DataHelper.copy(in, baos);
    267262        return baos.toByteArray();
    268263    }
  • core/java/src/net/i2p/data/DataHelper.java

    rf461d48 r42efed5  
    18311831        return p.split(s, limit);
    18321832    }
     1833
     1834    /**
     1835      * Copy in to out. Caller MUST close the streams.
     1836      *
     1837      * @param in non-null
     1838      * @param out non-null
     1839      * @since 0.9.29
     1840      */
     1841    public static void copy(InputStream in, OutputStream out) throws IOException {
     1842        final ByteCache cache = ByteCache.getInstance(8, 8*1024);
     1843        final ByteArray ba = cache.acquire();
     1844        try {
     1845            final byte buf[] = ba.getData();
     1846            int read;
     1847            while ((read = in.read(buf)) != -1) {
     1848                out.write(buf, 0, read);
     1849            }   
     1850        } finally {
     1851            cache.release(ba);
     1852        }
     1853    }
    18331854}
  • core/java/src/net/i2p/util/EepGet.java

    rf461d48 r42efed5  
    17361736        private final InputStream _inRaw;
    17371737        private final OutputStream _out;
    1738         private static final int CACHE_SIZE = 8*1024;
    1739         private final ByteCache _cache = ByteCache.getInstance(8, CACHE_SIZE);
    17401738
    17411739        public Gunzipper(InputStream in, OutputStream out) {
     
    17511749                // blocking
    17521750                in.initialize(_inRaw);
    1753                 ba = _cache.acquire();
    1754                 byte buf[] = ba.getData();
    1755                 int read = -1;
    1756                 while ( (read = in.read(buf)) != -1) {
    1757                     _out.write(buf, 0, read);
    1758                 }
     1751                DataHelper.copy(in, _out);
    17591752            } catch (IOException ioe) {
    17601753                _decompressException = ioe;
     
    17691762                } catch (IOException ioe) {}
    17701763                ReusableGZIPInputStream.release(in);
    1771                 if (ba != null)
    1772                     _cache.release(ba);
    17731764            }
    17741765        }
  • core/java/src/net/i2p/util/FileUtil.java

    rf461d48 r42efed5  
    1919import java.util.zip.ZipFile;
    2020
     21import net.i2p.data.DataHelper;
     22
    2123// Pack200 now loaded dynamically in unpack() below
    2224//
     
    105107        ZipFile zip = null;
    106108        try {
    107             byte buf[] = new byte[16*1024];
    108109            zip = new ZipFile(zipfile);
    109110            Enumeration<? extends ZipEntry> entries = zip.entries();
     
    153154                        } else {
    154155                            fos = new FileOutputStream(target);
    155                             int read = 0;
    156                             while ( (read = in.read(buf)) != -1) {
    157                                 fos.write(buf, 0, read);
    158                             }
     156                            DataHelper.copy(in, fos);
    159157                            if (logLevel <= Log.INFO)
    160158                                System.err.println("INFO: File [" + entry.getName() + "] extracted");
     
    406404        if (!targetStr.startsWith(rootDirStr)) throw new FileNotFoundException("Requested file is outside the root dir: " + path);
    407405
    408         byte buf[] = new byte[4*1024];
    409406        FileInputStream in = null;
    410407        try {
    411408            in = new FileInputStream(target);
    412             int read = 0;
    413             while ( (read = in.read(buf)) != -1)
    414                 out.write(buf, 0, read);
     409            DataHelper.copy(in, out);
    415410            try { out.close(); } catch (IOException ioe) {}
    416411        } finally {
     
    449444        if (dst.exists() && !overwriteExisting) return false;
    450445       
    451         byte buf[] = new byte[4096];
    452446        InputStream in = null;
    453447        OutputStream out = null;
     
    455449            in = new FileInputStream(src);
    456450            out = new FileOutputStream(dst);
    457            
    458             int read = 0;
    459             while ( (read = in.read(buf)) != -1)
    460                 out.write(buf, 0, read);
    461            
     451            DataHelper.copy(in, out);
    462452            return true;
    463453        } catch (IOException ioe) {
  • core/java/src/net/i2p/util/NativeBigInteger.java

    rf461d48 r42efed5  
    11041104            outFile = new File(I2PAppContext.getGlobalContext().getTempDir(), filename);
    11051105            fos = new FileOutputStream(outFile);
    1106             byte buf[] = new byte[4096];
    1107             while (true) {
    1108                 int read = libStream.read(buf);
    1109                 if (read < 0) break;
    1110                 fos.write(buf, 0, read);
    1111             }
     1106            DataHelper.copy(libStream, fos);
    11121107            fos.close();
    11131108            fos = null;
Note: See TracChangeset for help on using the changeset viewer.