natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add message dropped tasks to nodetool netstats 

patch by Jeremiah Jordan; reviewed by yukim for CASSANDRA-11855
This commit is contained in:
Jeremiah D Jordan 2016-05-20 11:44:44 -05:00 committed by Yuki Morishita
parent 00f25401c9
commit 129b1193e2
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -1,4 +1,5 @@
2.1.15
* Add message dropped tasks to nodetool netstats (CASSANDRA-11855)
* Don't compute expensive MaxPurgeableTimestamp until we've verified there's an
expired tombstone (CASSANDRA-11834)
* Fix paging on DISTINCT queries repeats result when first row in partition changes

11
src/java/org/apache/cassandra/tools/NodeTool.java
View File

@ -708,10 +708,12 @@ public class NodeTool
System.out.printf("%-25s", "Pool Name");
System.out.printf("%10s", "Active");
System.out.printf("%10s", "Pending");
System.out.printf("%15s%n", "Completed");
System.out.printf("%15s", "Completed");
System.out.printf("%10s%n", "Dropped");
int pending;
long completed;
long dropped;
pending = 0;
for (int n : ms.getCommandPendingTasks().values())
@ -719,7 +721,10 @@ public class NodeTool
completed = 0;
for (long n : ms.getCommandCompletedTasks().values())
completed += n;
System.out.printf("%-25s%10s%10s%15s%n", "Commands", "n/a", pending, completed);
dropped = 0;
for (long n : ms.getCommandDroppedTasks().values())
dropped += n;
System.out.printf("%-25s%10s%10s%15s%10s%n", "Commands", "n/a", pending, completed, dropped);
pending = 0;
for (int n : ms.getResponsePendingTasks().values())
@ -727,7 +732,7 @@ public class NodeTool
completed = 0;
for (long n : ms.getResponseCompletedTasks().values())
completed += n;
System.out.printf("%-25s%10s%10s%15s%n", "Responses", "n/a", pending, completed);
System.out.printf("%-25s%10s%10s%15s%10s%n", "Responses", "n/a", pending, completed, "n/a");
}
}
}