HDFS-11003. Expose XmitsInProgress through DataNodeMXBean. Contributed By Brahma Reddy Battula

(cherry picked from commit 5f4ae85bd8)
This commit is contained in:
Brahma Reddy Battula 2016-10-15 22:28:33 +05:30
parent a0eee72053
commit 64e532393b
3 changed files with 14 additions and 3 deletions

View File

@ -2081,8 +2081,9 @@ public class DataNode extends ReconfigurableBase
}
}
}
int getXmitsInProgress() {
@Override //DataNodeMXBean
public int getXmitsInProgress() {
return xmitsInProgress.get();
}

View File

@ -93,6 +93,12 @@ public interface DataNodeMXBean {
*/
public int getXceiverCount();
/**
* Returns an estimate of the number of data replication/reconstruction tasks
* running currently.
*/
public int getXmitsInProgress();
/**
* Gets the network error counts on a per-Datanode basis.
*/

View File

@ -90,7 +90,11 @@ public class TestDataNodeMXBean {
int xceiverCount = (Integer)mbs.getAttribute(mxbeanName,
"XceiverCount");
Assert.assertEquals(datanode.getXceiverCount(), xceiverCount);
// Ensure mxbean's XmitsInProgress is same as the DataNode's
// live value.
int xmitsInProgress =
(Integer) mbs.getAttribute(mxbeanName, "XmitsInProgress");
Assert.assertEquals(datanode.getXmitsInProgress(), xmitsInProgress);
String bpActorInfo = (String)mbs.getAttribute(mxbeanName,
"BPServiceActorInfo");
Assert.assertEquals(datanode.getBPServiceActorInfo(), bpActorInfo);