Fix worker ids.

apache · Dec 4, 2017 · 11b3105 · 11b3105
1 parent baf4000
commit 11b3105
Show file tree

Hide file tree

Showing 31 changed files with 31 additions and 31 deletions.
diff --git a/...lking/apm/collector/agent/stream/parser/standardization/SegmentStandardizationWorker.java b/...lking/apm/collector/agent/stream/parser/standardization/SegmentStandardizationWorker.java
@@ -42,7 +42,7 @@ public SegmentStandardizationWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return SegmentStandardizationWorker.class.hashCode();
+        return 108;
     }
 
     @Override protected void onWork(SegmentStandardization segmentStandardization) throws WorkerException {

diff --git a/...java/org/skywalking/apm/collector/agent/stream/worker/jvm/CpuMetricPersistenceWorker.java b/...java/org/skywalking/apm/collector/agent/stream/worker/jvm/CpuMetricPersistenceWorker.java
@@ -37,7 +37,7 @@ public CpuMetricPersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return 0;
+        return 115;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/.../java/org/skywalking/apm/collector/agent/stream/worker/jvm/GCMetricPersistenceWorker.java b/.../java/org/skywalking/apm/collector/agent/stream/worker/jvm/GCMetricPersistenceWorker.java
@@ -37,7 +37,7 @@ public GCMetricPersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return 0;
+        return 112;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/.../org/skywalking/apm/collector/agent/stream/worker/jvm/InstHeartBeatPersistenceWorker.java b/.../org/skywalking/apm/collector/agent/stream/worker/jvm/InstHeartBeatPersistenceWorker.java
@@ -37,7 +37,7 @@ public InstHeartBeatPersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return InstHeartBeatPersistenceWorker.class.hashCode();
+        return 113;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/...a/org/skywalking/apm/collector/agent/stream/worker/jvm/MemoryMetricPersistenceWorker.java b/...a/org/skywalking/apm/collector/agent/stream/worker/jvm/MemoryMetricPersistenceWorker.java
@@ -37,7 +37,7 @@ public MemoryMetricPersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return 0;
+        return 119;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/...g/skywalking/apm/collector/agent/stream/worker/jvm/MemoryPoolMetricPersistenceWorker.java b/...g/skywalking/apm/collector/agent/stream/worker/jvm/MemoryPoolMetricPersistenceWorker.java
@@ -33,7 +33,7 @@
 public class MemoryPoolMetricPersistenceWorker extends PersistenceWorker<MemoryPoolMetric, MemoryPoolMetric> {
 
     @Override public int id() {
-        return 0;
+        return 122;
     }
 
     public MemoryPoolMetricPersistenceWorker(ModuleManager moduleManager) {

diff --git a/...kywalking/apm/collector/agent/stream/worker/register/ApplicationRegisterRemoteWorker.java b/...kywalking/apm/collector/agent/stream/worker/register/ApplicationRegisterRemoteWorker.java
@@ -40,7 +40,7 @@ public ApplicationRegisterRemoteWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return ApplicationRegisterRemoteWorker.class.hashCode();
+        return 10006;
     }
 
     @Override protected void onWork(Application message) throws WorkerException {

diff --git a/...kywalking/apm/collector/agent/stream/worker/register/ApplicationRegisterSerialWorker.java b/...kywalking/apm/collector/agent/stream/worker/register/ApplicationRegisterSerialWorker.java
@@ -50,7 +50,7 @@ public ApplicationRegisterSerialWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return ApplicationRegisterSerialWorker.class.hashCode();
+        return 101;
     }
 
     @Override protected void onWork(Application application) throws WorkerException {

diff --git a/...g/skywalking/apm/collector/agent/stream/worker/register/InstanceRegisterRemoteWorker.java b/...g/skywalking/apm/collector/agent/stream/worker/register/InstanceRegisterRemoteWorker.java
@@ -36,7 +36,7 @@ public class InstanceRegisterRemoteWorker extends AbstractRemoteWorker<Instance,
     private final Logger logger = LoggerFactory.getLogger(InstanceRegisterRemoteWorker.class);
 
     @Override public int id() {
-        return InstanceRegisterRemoteWorker.class.hashCode();
+        return 10001;
     }
 
     InstanceRegisterRemoteWorker(ModuleManager moduleManager) {

diff --git a/...g/skywalking/apm/collector/agent/stream/worker/register/InstanceRegisterSerialWorker.java b/...g/skywalking/apm/collector/agent/stream/worker/register/InstanceRegisterSerialWorker.java
@@ -48,7 +48,7 @@ public InstanceRegisterSerialWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return InstanceRegisterSerialWorker.class.hashCode();
+        return 102;
     }
 
     @Override protected void onWork(Instance instance) throws WorkerException {

diff --git a/...kywalking/apm/collector/agent/stream/worker/register/ServiceNameRegisterRemoteWorker.java b/...kywalking/apm/collector/agent/stream/worker/register/ServiceNameRegisterRemoteWorker.java
@@ -40,7 +40,7 @@ public ServiceNameRegisterRemoteWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return ServiceNameRegisterRemoteWorker.class.hashCode();
+        return 10000;
     }
 
     @Override protected void onWork(ServiceName serviceName) throws WorkerException {

diff --git a/...kywalking/apm/collector/agent/stream/worker/register/ServiceNameRegisterSerialWorker.java b/...kywalking/apm/collector/agent/stream/worker/register/ServiceNameRegisterSerialWorker.java
@@ -50,7 +50,7 @@ public ServiceNameRegisterSerialWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return ServiceNameRegisterSerialWorker.class.hashCode();
+        return 100;
     }
 
     @Override protected void onWork(ServiceName serviceName) throws WorkerException {

diff --git a/...ywalking/apm/collector/agent/stream/worker/trace/global/GlobalTracePersistenceWorker.java b/...ywalking/apm/collector/agent/stream/worker/trace/global/GlobalTracePersistenceWorker.java
@@ -37,7 +37,7 @@ public GlobalTracePersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return 0;
+        return 120;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/...ng/apm/collector/agent/stream/worker/trace/instance/InstPerformancePersistenceWorker.java b/...ng/apm/collector/agent/stream/worker/trace/instance/InstPerformancePersistenceWorker.java
@@ -37,7 +37,7 @@ public InstPerformancePersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return InstPerformancePersistenceWorker.class.hashCode();
+        return 118;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/...ywalking/apm/collector/agent/stream/worker/trace/node/NodeComponentAggregationWorker.java b/...ywalking/apm/collector/agent/stream/worker/trace/node/NodeComponentAggregationWorker.java
@@ -34,7 +34,7 @@ public NodeComponentAggregationWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return NodeComponentAggregationWorker.class.hashCode();
+        return 104;
     }
 
     public static class Factory extends AbstractLocalAsyncWorkerProvider<NodeComponent, NodeComponent, NodeComponentAggregationWorker> {

diff --git a/...ywalking/apm/collector/agent/stream/worker/trace/node/NodeComponentPersistenceWorker.java b/...ywalking/apm/collector/agent/stream/worker/trace/node/NodeComponentPersistenceWorker.java
@@ -37,7 +37,7 @@ public NodeComponentPersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return NodeComponentPersistenceWorker.class.hashCode();
+        return 111;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/...rg/skywalking/apm/collector/agent/stream/worker/trace/node/NodeComponentRemoteWorker.java b/...rg/skywalking/apm/collector/agent/stream/worker/trace/node/NodeComponentRemoteWorker.java
@@ -36,7 +36,7 @@ public class NodeComponentRemoteWorker extends AbstractRemoteWorker<NodeComponen
     }
 
     @Override public int id() {
-        return NodeComponentRemoteWorker.class.hashCode();
+        return 10004;
     }
 
     @Override protected void onWork(NodeComponent nodeComponent) throws WorkerException {

diff --git a/...skywalking/apm/collector/agent/stream/worker/trace/node/NodeMappingAggregationWorker.java b/...skywalking/apm/collector/agent/stream/worker/trace/node/NodeMappingAggregationWorker.java
@@ -34,7 +34,7 @@ public NodeMappingAggregationWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return NodeMappingAggregationWorker.class.hashCode();
+        return 105;
     }
 
     public static class Factory extends AbstractLocalAsyncWorkerProvider<NodeMapping, NodeMapping, NodeMappingAggregationWorker> {

diff --git a/...skywalking/apm/collector/agent/stream/worker/trace/node/NodeMappingPersistenceWorker.java b/...skywalking/apm/collector/agent/stream/worker/trace/node/NodeMappingPersistenceWorker.java
@@ -37,7 +37,7 @@ public NodeMappingPersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return NodeMappingPersistenceWorker.class.hashCode();
+        return 114;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/.../org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeMappingRemoteWorker.java b/.../org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeMappingRemoteWorker.java
@@ -36,7 +36,7 @@ public class NodeMappingRemoteWorker extends AbstractRemoteWorker<NodeMapping, N
     }
 
     @Override public int id() {
-        return NodeMappingRemoteWorker.class.hashCode();
+        return 10007;
     }
 
     @Override protected void onWork(NodeMapping nodeMapping) throws WorkerException {

diff --git a/...lking/apm/collector/agent/stream/worker/trace/noderef/NodeReferenceAggregationWorker.java b/...lking/apm/collector/agent/stream/worker/trace/noderef/NodeReferenceAggregationWorker.java
@@ -34,7 +34,7 @@ public NodeReferenceAggregationWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return NodeReferenceAggregationWorker.class.hashCode();
+        return 106;
     }
 
     public static class Factory extends AbstractLocalAsyncWorkerProvider<NodeReference, NodeReference, NodeReferenceAggregationWorker> {

diff --git a/...lking/apm/collector/agent/stream/worker/trace/noderef/NodeReferencePersistenceWorker.java b/...lking/apm/collector/agent/stream/worker/trace/noderef/NodeReferencePersistenceWorker.java
@@ -37,7 +37,7 @@ public NodeReferencePersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return 0;
+        return 116;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/...skywalking/apm/collector/agent/stream/worker/trace/noderef/NodeReferenceRemoteWorker.java b/...skywalking/apm/collector/agent/stream/worker/trace/noderef/NodeReferenceRemoteWorker.java
@@ -36,7 +36,7 @@ public class NodeReferenceRemoteWorker extends AbstractRemoteWorker<NodeReferenc
     }
 
     @Override public int id() {
-        return NodeReferenceRemoteWorker.class.hashCode();
+        return 10002;
     }
 
     @Override protected void onWork(NodeReference nodeReference) throws WorkerException {

diff --git a/...walking/apm/collector/agent/stream/worker/trace/segment/SegmentCostPersistenceWorker.java b/...walking/apm/collector/agent/stream/worker/trace/segment/SegmentCostPersistenceWorker.java
@@ -37,7 +37,7 @@ public SegmentCostPersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return SegmentCostPersistenceWorker.class.hashCode();
+        return 110;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/.../skywalking/apm/collector/agent/stream/worker/trace/segment/SegmentPersistenceWorker.java b/.../skywalking/apm/collector/agent/stream/worker/trace/segment/SegmentPersistenceWorker.java
@@ -37,7 +37,7 @@ public SegmentPersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return 0;
+        return 117;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/...alking/apm/collector/agent/stream/worker/trace/service/ServiceEntryAggregationWorker.java b/...alking/apm/collector/agent/stream/worker/trace/service/ServiceEntryAggregationWorker.java
@@ -34,7 +34,7 @@ public ServiceEntryAggregationWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return ServiceEntryAggregationWorker.class.hashCode();
+        return 103;
     }
 
     public static class Factory extends AbstractLocalAsyncWorkerProvider<ServiceEntry, ServiceEntry, ServiceEntryAggregationWorker> {

diff --git a/...alking/apm/collector/agent/stream/worker/trace/service/ServiceEntryPersistenceWorker.java b/...alking/apm/collector/agent/stream/worker/trace/service/ServiceEntryPersistenceWorker.java
@@ -37,7 +37,7 @@ public ServiceEntryPersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return 0;
+        return 121;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/.../skywalking/apm/collector/agent/stream/worker/trace/service/ServiceEntryRemoteWorker.java b/.../skywalking/apm/collector/agent/stream/worker/trace/service/ServiceEntryRemoteWorker.java
@@ -36,7 +36,7 @@ public ServiceEntryRemoteWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return ServiceEntryRemoteWorker.class.hashCode();
+        return 10003;
     }
 
     @Override protected void onWork(ServiceEntry serviceEntry) throws WorkerException {

diff --git a/...apm/collector/agent/stream/worker/trace/serviceref/ServiceReferenceAggregationWorker.java b/...apm/collector/agent/stream/worker/trace/serviceref/ServiceReferenceAggregationWorker.java
@@ -34,7 +34,7 @@ public ServiceReferenceAggregationWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return ServiceReferenceAggregationWorker.class.hashCode();
+        return 107;
     }
 
     public static class Factory extends AbstractLocalAsyncWorkerProvider<ServiceReference, ServiceReference, ServiceReferenceAggregationWorker> {

diff --git a/...apm/collector/agent/stream/worker/trace/serviceref/ServiceReferencePersistenceWorker.java b/...apm/collector/agent/stream/worker/trace/serviceref/ServiceReferencePersistenceWorker.java
@@ -37,7 +37,7 @@ public ServiceReferencePersistenceWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return 0;
+        return 109;
     }
 
     @Override protected boolean needMergeDBData() {

diff --git a/...king/apm/collector/agent/stream/worker/trace/serviceref/ServiceReferenceRemoteWorker.java b/...king/apm/collector/agent/stream/worker/trace/serviceref/ServiceReferenceRemoteWorker.java
@@ -36,7 +36,7 @@ public ServiceReferenceRemoteWorker(ModuleManager moduleManager) {
     }
 
     @Override public int id() {
-        return ServiceReferenceRemoteWorker.class.hashCode();
+        return 10005;
     }
 
     @Override protected void onWork(ServiceReference serviceReference) throws WorkerException {