diff --git a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/EndpointInventory.java b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/EndpointInventory.java index cb954406b..a9c0d0098 100644 --- a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/EndpointInventory.java +++ b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/EndpointInventory.java @@ -72,7 +72,7 @@ public class EndpointInventory extends RegisterSource { EndpointInventory source = (EndpointInventory)obj; if (serviceId != source.getServiceId()) return false; - if (name.equals(source.getName())) + if (!name.equals(source.getName())) return false; return true; diff --git a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/NetworkAddressInventory.java b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/NetworkAddressInventory.java index 899779bd3..c68ba637f 100644 --- a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/NetworkAddressInventory.java +++ b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/NetworkAddressInventory.java @@ -65,7 +65,7 @@ public class NetworkAddressInventory extends RegisterSource { return false; NetworkAddressInventory source = (NetworkAddressInventory)obj; - if (name.equals(source.getName())) + if (!name.equals(source.getName())) return false; return true; diff --git a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/ServiceInstanceInventory.java b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/ServiceInstanceInventory.java index 7e6956c51..4dfdd5499 100644 --- a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/ServiceInstanceInventory.java +++ b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/ServiceInstanceInventory.java @@ -97,7 +97,7 @@ public class ServiceInstanceInventory extends RegisterSource { ServiceInstanceInventory source = (ServiceInstanceInventory)obj; if (serviceId != source.getServiceId()) return false; - if (name.equals(source.getName())) + if (!name.equals(source.getName())) return false; if (isAddress != source.getIsAddress()) return false; diff --git a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/ServiceInventory.java b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/ServiceInventory.java index c6b456259..f8809a1be 100644 --- a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/ServiceInventory.java +++ b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/ServiceInventory.java @@ -84,7 +84,7 @@ public class ServiceInventory extends RegisterSource { return false; ServiceInventory source = (ServiceInventory)obj; - if (name.equals(source.getName())) + if (!name.equals(source.getName())) return false; if (isAddress != source.getIsAddress()) return false; diff --git a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/source/DetectPoint.java b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/source/DetectPoint.java index e74608648..598afcc20 100644 --- a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/source/DetectPoint.java +++ b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/source/DetectPoint.java @@ -31,7 +31,7 @@ public enum DetectPoint { case Entry: return DetectPoint.SERVER; case Exit: - return DetectPoint.SERVER; + return DetectPoint.CLIENT; case UNRECOGNIZED: case Local: default: diff --git a/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/trace/mock/AgentDataMock.java b/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/trace/mock/AgentDataMock.java index c112452ff..d2b7f03f3 100644 --- a/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/trace/mock/AgentDataMock.java +++ b/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/trace/mock/AgentDataMock.java @@ -44,20 +44,20 @@ public class AgentDataMock { ServiceAMock serviceAMock = new ServiceAMock(registerMock); serviceAMock.register(); - UniqueId.Builder serviceASegmentId = UniqueIdBuilder.INSTANCE.create(); - serviceAMock.mock(streamObserver, globalTraceId, serviceASegmentId, startTimestamp, true); - // ServiceBMock ServiceBMock serviceBMock = new ServiceBMock(registerMock); serviceBMock.register(); - UniqueId.Builder serviceBSegmentId = UniqueIdBuilder.INSTANCE.create(); - serviceBMock.mock(streamObserver, globalTraceId, serviceBSegmentId, serviceASegmentId, startTimestamp, true); - // ServiceCMock ServiceCMock serviceCMock = new ServiceCMock(registerMock); serviceCMock.register(); + UniqueId.Builder serviceASegmentId = UniqueIdBuilder.INSTANCE.create(); + serviceAMock.mock(streamObserver, globalTraceId, serviceASegmentId, startTimestamp, true); + + UniqueId.Builder serviceBSegmentId = UniqueIdBuilder.INSTANCE.create(); + serviceBMock.mock(streamObserver, globalTraceId, serviceBSegmentId, serviceASegmentId, startTimestamp, true); + UniqueId.Builder serviceCSegmentId = UniqueIdBuilder.INSTANCE.create(); serviceCMock.mock(streamObserver, globalTraceId, serviceCSegmentId, serviceBSegmentId, startTimestamp, true); diff --git a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/MetricQueryEsDAO.java b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/MetricQueryEsDAO.java index ad897b642..d40f533f2 100644 --- a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/MetricQueryEsDAO.java +++ b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/MetricQueryEsDAO.java @@ -150,7 +150,7 @@ public class MetricQueryEsDAO extends EsDAO implements IMetricQueryDAO { } for (IntKeyLongValue intKeyLongValue : intKeyLongValues) { - axisYValues.set(intKeyLongValue.getKey(), intKeyLongValue.getValue()); + axisYValues.set(intKeyLongValue.getKey() - 1, intKeyLongValue.getValue()); } thermodynamicValueMatrix.add(axisYValues);