Changeset 2b54d85 for apps/ministreaming


Ignore:
Timestamp:
Oct 1, 2004 5:19:37 PM (17 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
a14da92
Parents:
a63c1b1
git-author:
jrandom <jrandom> (10/01/04 17:19:37)
git-committer:
zzz <zzz@…> (10/01/04 17:19:37)
Message:

logging

File:
1 edited

Legend:

Unmodified
Added
Removed
  • apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketManager.java

    ra63c1b1 r2b54d85  
    177177
    178178        if (s == null) {
    179             _log.warn(getName() + ": No socket responsible for ACK packet");
     179            _log.warn(getName() + ": No socket responsible for ACK packet for id " + getReadableForm(id));
    180180            return;
    181181        }
     
    224224        }
    225225       
    226         _log.debug(getName() + ": *Disconnect outgoing for socket " + s);
     226        _log.debug(getName() + ": *Disconnect outgoing for socket " + s + " on id "
     227                   + getReadableForm(id));
    227228        try {
    228229            if (s != null) {
     
    260261        // packet send outgoing
    261262        if (_log.shouldLog(Log.DEBUG))
    262             _log.debug(getName() + ": *Packet send outgoing [" + payload.length + "] for socket " + s);
     263            _log.debug(getName() + ": *Packet send outgoing [" + payload.length + "] for socket "
     264                       + s + " on id " + getReadableForm(id));
    263265        if (s != null) {
    264266            s.queueData(payload);
     
    294296            }
    295297        }   
    296         _log.debug(getName() + ": *Syn! for socket " + s);
     298        _log.debug(getName() + ": *Syn! for socket " + s + " on id " + getReadableForm(newLocalID)
     299                   + " from " + d.calculateHash().toBase64().substring(0,6));
    297300       
    298301        if (!acceptConnections) {
     
    455458            _outSockets.put(localID, s);
    456459        }
     460        if (_log.shouldLog(Log.DEBUG))
     461            _log.debug(getName() + ": connect(" + peer.calculateHash().toBase64().substring(0,6)
     462                       + ", ...): localID = " + lcID);
     463       
    457464        try {
    458465            ByteArrayOutputStream pubkey = new ByteArrayOutputStream();
     
    463470            sent = _session.sendMessage(peer, packet);
    464471            if (!sent) {
    465                 _log.info(getName() + ": Unable to send & receive ack for SYN packet for socket " + s);
     472                _log.info(getName() + ": Unable to send & receive ack for SYN packet for socket "
     473                          + s + " with localID = " + lcID);
    466474                synchronized (lock) {
    467475                    _outSockets.remove(s.getLocalID());
     
    469477                _context.statManager().addRateData("streaming.synNoAck", 1, 1);
    470478                throw new I2PException("Error sending through I2P network");
     479            } else {
     480                if (_log.shouldLog(Log.DEBUG))
     481                    _log.debug(getName() + ": syn sent ok to "
     482                               + peer.calculateHash().toBase64().substring(0,6)
     483                               + " with localID = " + lcID);
    471484            }
    472485            if (options != null)
     
    474487            else
    475488                remoteID = s.getRemoteID(true, getDefaultOptions().getConnectTimeout());
     489           
     490            if (_log.shouldLog(Log.DEBUG))
     491                _log.debug(getName() + ": remoteID received from "
     492                           + peer.calculateHash().toBase64().substring(0,6)
     493                           + ": " + getReadableForm(remoteID)
     494                           + " with localID = " + lcID);
    476495           
    477496            if (remoteID == null) {
     
    491510            if (_log.shouldLog(Log.ERROR))
    492511                _log.error(getName() + ": Timeout waiting for ack from syn for id "
    493                            + getReadableForm(lcID) + " for socket " + s, ioe);
     512                           + lcID + " to " + peer.calculateHash().toBase64().substring(0,6)
     513                           + " for socket " + s, ioe);
    494514            synchronized (lock) {
    495515                _outSockets.remove(s.getLocalID());
     
    499519            throw new InterruptedIOException("Timeout waiting for ack");
    500520        } catch (ConnectException ex) {
     521            if (_log.shouldLog(Log.DEBUG))
     522                _log.debug(getName() + ": Connection error waiting for ack from syn for id "
     523                           + lcID + " to " + peer.calculateHash().toBase64().substring(0,6)
     524                           + " for socket " + s, ex);
    501525            s.internalClose();
    502526            throw ex;
    503527        } catch (NoRouteToHostException ex) {
     528            if (_log.shouldLog(Log.DEBUG))
     529                _log.debug(getName() + ": No route to host waiting for ack from syn for id "
     530                           + lcID + " to " + peer.calculateHash().toBase64().substring(0,6)
     531                           + " for socket " + s, ex);
    504532            s.internalClose();
    505533            throw ex;
    506534        } catch (IOException ex) {
    507535            if (_log.shouldLog(Log.ERROR))
    508                 _log.error(getName() + ": Error sending syn on id " + getReadableForm(lcID) + " for socket " + s, ex);
     536                _log.error(getName() + ": Error sending syn on id "
     537                           + lcID + " to " + peer.calculateHash().toBase64().substring(0,6)
     538                           + " for socket " + s, ex);
    509539            synchronized (lock) {
    510540                _outSockets.remove(s.getLocalID());
     
    514544        } catch (I2PException ex) {
    515545            if (_log.shouldLog(Log.INFO))
    516                 _log.info(getName() + ": Error sending syn on id " + getReadableForm(lcID) + " for socket " + s, ex);
     546                _log.info(getName() + ": Error sending syn on id "
     547                          + lcID + " to " + peer.calculateHash().toBase64().substring(0,6)
     548                          + " for socket " + s, ex);
    517549            synchronized (lock) {
    518550                _outSockets.remove(s.getLocalID());
     
    522554        } catch (Exception e) {
    523555            s.internalClose();
    524             _log.error(getName() + ": Unhandled error connecting", e);
     556            _log.error(getName() + ": Unhandled error connecting on "
     557                       + lcID + " to " + peer.calculateHash().toBase64().substring(0,6)
     558                       + " for socket " + s, e);
    525559            throw new ConnectException("Unhandled error connecting: " + e.getMessage());
    526560        }
     
    625659
    626660    public void removeSocket(I2PSocketImpl sock) {
    627         synchronized (lock) {
    628             _inSockets.remove(sock.getLocalID());
    629             _outSockets.remove(sock.getLocalID());
     661        String localId = sock.getLocalID();
     662        boolean removed = false;
     663        synchronized (lock) {
     664            removed = (null != _inSockets.remove(localId));
     665            removed = removed || (null != _outSockets.remove(localId));
    630666            lock.notify();
    631667        }
     
    638674
    639675        if (_log.shouldLog(Log.DEBUG)) {
    640             _log.debug(getName() + ": Removing socket \"" + getReadableForm(sock.getLocalID()) + "\" [" + sock
     676            _log.debug(getName() + ": Removing socket \"" + getReadableForm(localId) + "\" [" + sock
    641677                       + ", send: " + sent + ", recv: " + recv
    642                        + ", lifetime: " + lifetime + "ms, time since close: " + timeSinceClose + ")]",
     678                       + ", lifetime: " + lifetime + "ms, time since close: " + timeSinceClose
     679                       + " removed? " + removed + ")]",
    643680                       new Exception("removeSocket called"));
    644681        }
Note: See TracChangeset for help on using the changeset viewer.