public void run() {
try {
// Send stats requests
- statsRequestSender();
+ for (NodeStatisticsHandler h : handlers.values()) {
+ sendStatisticsRequestsToNode(h);
+ }
// Perform cleanup
for(NodeStatisticsHandler nodeStatisticsAger : handlers.values()){
return dps.beginTransaction();
}
- private void statsRequestSender() {
- for (NodeStatisticsHandler h : handlers.values()) {
- sendStatisticsRequestsToNode(h);
- }
- }
-
private void sendStatisticsRequestsToNode(final NodeStatisticsHandler h) {
NodeKey targetNode = h.getTargetNodeKey();
spLogger.debug("Send requests for statistics collection to node : {}", targetNode.getId());