View Javadoc

    1   /*
    2    *  Licensed to the Apache Software Foundation (ASF) under one
    3    *  or more contributor license agreements.  See the NOTICE file
    4    *  distributed with this work for additional information
    5    *  regarding copyright ownership.  The ASF licenses this file
    6    *  to you under the Apache License, Version 2.0 (the
    7    *  "License"); you may not use this file except in compliance
    8    *  with the License.  You may obtain a copy of the License at
    9    *
    10   *    http://www.apache.org/licenses/LICENSE-2.0
    11   *
    12   *  Unless required by applicable law or agreed to in writing,
    13   *  software distributed under the License is distributed on an
    14   *  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
    15   *  KIND, either express or implied.  See the License for the
    16   *  specific language governing permissions and limitations
    17   *  under the License.
    18   *
    19   */
    20  package org.apache.mina.management;
    21
    22  import org.apache.mina.common.IoSession;
    23
    24  /**
    25   * The collected stats for a session. It's used by {@link StatCollector} to attach
    26   * throughput stats to an {@link IoSession}. You can accces a session stat using
    27   * {@link IoSession} getAttribute method :
    28   * <pre>
    29   * IoSession session = ...
    30   * IoSessionStat stat = session.getAttribute( StatCollector.KEY );
    31   * </pre>
    32   *
    33   * @author The Apache Directory Project (mina-dev@directory.apache.org)
    34   * @version $Rev: 555855 $, $Date: 2007-07-13 05:19:00 +0200 (Fri, 13 Jul 2007) $
    35   */
    36  public class IoSessionStat {
    37      long lastByteRead = -1;
    38
    39      long lastByteWrite = -1;
    40
    41      long lastMessageRead = -1;
    42
    43      long lastMessageWrite = -1;
    44
    45      float byteWrittenThroughput = 0;
    46
    47      float byteReadThroughput = 0;
    48
    49      float messageWrittenThroughput = 0;
    50
    51      float messageReadThroughput = 0;
    52
    53      //  last time the session was polled
    54      long lastPollingTime = System.currentTimeMillis();
    55
    56      /**
    57       * Bytes read per second
    58       * @return bytes per second
    59       */
    60      public float getByteReadThroughput() {
    61          return byteReadThroughput;
    62      }
    63
    64      /**
    65       * Bytes written per second
    66       * @return bytes per second
    67       */
    68      public float getByteWrittenThroughput() {
    69          return byteWrittenThroughput;
    70      }
    71
    72      /**
    73       * Messages read per second
    74       * @return messages per second
    75       */
    76      public float getMessageReadThroughput() {
    77          return messageReadThroughput;
    78      }
    79
    80      /**
    81       * Messages written per second
    82       * @return messages per second
    83       */
    84      public float getMessageWrittenThroughput() {
    85          return messageWrittenThroughput;
    86      }
    87
    88      /**
    89       * used for the StatCollector, last polling value
    90       */
    91      long getLastByteRead() {
    92          return lastByteRead;
    93      }
    94
    95      /**
    96       * used for the StatCollector, last polling value
    97       */
    98      long getLastByteWrite() {
    99          return lastByteWrite;
    100     }
    101
    102     /**
    103      * used for the StatCollector, last polling value
    104      */
    105     long getLastMessageRead() {
    106         return lastMessageRead;
    107     }
    108
    109     /**
    110      * used for the StatCollector, last polling value
    111      */
    112     long getLastMessageWrite() {
    113         return lastMessageWrite;
    114     }
    115 }