HADOOP-6475. Adding some javadoc to Server.RpcMetrics, UGI. Contributed by Jitendra Pandey and borya.

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@979919 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jakob Homan 2010-07-28 00:56:50 +00:00
parent fa49f7349d
commit 5c5c163aa3
4 changed files with 51 additions and 3 deletions

View File

@ -86,6 +86,9 @@ Trunk (unreleased changes)
HADOOP-6877. Common part of HDFS-1178 (NameNode servlets should communicate HADOOP-6877. Common part of HDFS-1178 (NameNode servlets should communicate
with NameNode directrly). (Kan Zhang via jghoman) with NameNode directrly). (Kan Zhang via jghoman)
HADOOP-6475. Adding some javadoc to Server.RpcMetrics, UGI.
(Jitendra Pandey and borya via jghoman)
OPTIMIZATIONS OPTIMIZATIONS
BUG FIXES BUG FIXES

View File

@ -231,7 +231,10 @@ public abstract class Server {
} }
} }
/*Returns a handle to the rpcMetrics (required in tests)*/ /**
* Returns a handle to the rpcMetrics (required in tests)
* @return rpc metrics
*/
public RpcMetrics getRpcMetrics() { public RpcMetrics getRpcMetrics() {
return rpcMetrics; return rpcMetrics;
} }

View File

@ -76,26 +76,57 @@ public class RpcMetrics implements Updater {
* -they can also be read directly - e.g. JMX does this. * -they can also be read directly - e.g. JMX does this.
*/ */
/**
* metrics - number of bytes received
*/
public final MetricsTimeVaryingLong receivedBytes = public final MetricsTimeVaryingLong receivedBytes =
new MetricsTimeVaryingLong("ReceivedBytes", registry); new MetricsTimeVaryingLong("ReceivedBytes", registry);
/**
* metrics - number of bytes sent
*/
public final MetricsTimeVaryingLong sentBytes = public final MetricsTimeVaryingLong sentBytes =
new MetricsTimeVaryingLong("SentBytes", registry); new MetricsTimeVaryingLong("SentBytes", registry);
/**
* metrics - rpc queue time
*/
public final MetricsTimeVaryingRate rpcQueueTime = public final MetricsTimeVaryingRate rpcQueueTime =
new MetricsTimeVaryingRate("RpcQueueTime", registry); new MetricsTimeVaryingRate("RpcQueueTime", registry);
public MetricsTimeVaryingRate rpcProcessingTime = /**
* metrics - rpc processing time
*/
public final MetricsTimeVaryingRate rpcProcessingTime =
new MetricsTimeVaryingRate("RpcProcessingTime", registry); new MetricsTimeVaryingRate("RpcProcessingTime", registry);
/**
* metrics - number of open connections
*/
public final MetricsIntValue numOpenConnections = public final MetricsIntValue numOpenConnections =
new MetricsIntValue("NumOpenConnections", registry); new MetricsIntValue("NumOpenConnections", registry);
/**
* metrics - length of the queue
*/
public final MetricsIntValue callQueueLen = public final MetricsIntValue callQueueLen =
new MetricsIntValue("callQueueLen", registry); new MetricsIntValue("callQueueLen", registry);
/**
* metrics - number of failed authentications
*/
public final MetricsTimeVaryingInt authenticationFailures = public final MetricsTimeVaryingInt authenticationFailures =
new MetricsTimeVaryingInt("rpcAuthenticationFailures", registry); new MetricsTimeVaryingInt("rpcAuthenticationFailures", registry);
/**
* metrics - number of successful authentications
*/
public final MetricsTimeVaryingInt authenticationSuccesses = public final MetricsTimeVaryingInt authenticationSuccesses =
new MetricsTimeVaryingInt("rpcAuthenticationSuccesses", registry); new MetricsTimeVaryingInt("rpcAuthenticationSuccesses", registry);
/**
* metrics - number of failed authorizations
*/
public final MetricsTimeVaryingInt authorizationFailures = public final MetricsTimeVaryingInt authorizationFailures =
new MetricsTimeVaryingInt("rpcAuthorizationFailures", registry); new MetricsTimeVaryingInt("rpcAuthorizationFailures", registry);
/**
* metrics - number of successful authorizations
*/
public final MetricsTimeVaryingInt authorizationSuccesses = public final MetricsTimeVaryingInt authorizationSuccesses =
new MetricsTimeVaryingInt("rpcAuthorizationSuccesses", registry); new MetricsTimeVaryingInt("rpcAuthorizationSuccesses", registry);
/** /**
* Push the metrics to the monitoring subsystem on doUpdate() call. * Push the metrics to the monitoring subsystem on doUpdate() call.
*/ */
@ -113,6 +144,9 @@ public class RpcMetrics implements Updater {
metricsRecord.update(); metricsRecord.update();
} }
/**
* shutdown the metrics
*/
public void shutdown() { public void shutdown() {
if (rpcMBean != null) if (rpcMBean != null)
rpcMBean.shutdown(); rpcMBean.shutdown();

View File

@ -556,6 +556,9 @@ public class UserGroupInformation {
return new UserGroupInformation(subject); return new UserGroupInformation(subject);
} }
/**
* existing types of authentications' methods
*/
@InterfaceStability.Evolving @InterfaceStability.Evolving
public static enum AuthenticationMethod { public static enum AuthenticationMethod {
SIMPLE, SIMPLE,
@ -566,7 +569,8 @@ public class UserGroupInformation {
PROXY; PROXY;
} }
/* Create a proxy user using username of the effective user and the ugi of the /**
* Create a proxy user using username of the effective user and the ugi of the
* real user. * real user.
* *
* @param effective * @param effective
@ -587,6 +591,10 @@ public class UserGroupInformation {
return new UserGroupInformation(subject); return new UserGroupInformation(subject);
} }
/**
* get RealUser (vs. EffectiveUser)
* @return realUser running over proxy user
*/
public UserGroupInformation getRealUser() { public UserGroupInformation getRealUser() {
for (RealUser p: subject.getPrincipals(RealUser.class)) { for (RealUser p: subject.getPrincipals(RealUser.class)) {
return p.getRealUser(); return p.getRealUser();