storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [12/23] storm git commit: Remove obsolete metrics
Date Tue, 14 Jul 2015 19:06:43 GMT
Remove obsolete metrics


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/ee4e94a0
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/ee4e94a0
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/ee4e94a0

Branch: refs/heads/0.9.x-branch
Commit: ee4e94a01c29caacea480b12d57a7d77174bb9be
Parents: ad8112d
Author: Enno Shioji <eshioji@gmail.com>
Authored: Sun May 31 00:54:52 2015 +0100
Committer: Enno Shioji <eshioji@gmail.com>
Committed: Sun May 31 00:54:52 2015 +0100

----------------------------------------------------------------------
 storm-core/src/jvm/backtype/storm/messaging/netty/Client.java | 7 -------
 1 file changed, 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/ee4e94a0/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
index 187bba3..ac36035 100644
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
@@ -104,12 +104,6 @@ public class Client extends ConnectionWithStatus implements IStatefulObject
{
     private final AtomicInteger messagesLost = new AtomicInteger(0);
 
     /**
-     * Number of messages buffered in memory.
-     */
-    private final AtomicLong pendingMessages = new AtomicLong(0);
-
-
-    /**
      * This flag is set to true if and only if a client instance is being closed.
      */
     private volatile boolean closing = false;
@@ -371,7 +365,6 @@ public class Client extends ConnectionWithStatus implements IStatefulObject
{
         HashMap<String, Object> ret = new HashMap<String, Object>();
         ret.put("reconnects", totalConnectionAttempts.getAndSet(0));
         ret.put("sent", messagesSent.getAndSet(0));
-        ret.put("pending", pendingMessages.get());
         ret.put("lostOnSend", messagesLost.getAndSet(0));
         ret.put("dest", dstAddress.toString());
         String src = srcAddressName();


Mime
View raw message