Changeset a67ea4b


Ignore:
Timestamp:
Dec 9, 2017 1:02:17 AM (3 years ago)
Author:
str4d <str4d@…>
Branches:
master
Children:
4512a94
Parents:
fe5e4a2
Message:

Cleanups: Close resources via try-finally

We can't use try-with-resources until we bump the minimum-supported Android
version for the client library to API 19.

Files:
14 edited

Legend:

Unmodified
Added
Removed
  • apps/addressbook/java/src/net/metanotion/io/block/BlockFile.java

    rfe5e4a2 ra67ea4b  
    145145                }
    146146                boolean init = !(new File(args[0])).exists();
     147                RAIFile raif = null;
     148                BlockFile bf = null;
    147149                try {
    148                         RAIFile raif = new RAIFile(new File(args[0]), true, true);
    149                         BlockFile bf = new BlockFile(raif, init);
     150                        raif = new RAIFile(new File(args[0]), true, true);
     151                        bf = new BlockFile(raif, init);
    150152                        bf.bfck(true);
    151                         bf.close();
    152                         raif.close();
    153153                } catch (IOException e) {
    154154                        e.printStackTrace();
     155                } finally {
     156                        if (bf != null) try { bf.close(); } catch (IOException ioe) {}
     157                        if (raif != null) try { raif.close(); } catch (IOException ioe) {}
    155158                }
    156159        }
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnel.java

    rfe5e4a2 ra67ea4b  
    16081608    private void runRun(String args[], Logging l) {
    16091609        if (args.length == 1) {
    1610             try {
    1611                 BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(args[0]), "UTF-8"));
     1610            BufferedReader br = null;
     1611            try {
     1612                br = new BufferedReader(new InputStreamReader(new FileInputStream(args[0]), "UTF-8"));
    16121613                String line;
    16131614                while ((line = br.readLine()) != null) {
     
    16201621                _log.error(getPrefix() + "Error running the file", ioe);
    16211622                notifyEvent("runResult", "error");
     1623            } finally {
     1624                if (br != null) try { br.close(); } catch (IOException ioe) {}
    16221625            }
    16231626        } else {
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2Ping.java

    rfe5e4a2 ra67ea4b  
    160160
    161161      if (hostListFile != null) {
    162             BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(hostListFile), "UTF-8"));
     162        BufferedReader br = null;
     163        try {
     164            br = new BufferedReader(new InputStreamReader(new FileInputStream(hostListFile), "UTF-8"));
    163165            String line;
    164166            List<PingHandler> pingHandlers = new ArrayList<PingHandler>();
     
    182184                t.join();
    183185            return;
     186        } finally {
     187            if (br != null) try { br.close(); } catch (IOException ioe) {}
     188        }
    184189      }
    185190
  • apps/jetty/java/src/net/i2p/jetty/JettyStart.java

    rfe5e4a2 ra67ea4b  
    11package net.i2p.jetty;
     2
     3import java.io.IOException;
    24
    35// Contains code from org.mortbay.xml.XmlConfiguation:
     
    1820
    1921import java.io.InputStream;
     22import java.net.URL;
    2023import java.util.ArrayList;
    2124import java.util.Arrays;
     
    8083        Properties properties=new Properties();
    8184        XmlConfiguration last=null;
    82         InputStream in = null;
     85        Resource r = null;
    8386        for (int i = 0; i < args.length; i++) {
    8487            if (args[i].toLowerCase().endsWith(".properties")) {
    85                 in = Resource.newResource(args[i]).getInputStream();
    86                 properties.load(in);
    87                 in.close();
     88                try {
     89                    r = Resource.newResource(args[i]);
     90                    properties.load(r.getInputStream());
     91                } finally {
     92                    if (r != null) r.close();
     93                }
    8894            } else {
    89                 XmlConfiguration configuration = new XmlConfiguration(Resource.newResource(args[i]).getURL());
     95                URL configUrl;
     96                try {
     97                    r = Resource.newResource(args[i]);
     98                    configUrl = r.getURL();
     99                } finally {
     100                    if (r != null) r.close();
     101                }
     102                XmlConfiguration configuration = new XmlConfiguration(configUrl);
    90103                if (last!=null)
    91104                    configuration.getIdMap().putAll(last.getIdMap());
  • apps/routerconsole/java/src/net/i2p/router/web/helpers/LogsHelper.java

    rfe5e4a2 ra67ea4b  
    174174    private static String readTextFile(File f, int maxNumLines) {
    175175        if (!f.exists()) return null;
    176         FileInputStream fis = null;
    177176        BufferedReader in = null;
    178177        try {
    179             fis = new FileInputStream(f);
    180             in = new BufferedReader(new InputStreamReader(fis));
     178            in = new BufferedReader(new InputStreamReader(new FileInputStream(f)));
    181179            List<String> lines = new ArrayList<String>(maxNumLines);
    182180            String line = null;
  • apps/sam/java/src/net/i2p/sam/client/SAMStreamSink.java

    rfe5e4a2 ra67ea4b  
    244244
    245245        public void run() {
     246            DatagramSocket dg = null;
    246247            byte[] buf = new byte[32768];
    247248            try {
    248249                Sink sink = new Sink("FAKE", "FAKEFROM");
    249                 DatagramSocket dg = new DatagramSocket(V3DGPORT);
     250                dg = new DatagramSocket(V3DGPORT);
    250251                while (true) {
    251252                    DatagramPacket p = new DatagramPacket(buf, 32768);
     
    284285            } catch (IOException ioe) {
    285286                _log.error("DGRcvr", ioe);
     287            } finally {
     288                if (dg != null) dg.close();
    286289            }
    287290        }
  • apps/systray/java/src/net/i2p/apps/systray/UrlLauncher.java

    rfe5e4a2 ra67ea4b  
    137137        for (int i = 0; i < MAX_TRIES; i++) {
    138138            try {
    139                 Socket test = new Socket();
    140                 // this will usually fail right away if it's going to fail since it's local
    141                 test.connect(sa, WAIT_TIME);
    142                 // it worked
     139                Socket test = null;
    143140                try {
    144                    test.close();
    145                 } catch (IOException ioe) {}
     141                    test = new Socket();
     142                    // this will usually fail right away if it's going to fail since it's local
     143                    test.connect(sa, WAIT_TIME);
     144                    // it worked
     145                } finally {
     146                    if (test != null) try { test.close(); } catch (IOException ioe) {}
     147                }
    146148                // Jetty 6 seems to start the Connector before the
    147149                // webapp is completely ready
  • core/java/src/freenet/support/CPUInformation/CPUID.java

    rfe5e4a2 ra67ea4b  
    552552        if (resource == null)
    553553            return false;
     554        InputStream libStream = null;
    554555        File outFile = null;
    555556        FileOutputStream fos = null;
    556557        String filename = getLibraryPrefix() + "jcpuid" + getLibrarySuffix();
    557558        try {
    558             InputStream libStream = resource.openStream();
     559            libStream = resource.openStream();
    559560            outFile = new File(I2PAppContext.getGlobalContext().getTempDir(), filename);
    560561            fos = new FileOutputStream(outFile);
     
    581582            return false;
    582583        } finally {
     584            if (libStream != null) try { libStream.close(); } catch (IOException ioe) {}
    583585            if (fos != null) {
    584586                try { fos.close(); } catch (IOException ioe) {}
  • core/java/src/net/i2p/client/naming/SingleFileNamingService.java

    rfe5e4a2 ra67ea4b  
    211211            return success;
    212212        } catch (IOException ioe) {
     213            _log.error("Error adding " + hostname, ioe);
     214            return false;
     215        } finally {
    213216            if (in != null) try { in.close(); } catch (IOException e) {}
    214217            if (out != null) try { out.close(); } catch (IOException e) {}
    215             _log.error("Error adding " + hostname, ioe);
    216             return false;
    217         } finally { releaseWriteLock(); }
     218            releaseWriteLock();
     219        }
    218220    }
    219221
     
    334336            return success;
    335337        } catch (IOException ioe) {
     338            _log.error("Error removing " + hostname, ioe);
     339            return false;
     340        } finally {
    336341            if (in != null) try { in.close(); } catch (IOException e) {}
    337342            if (out != null) try { out.close(); } catch (IOException e) {}
    338             _log.error("Error removing " + hostname, ioe);
    339             return false;
    340         } finally {
    341343            releaseWriteLock();
    342344        }
  • core/java/src/net/i2p/crypto/TrustedUpdate.java

    rfe5e4a2 ra67ea4b  
    765765            return null;
    766766        } finally {
    767             if (bytesToSignInputStream != null)
    768                 try {
    769                     bytesToSignInputStream.close();
    770                     fileInputStream.close();
    771                 } catch (IOException ioe) {
    772                 }
    773 
     767            if (bytesToSignInputStream != null) try { bytesToSignInputStream.close(); } catch (IOException ioe) {}
     768            if (fileInputStream != null) try { fileInputStream.close(); } catch (IOException ioe) {}
    774769        }
    775770
  • core/java/src/net/i2p/data/DataHelper.java

    rfe5e4a2 ra67ea4b  
    495495     */
    496496    public static void storeProps(Properties props, File file) throws IOException {
     497        FileOutputStream fos = null;
    497498        PrintWriter out = null;
    498499        IllegalArgumentException iae = null;
    499500        File tmpFile = new File(file.getPath() + ".tmp");
    500501        try {
    501             FileOutputStream fos = new SecureFileOutputStream(tmpFile);
     502            fos = new SecureFileOutputStream(tmpFile);
    502503            out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(fos, "UTF-8")));
    503504            out.println("# NOTE: This I2P config file must use UTF-8 encoding");
     
    534535        } finally {
    535536            if (out != null) out.close();
     537            if (fos != null) try { fos.close(); } catch (IOException ioe) {}
    536538        }
    537539        if (iae != null)
  • core/java/src/net/i2p/util/NativeBigInteger.java

    rfe5e4a2 ra67ea4b  
    11201120        }
    11211121
     1122        InputStream libStream = null;
    11221123        File outFile = null;
    11231124        FileOutputStream fos = null;
    11241125        String filename =  _libPrefix + "jbigi" + _libSuffix;
    11251126        try {
    1126             InputStream libStream = resource.openStream();
     1127            libStream = resource.openStream();
    11271128            outFile = new File(I2PAppContext.getGlobalContext().getTempDir(), filename);
    11281129            fos = new FileOutputStream(outFile);
     
    11441145            return false;
    11451146        } finally {
     1147            if (libStream != null) try { libStream.close(); } catch (IOException ioe) {}
    11461148            if (fos != null) {
    11471149                try { fos.close(); } catch (IOException ioe) {}
  • core/java/src/net/i2p/util/TranslateReader.java

    rfe5e4a2 ra67ea4b  
    396396    private static void test(String file) throws IOException {
    397397        FileInputStream fio = new FileInputStream(file);
    398         TranslateReader r = new TranslateReader(I2PAppContext.getGlobalContext(),
    399                                                 "net.i2p.router.web.messages",
    400                                                 fio);
    401         int c;
    402         while ((c = r.read()) >= 0) {
    403             System.out.print((char)c);
    404         }
    405         System.out.flush();
    406         r.close();
     398        TranslateReader r = null;
     399        try {
     400            r = new TranslateReader(I2PAppContext.getGlobalContext(),
     401                                    "net.i2p.router.web.messages",
     402                                    fio);
     403            int c;
     404            while ((c = r.read()) >= 0) {
     405                System.out.print((char)c);
     406            }
     407            System.out.flush();
     408        } finally {
     409            if (r != null) try { r.close(); } catch (IOException ioe) {}
     410        }
    407411    }
    408412
  • router/java/src/org/cybergarage/upnp/ssdp/HTTPMUSocket.java

    rfe5e4a2 ra67ea4b  
    195195        public boolean send(String msg, String bindAddr, int bindPort)
    196196        {
    197                 try {
    198                         MulticastSocket msock;
     197                MulticastSocket msock = null;
     198                try {
    199199                        if ((bindAddr) != null && (0 < bindPort)) {
    200200                                msock = new MulticastSocket(null);
     
    207207                        msock.setTimeToLive(UPnP.getTimeToLive());
    208208                        msock.send(dgmPacket);
    209                         msock.close();
    210209                }
    211210                catch (Exception e) {
    212211                        Debug.warning(e);
    213212                        return false;
     213                } finally {
     214                        if (msock != null) msock.close();
    214215                }
    215216                return true;
Note: See TracChangeset for help on using the changeset viewer.