Changeset 42efed5


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()

Files:
16 edited

Legend:

Unmodified
Added
Removed
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPServer.java

    rf461d48 r42efed5  
    659659        // shadows _log in super()
    660660        private final Log _log;
    661         private static final int BUF_SIZE = 8*1024;
    662         private static final ByteCache _cache = ByteCache.getInstance(16, BUF_SIZE);
    663661
    664662        public Sender(OutputStream out, InputStream in, String name, Log log) {
     
    672670            if (_log.shouldLog(Log.INFO))
    673671                _log.info(_name + ": Begin sending");
    674             ByteArray ba = _cache.acquire();
    675             try {
    676                 byte buf[] = ba.getData();
    677                 int read = 0;
    678                 long total = 0;
    679                 while ( (read = _in.read(buf)) != -1) {
    680                     if (_log.shouldLog(Log.INFO))
    681                         _log.info(_name + ": read " + read + " and sending through the stream");
    682                     _out.write(buf, 0, read);
    683                     total += read;
    684                 }
     672            try {
     673                DataHelper.copy(_in, _out);
    685674                if (_log.shouldLog(Log.INFO))
    686                     _log.info(_name + ": Done sending: " + total);
     675                    _log.info(_name + ": Done sending");
    687676                //_out.flush();
    688677            } catch (IOException ioe) {
     
    690679                    _log.debug("Error sending", ioe);
    691680            } finally {
    692                 _cache.release(ba);
    693681                if (_out != null) try { _out.close(); } catch (IOException ioe) {}
    694682                if (_in != null) try { _in.close(); } catch (IOException ioe) {}
  • apps/routerconsole/java/src/net/i2p/router/update/NewsFetcher.java

    rf461d48 r42efed5  
    561561            in.initialize(new FileInputStream(from));
    562562            out = new SecureFileOutputStream(to);
    563             byte buf[] = new byte[4096];
    564             int read;
    565             while ((read = in.read(buf)) != -1) {
    566                 out.write(buf, 0, read);
    567             }
     563            DataHelper.copy(in, out);
    568564        } finally {
    569565            if (out != null) try {
  • apps/routerconsole/java/src/net/i2p/router/web/ConfigClientsHandler.java

    rf461d48 r42efed5  
    435435            out = new BufferedOutputStream(new SecureFileOutputStream(tmp));
    436436            out.write(magic);
    437             byte buf[] = new byte[16*1024];
    438             int read = 0;
    439             while ( (read = in.read(buf)) != -1)  {
    440                 out.write(buf, 0, read);
    441             }
     437            DataHelper.copy(in, out);
    442438            out.close();
    443439            String url = tmp.toURI().toString();
  • apps/routerconsole/jsp/createreseed.jsp

    rf461d48 r42efed5  
    2323        byte buf[] = new byte[16*1024];
    2424        in = new java.io.FileInputStream(zip);
    25         int read = 0;
    2625        java.io.OutputStream cout = response.getOutputStream();
    27         while ( (read = in.read(buf)) != -1) {
    28             cout.write(buf, 0, read);
    29         }
     26        net.i2p.data.DataHelper.copy(in, cout);
    3027    } finally {
    3128        if (in != null)
  • apps/routerconsole/jsp/viewrouterlog.jsp

    rf461d48 r42efed5  
    2525        in = new java.io.FileInputStream(f);
    2626        java.io.OutputStream bout = response.getOutputStream();
    27         int read = 0;
    28         byte buf[] = new byte[4*1024];
    29         while ((read = in.read(buf)) != -1) {
    30             bout.write(buf, 0, read);
    31         }
     27        net.i2p.data.DataHelper.copy(in, bout);
    3228    } catch (java.io.IOException ioe) {
    3329        // prevent 'Committed' IllegalStateException from Jetty
  • apps/routerconsole/jsp/viewwrapperlog.jsp

    rf461d48 r42efed5  
    2323        in = new java.io.FileInputStream(f);
    2424        java.io.OutputStream bout = response.getOutputStream();
    25         int read = 0;
    26         byte buf[] = new byte[4*1024];
    27         while ((read = in.read(buf)) != -1) {
    28             bout.write(buf, 0, read);
    29         }
     25        net.i2p.data.DataHelper.copy(in, bout);
    3026    } catch (java.io.IOException ioe) {
    3127        // prevent 'Committed' IllegalStateException from Jetty
  • apps/susimail/src/src/i2p/susi/webmail/PersistentMailCache.java

    rf461d48 r42efed5  
    273273                        in = new GZIPInputStream(new BufferedInputStream(new FileInputStream(f)));
    274274                        ByteArrayOutputStream out = new ByteArrayOutputStream((int) len);
    275                         int read = 0;
    276                         byte buf[] = new byte[4*1024];
    277                         while ( (read = in.read(buf)) != -1)  {
    278                                 out.write(buf, 0, read);
    279                         }
     275                        DataHelper.copy(in, out);
    280276                        ReadBuffer rb = new ReadBuffer(out.toByteArray(), 0, out.size());
    281277                        return rb;
  • 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;
  • router/java/src/net/i2p/router/networkdb/reseed/Reseeder.java

    rf461d48 r42efed5  
    211211            out = new BufferedOutputStream(new SecureFileOutputStream(tmp));
    212212            out.write(magic);
    213             byte buf[] = new byte[16*1024];
    214             int read = 0;
    215             while ( (read = in.read(buf)) != -1)
    216                 out.write(buf, 0, read);
     213            DataHelper.copy(in, out);
    217214            out.close();
    218215            int[] stats;
  • router/java/src/net/i2p/router/startup/WorkingDir.java

    rf461d48 r42efed5  
    431431            in = new FileInputStream(src);
    432432            out = new SecureFileOutputStream(dst);
    433            
    434             int read = 0;
    435             while ( (read = in.read(buf)) != -1)
    436                 out.write(buf, 0, read);
    437            
     433            DataHelper.copy(in, out);
    438434            System.err.println("Copied " + src.getPath());
    439435        } catch (IOException ioe) {
Note: See TracChangeset for help on using the changeset viewer.