You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gossip.apache.org by ec...@apache.org on 2017/08/09 01:20:47 UTC
[1/3] incubator-gossip git commit: GOSSIP-87 Unused workQueue in
gossipCore
Repository: incubator-gossip
Updated Branches:
refs/heads/master 95e166770 -> 968571a56
GOSSIP-87 Unused workQueue in gossipCore
Project: http://git-wip-us.apache.org/repos/asf/incubator-gossip/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gossip/commit/4572eed7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gossip/tree/4572eed7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gossip/diff/4572eed7
Branch: refs/heads/master
Commit: 4572eed73d9512bd3bfc26e1e80e3bcb8836582a
Parents: 95cce48
Author: pxsalehi <px...@gmail.com>
Authored: Thu Aug 3 14:03:24 2017 +0200
Committer: pxsalehi <px...@gmail.com>
Committed: Thu Aug 3 14:03:24 2017 +0200
----------------------------------------------------------------------
.../java/org/apache/gossip/manager/GossipCore.java | 16 +++++++---------
1 file changed, 7 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gossip/blob/4572eed7/gossip-base/src/main/java/org/apache/gossip/manager/GossipCore.java
----------------------------------------------------------------------
diff --git a/gossip-base/src/main/java/org/apache/gossip/manager/GossipCore.java b/gossip-base/src/main/java/org/apache/gossip/manager/GossipCore.java
index 4167664..e44302e 100644
--- a/gossip-base/src/main/java/org/apache/gossip/manager/GossipCore.java
+++ b/gossip-base/src/main/java/org/apache/gossip/manager/GossipCore.java
@@ -57,26 +57,24 @@ public class GossipCore implements GossipCoreConstants {
private ConcurrentHashMap<String, LatchAndBase> requests;
private final ConcurrentHashMap<String, ConcurrentHashMap<String, PerNodeDataMessage>> perNodeData;
private final ConcurrentHashMap<String, SharedDataMessage> sharedData;
- private final BlockingQueue<Runnable> workQueue;
private final Meter messageSerdeException;
- private final Meter tranmissionException;
- private final Meter tranmissionSuccess;
+ private final Meter transmissionException;
+ private final Meter transmissionSuccess;
private final DataEventManager eventManager;
public GossipCore(GossipManager manager, MetricRegistry metrics){
this.gossipManager = manager;
requests = new ConcurrentHashMap<>();
- workQueue = new ArrayBlockingQueue<>(1024);
perNodeData = new ConcurrentHashMap<>();
sharedData = new ConcurrentHashMap<>();
eventManager = new DataEventManager(metrics);
- metrics.register(WORKQUEUE_SIZE, (Gauge<Integer>)() -> workQueue.size());
+ metrics.register(WORKQUEUE_SIZE, (Gauge<Integer>)() -> 0);
metrics.register(PER_NODE_DATA_SIZE, (Gauge<Integer>)() -> perNodeData.size());
metrics.register(SHARED_DATA_SIZE, (Gauge<Integer>)() -> sharedData.size());
metrics.register(REQUEST_SIZE, (Gauge<Integer>)() -> requests.size());
messageSerdeException = metrics.meter(MESSAGE_SERDE_EXCEPTION);
- tranmissionException = metrics.meter(MESSAGE_TRANSMISSION_EXCEPTION);
- tranmissionSuccess = metrics.meter(MESSAGE_TRANSMISSION_SUCCESS);
+ transmissionException = metrics.meter(MESSAGE_TRANSMISSION_EXCEPTION);
+ transmissionSuccess = metrics.meter(MESSAGE_TRANSMISSION_SUCCESS);
}
@SuppressWarnings({ "unchecked", "rawtypes" })
@@ -172,9 +170,9 @@ public class GossipCore implements GossipCoreConstants {
}
try {
gossipManager.getTransportManager().send(uri, json_bytes);
- tranmissionSuccess.mark();
+ transmissionSuccess.mark();
} catch (IOException e) {
- tranmissionException.mark();
+ transmissionException.mark();
throw new RuntimeException(e);
}
}
[3/3] incubator-gossip git commit: Merge branch 'master' of
https://github.com/pxsalehi/incubator-gossip
Posted by ec...@apache.org.
Merge branch 'master' of https://github.com/pxsalehi/incubator-gossip
Project: http://git-wip-us.apache.org/repos/asf/incubator-gossip/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gossip/commit/968571a5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gossip/tree/968571a5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gossip/diff/968571a5
Branch: refs/heads/master
Commit: 968571a563a73f34711f79b9fe47d0678ef38868
Parents: 95e1667 5280dc8
Author: edward <ed...@hollywood.ian>
Authored: Tue Aug 8 21:20:24 2017 -0400
Committer: edward <ed...@hollywood.ian>
Committed: Tue Aug 8 21:20:24 2017 -0400
----------------------------------------------------------------------
.../java/org/apache/gossip/manager/GossipCore.java | 15 ++++++---------
.../apache/gossip/manager/GossipCoreConstants.java | 1 -
2 files changed, 6 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
[2/3] incubator-gossip git commit: GOSSIP-87 removed WORKQUEUE_SIZE
metric
Posted by ec...@apache.org.
GOSSIP-87 removed WORKQUEUE_SIZE metric
Project: http://git-wip-us.apache.org/repos/asf/incubator-gossip/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gossip/commit/5280dc8a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gossip/tree/5280dc8a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gossip/diff/5280dc8a
Branch: refs/heads/master
Commit: 5280dc8a18b951c5061471731a9d54b2eafdfb2d
Parents: 4572eed
Author: pxsalehi <px...@gmail.com>
Authored: Tue Aug 8 19:23:22 2017 +0200
Committer: pxsalehi <px...@gmail.com>
Committed: Tue Aug 8 19:23:22 2017 +0200
----------------------------------------------------------------------
gossip-base/src/main/java/org/apache/gossip/manager/GossipCore.java | 1 -
.../main/java/org/apache/gossip/manager/GossipCoreConstants.java | 1 -
2 files changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gossip/blob/5280dc8a/gossip-base/src/main/java/org/apache/gossip/manager/GossipCore.java
----------------------------------------------------------------------
diff --git a/gossip-base/src/main/java/org/apache/gossip/manager/GossipCore.java b/gossip-base/src/main/java/org/apache/gossip/manager/GossipCore.java
index e44302e..384d796 100644
--- a/gossip-base/src/main/java/org/apache/gossip/manager/GossipCore.java
+++ b/gossip-base/src/main/java/org/apache/gossip/manager/GossipCore.java
@@ -68,7 +68,6 @@ public class GossipCore implements GossipCoreConstants {
perNodeData = new ConcurrentHashMap<>();
sharedData = new ConcurrentHashMap<>();
eventManager = new DataEventManager(metrics);
- metrics.register(WORKQUEUE_SIZE, (Gauge<Integer>)() -> 0);
metrics.register(PER_NODE_DATA_SIZE, (Gauge<Integer>)() -> perNodeData.size());
metrics.register(SHARED_DATA_SIZE, (Gauge<Integer>)() -> sharedData.size());
metrics.register(REQUEST_SIZE, (Gauge<Integer>)() -> requests.size());
http://git-wip-us.apache.org/repos/asf/incubator-gossip/blob/5280dc8a/gossip-base/src/main/java/org/apache/gossip/manager/GossipCoreConstants.java
----------------------------------------------------------------------
diff --git a/gossip-base/src/main/java/org/apache/gossip/manager/GossipCoreConstants.java b/gossip-base/src/main/java/org/apache/gossip/manager/GossipCoreConstants.java
index 6d3765a..9cac7c0 100644
--- a/gossip-base/src/main/java/org/apache/gossip/manager/GossipCoreConstants.java
+++ b/gossip-base/src/main/java/org/apache/gossip/manager/GossipCoreConstants.java
@@ -18,7 +18,6 @@
package org.apache.gossip.manager;
public interface GossipCoreConstants {
- String WORKQUEUE_SIZE = "gossip.core.workqueue.size";
String PER_NODE_DATA_SIZE = "gossip.core.pernodedata.size";
String SHARED_DATA_SIZE = "gossip.core.shareddata.size";
String REQUEST_SIZE = "gossip.core.requests.size";