Changeset 1f92232 for apps/sam


Ignore:
Timestamp:
Aug 26, 2018 1:50:40 PM (3 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
e64ad7c
Parents:
db54edc
Message:

Findbugs all over

File:
1 edited

Legend:

Unmodified
Added
Removed
  • apps/sam/java/src/net/i2p/sam/SAMStreamSession.java

    rdb54edc r1f92232  
    2222import java.util.Iterator;
    2323import java.util.List;
     24import java.util.Map;
    2425import java.util.Properties;
    2526import java.util.Set;
     
    397398     */
    398399    protected int createSocketHandler ( I2PSocket s, int id ) {
    399         SAMStreamSessionSocketReader reader = null;
    400         StreamSender sender = null;
     400        SAMStreamSessionSocketReader reader;
     401        StreamSender sender;
    401402        if (id == 0) {
    402403            id = createUniqueId();
     
    469470
    470471        synchronized (handlersMap) {
    471             reader = handlersMap.remove(Integer.valueOf(id));
    472             sender = sendersMap.remove(Integer.valueOf(id));
     472            Integer iid = Integer.valueOf(id);
     473            reader = handlersMap.remove(iid);
     474            sender = sendersMap.remove(iid);
    473475        }
    474476
     
    487489     */
    488490    private void removeAllSocketHandlers() {
    489         Integer id;
    490         Set<Integer> keySet;
    491         Iterator<Integer> iter;
    492 
    493491        synchronized (handlersMap) {
    494             keySet = handlersMap.keySet();
    495             iter = keySet.iterator();
    496            
    497             while (iter.hasNext()) {
    498                  id = iter.next();
    499                  handlersMap.get(id).stopRunning();
     492            for (Map.Entry<Integer, SAMStreamSessionSocketReader> e : handlersMap.entrySet()) {
     493                 Integer id = e.getKey();
     494                 e.getValue().stopRunning();
    500495                 sendersMap.get(id).shutDownGracefully();
    501496            }
Note: See TracChangeset for help on using the changeset viewer.