You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/07/14 21:06:43 UTC
[12/23] storm git commit: Remove obsolete metrics
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 <es...@gmail.com>
Authored: Sun May 31 00:54:52 2015 +0100
Committer: Enno Shioji <es...@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();