Changeset e5f186f6


Ignore:
Timestamp:
Nov 26, 2015 3:02:47 PM (5 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
9367aca
Parents:
807e5bf
Message:

fix stopping of reader

Location:
apps/sam/java/src/net/i2p/sam/client
Files:
3 edited

Legend:

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

    r807e5bf re5f186f6  
    9999                        return _helloOk.booleanValue() ? _version : null;
    100100                }
    101             } catch (InterruptedException ie) {}
     101            } catch (InterruptedException ie) { return null; }
    102102        }
    103103    }
     
    117117                        return _sessionCreateOk.booleanValue();
    118118                }
    119             } catch (InterruptedException ie) {}
     119            } catch (InterruptedException ie) { return false; }
    120120        }
    121121    }
     
    135135                        return _streamStatusOk.booleanValue();
    136136                }
    137             } catch (InterruptedException ie) {}
     137            } catch (InterruptedException ie) { return false; }
    138138        }
    139139    }
     
    162162                    }
    163163                }
    164             } catch (InterruptedException ie) {}
     164            } catch (InterruptedException ie) { return null; }
    165165        }
    166166    }
  • apps/sam/java/src/net/i2p/sam/client/SAMReader.java

    r807e5bf re5f186f6  
    4343            _thread.interrupt();
    4444            _thread = null;
     45            try { _inRaw.close(); } catch (IOException ioe) {}
    4546        }
    4647    }
     
    99100                    }
    100101                    if (c == -1) {
    101                         _log.error("Error reading from the SAM bridge");
     102                        _log.info("EOF reading from the SAM bridge");
    102103                        break;
    103104                    }
     
    107108                }
    108109               
    109                 String line = new String(baos.toByteArray());
     110                String line = "";
     111                try {
     112                    line = new String(baos.toByteArray(), "ISO-8859-1");
     113                } catch (IOException ioe) {}
    110114                baos.reset();
    111                
    112                 if (line == null) {
    113                     _log.info("No more data from the SAM bridge");
    114                     break;
    115                 }
    116115               
    117116                if (_log.shouldDebug())
     
    122121                if (tok.countTokens() < 2) {
    123122                    _log.error("Invalid SAM line: [" + line + "]");
    124                     _live = false;
    125123                    break;
    126124                }
     
    146144                processEvent(major, minor, params);
    147145            }
     146            _live = false;
    148147            if (_log.shouldWarn())
    149148                _log.warn("SAMReader exiting");
  • apps/sam/java/src/net/i2p/sam/client/SAMStreamSend.java

    r807e5bf re5f186f6  
    182182    }
    183183   
    184     private void send(OutputStream samOut, SAMEventHandler eventHandler) {
     184    private void send(OutputStream samOut, SAMEventHandler eventHandler) throws IOException {
    185185        Sender sender = new Sender(samOut, eventHandler);
    186186        boolean ok = sender.openConnection();
     
    188188            I2PAppThread t = new I2PAppThread(sender, "Sender");
    189189            t.start();
     190        } else {
     191            throw new IOException("Sender failed to connect");
    190192        }
    191193    }
Note: See TracChangeset for help on using the changeset viewer.