提交 10574638 编写于 作者: 彭勇升 pengys 提交者: wu-sheng

Correct spelling errors in the network protocol. (#3091)

* Correct spelling errors in the network protocol.

* update protocol submodule commit id.
上级 90253591
Subproject commit ef3f6f0c18db9e4d11dbdd7ceacd16df456c3a1b
Subproject commit 7b244ff7ec350910295eee85633e02d92a6f6b1c
......@@ -19,17 +19,11 @@
package org.apache.skywalking.apm.agent.core.dictionary;
import io.netty.util.internal.ConcurrentSet;
import java.util.Map;
import java.util.Set;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import org.apache.skywalking.apm.agent.core.logging.api.ILog;
import org.apache.skywalking.apm.agent.core.logging.api.LogManager;
import org.apache.skywalking.apm.agent.core.logging.api.*;
import org.apache.skywalking.apm.network.common.DetectPoint;
import org.apache.skywalking.apm.network.register.v2.Endpoint;
import org.apache.skywalking.apm.network.register.v2.EndpointMapping;
import org.apache.skywalking.apm.network.register.v2.EndpointMappingElement;
import org.apache.skywalking.apm.network.register.v2.Enpoints;
import org.apache.skywalking.apm.network.register.v2.RegisterGrpc;
import org.apache.skywalking.apm.network.register.v2.*;
import static org.apache.skywalking.apm.agent.core.conf.Config.Dictionary.ENDPOINT_NAME_BUFFER_SIZE;
......@@ -73,7 +67,7 @@ public enum EndpointNameDictionary {
public void syncRemoteDictionary(
RegisterGrpc.RegisterBlockingStub serviceNameDiscoveryServiceBlockingStub) {
if (unRegisterEndpoints.size() > 0) {
Enpoints.Builder builder = Enpoints.newBuilder();
Endpoints.Builder builder = Endpoints.newBuilder();
for (OperationNameKey operationNameKey : unRegisterEndpoints) {
Endpoint endpoint = Endpoint.newBuilder()
.setServiceId(operationNameKey.getServiceId())
......
......@@ -130,7 +130,7 @@ public class RegisterServiceHandler extends RegisterGrpc.RegisterImplBase implem
responseObserver.onCompleted();
}
@Override public void doEndpointRegister(Enpoints request, StreamObserver<EndpointMapping> responseObserver) {
@Override public void doEndpointRegister(Endpoints request, StreamObserver<EndpointMapping> responseObserver) {
EndpointMapping.Builder builder = EndpointMapping.newBuilder();
request.getEndpointsList().forEach(endpoint -> {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册