Changeset f3e2dfac


Ignore:
Timestamp:
Nov 21, 2011 7:06:17 PM (9 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
df8cd90, f4f5873
Parents:
9d0bafb
Message:

stat cleanups

File:
1 edited

Legend:

Unmodified
Added
Removed
  • router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java

    r9d0bafb rf3e2dfac  
    302302                    _log.warn("Too backlogged for too long (" + _consecutiveBacklog + " messages for " + DataHelper.formatDuration(queueTime()) + ", sched? " + wantsWrite + ", blocks: " + blocks + ") sending to " + _remotePeer.calculateHash());
    303303                }
    304                 _context.statManager().addRateData("ntcp.closeOnBacklog", getUptime(), getUptime());
     304                _context.statManager().addRateData("ntcp.closeOnBacklog", getUptime());
    305305                close();
    306306            }
    307             _context.statManager().addRateData("ntcp.dontSendOnBacklog", _consecutiveBacklog, msg.getLifetime());
     307            _context.statManager().addRateData("ntcp.dontSendOnBacklog", _consecutiveBacklog);
    308308            return;
    309309        }
     
    354354                } catch (Exception e) {}  // java.nio.channels.CancelledKeyException
    355355            }
    356             _context.statManager().addRateData("ntcp.sendBacklogTime", queueTime, size);
     356            _context.statManager().addRateData("ntcp.sendBacklogTime", queueTime);
    357357            return true;
    358358        //} else if (size > 32) { // another arbitrary limit.
     
    915915            if (msg != null) {
    916916                _lastSendTime = System.currentTimeMillis();
    917                 _context.statManager().addRateData("ntcp.sendTime", msg.getSendTime(), msg.getSendTime());
     917                _context.statManager().addRateData("ntcp.sendTime", msg.getSendTime());
    918918                if (_log.shouldLog(Log.INFO)) {
    919919                    _log.info("I2NP message " + _messagesWritten + "/" + msg.getMessageId() + " sent after "
     
    10201020                if (!ok) {
    10211021                    _log.error("Read buffer " + System.identityHashCode(buf) + " contained corrupt data");
    1022                     _context.statManager().addRateData("ntcp.corruptDecryptedI2NP", 1, getUptime());
     1022                    _context.statManager().addRateData("ntcp.corruptDecryptedI2NP", 1);
    10231023                    return;
    10241024                }
     
    10411041        if (_curReadState.getSize() > BUFFER_SIZE) {
    10421042            _log.error("I2NP message too big - size: " + _curReadState.getSize() + " Dropping " + toString());
    1043             _context.statManager().addRateData("ntcp.corruptTooLargeI2NP", _curReadState.getSize(), getUptime());
     1043            _context.statManager().addRateData("ntcp.corruptTooLargeI2NP", _curReadState.getSize());
    10441044            close();
    10451045            return false;
     
    10691069            if (_log.shouldLog(Log.WARN))
    10701070                _log.warn("I2NP metadata message had a bad CRC value");
    1071             _context.statManager().addRateData("ntcp.corruptMetaCRC", 1, getUptime());
     1071            _context.statManager().addRateData("ntcp.corruptMetaCRC", 1);
    10721072            close();
    10731073            return;
     
    10771077                if (_log.shouldLog(Log.WARN))
    10781078                    _log.warn("Peer's skew jumped too far (from " + _clockSkew + " s to " + newSkew + " s): " + toString());
    1079                 _context.statManager().addRateData("ntcp.corruptSkew", newSkew, getUptime());
     1079                _context.statManager().addRateData("ntcp.corruptSkew", newSkew);
    10801080                close();
    10811081                return;
    10821082            }
    1083             _context.statManager().addRateData("ntcp.receiveMeta", newSkew, getUptime());
     1083            _context.statManager().addRateData("ntcp.receiveMeta", newSkew);
    10841084            if (_log.shouldLog(Log.DEBUG))
    10851085                _log.debug("Received NTCP metadata, old skew of " + _clockSkew + " s, new skew of " + newSkew + "s.");
     
    11271127   
    11281128   
    1129     public long getReadTime() { return _curReadState.getReadTime(); }
     1129    //public long getReadTime() { return _curReadState.getReadTime(); }
    11301130   
    11311131    private static class DataBuf {
     
    11651165
    11661166    /**
     1167     * Read the unencrypted message (16 bytes at a time).
     1168     * verify the checksum, and pass it on to
     1169     * an I2NPMessageHandler.  The unencrypted message is encoded as follows:
     1170     *
     1171     *<pre>
     1172     *  +-------+-------+--//--+---//----+-------+-------+-------+-------+
     1173     *  | sizeof(data)  | data | padding | adler checksum of sz+data+pad |
     1174     *  +-------+-------+--//--+---//----+-------+-------+-------+-------+
     1175     *</pre>
     1176     *
    11671177     * sizeof(data)+data+pad+crc.
    11681178     *
     
    11771187        private int _nextWrite;
    11781188        private long _expectedCrc;
    1179         private Adler32 _crc;
     1189        private final Adler32 _crc;
    11801190        private long _stateBegin;
    11811191        private int _blocks;
     1192
    11821193        public ReadState() {
    11831194            _crc = new Adler32();
    11841195            init();
    11851196        }
     1197
    11861198        private void init() {
    11871199            _size = -1;
     
    11951207            _dataBuf = null;
    11961208        }
     1209
    11971210        public int getSize() { return _size; }
     1211
     1212        /**
     1213         *  Caller must synchronize
     1214         *  @param buf 16 bytes
     1215         */
    11981216        public void receiveBlock(byte buf[]) {
    11991217            if (_size == -1) {
     
    12031221            }
    12041222        }
     1223
     1224     /****
    12051225        public long getReadTime() {
    12061226            long now = System.currentTimeMillis();
     
    12111231                return readTime;
    12121232        }
     1233      ****/
     1234
     1235        /** @param buf 16 bytes */
    12131236        private void receiveInitial(byte buf[]) {
    12141237            _stateBegin = System.currentTimeMillis();
     
    12281251            }
    12291252        }
     1253
     1254        /** @param buf 16 bytes */
    12301255        private void receiveSubsequent(byte buf[]) {
    12311256            _blocks++;
     
    12501275            }
    12511276        }
     1277
     1278        /** @param buf 16 bytes */
    12521279        private void receiveLastBlock(byte buf[]) {
    12531280            //if (_log.shouldLog(Log.DEBUG))
     
    12771304                        _log.info("I2NP message " + _messagesRead + "/" + (read != null ? read.getUniqueId() : 0)
    12781305                                   + " received after " + timeToRecv + " with " + _size +"/"+ (_blocks*16) + " bytes on " + NTCPConnection.this.toString());
    1279                     _context.statManager().addRateData("ntcp.receiveTime", timeToRecv, timeToRecv);
    1280                     _context.statManager().addRateData("ntcp.receiveSize", _size, timeToRecv);
     1306                    _context.statManager().addRateData("ntcp.receiveTime", timeToRecv);
     1307                    _context.statManager().addRateData("ntcp.receiveSize", _size);
    12811308
    12821309                    // FIXME move end of try block here.
     
    12951322                    if (_log.shouldLog(Log.WARN))
    12961323                        _log.warn("Error parsing I2NP message", ioe);
    1297                     _context.statManager().addRateData("ntcp.corruptI2NPIOE", 1, getUptime());
     1324                    _context.statManager().addRateData("ntcp.corruptI2NPIOE", 1);
    12981325                    close();
    12991326                    // handler and databuf are lost
     
    13021329                    if (_log.shouldLog(Log.WARN))
    13031330                        _log.warn("Error parsing I2NP message", ime);
    1304                     _context.statManager().addRateData("ntcp.corruptI2NPIME", 1, getUptime());
     1331                    _context.statManager().addRateData("ntcp.corruptI2NPIME", 1);
    13051332                    close();
    13061333                    // handler and databuf are lost
     
    13101337                if (_log.shouldLog(Log.WARN))
    13111338                    _log.warn("CRC incorrect for message " + _messagesRead + " (calc=" + val + " expected=" + _expectedCrc + ") size=" + _size + " blocks " + _blocks);
    1312                     _context.statManager().addRateData("ntcp.corruptI2NPCRC", 1, getUptime());
     1339                    _context.statManager().addRateData("ntcp.corruptI2NPCRC", 1);
    13131340                // FIXME should we try to read in the message and keep going?
    13141341                close();
Note: See TracChangeset for help on using the changeset viewer.