开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 网格计算 > 查看源码
RpcMgt.java
资源名称：hadoop-0.20.0.tar.gz　[点击查看]
上传用户：quxuerui
上传日期：2018-01-08
资源大小：41811k
文件大小：3k
源码类别：

网格计算

开发平台：

Java

RpcMgt.java：源码内容
  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, software
  13.  * distributed under the License is distributed on an "AS IS" BASIS,
  14.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15.  * See the License for the specific language governing permissions and
  16.  * limitations under the License.
  17.  */
  18. package org.apache.hadoop.ipc.metrics;
  21. import javax.management.ObjectName;
  23. import org.apache.hadoop.ipc.Server;
  24. import org.apache.hadoop.metrics.util.MBeanUtil;
  27. /**
  28.  * This class implements the RpcMgt MBean
  29.  *
  30.  */
  31. class RpcMgt implements RpcMgtMBean {
  32.   private RpcMetrics myMetrics;
  33.   private Server myServer;
  34.   private ObjectName mbeanName;
  35.   
  36.   RpcMgt(final String serviceName, final String port,
  37.                 final RpcMetrics metrics, Server server) {
  38.     myMetrics = metrics;
  39.     myServer = server;
  40.     mbeanName = MBeanUtil.registerMBean(serviceName,
  41.                     "RpcStatisticsForPort" + port, this);
  42.   }
  44.   public void shutdown() {
  45.     if (mbeanName != null)
  46.       MBeanUtil.unregisterMBean(mbeanName);
  47.   }
  48.   
  49.   /**
  50.    * @inheritDoc
  51.    */
  52.   public long getRpcOpsAvgProcessingTime() {
  53.     return myMetrics.rpcProcessingTime.getPreviousIntervalAverageTime();
  54.   }
  55.   
  56.   /**
  57.    * @inheritDoc
  58.    */
  59.   public long getRpcOpsAvgProcessingTimeMax() {
  60.     return myMetrics.rpcProcessingTime.getMaxTime();
  61.   }
  63.   /**
  64.    * @inheritDoc
  65.    */
  66.   public long getRpcOpsAvgProcessingTimeMin() {
  67.     return myMetrics.rpcProcessingTime.getMinTime();
  68.   }
  70.   /**
  71.    * @inheritDoc
  72.    */
  73.   public long getRpcOpsAvgQueueTime() {
  74.     return myMetrics.rpcQueueTime.getPreviousIntervalAverageTime();
  75.   }
  76.   
  77.   /**
  78.    * @inheritDoc
  79.    */
  80.   public long getRpcOpsAvgQueueTimeMax() {
  81.     return myMetrics.rpcQueueTime.getMaxTime();
  82.   }
  84.   /**
  85.    * @inheritDoc
  86.    */
  87.   public long getRpcOpsAvgQueueTimeMin() {
  88.     return myMetrics.rpcQueueTime.getMinTime();
  89.   }
  91.   /**
  92.    * @inheritDoc
  93.    */
  94.   public int getRpcOpsNumber() {
  95.     return myMetrics.rpcProcessingTime.getPreviousIntervalNumOps() ;
  96.   }
  98.   /**
  99.    * @inheritDoc
  100.    */
  101.   public int getNumOpenConnections() {
  102.     return myServer.getNumOpenConnections();
  103.   }
  104.   
  105.   /**
  106.    * @inheritDoc
  107.    */
  108.   public int getCallQueueLen() {
  109.     return myServer.getCallQueueLen();
  110.   }
  112.   /**
  113.    * @inheritDoc
  114.    */
  115.   public void resetAllMinMax() {
  116.     myMetrics.rpcProcessingTime.resetMinMax();
  117.     myMetrics.rpcQueueTime.resetMinMax();
  118.   }
  119. }