public class org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher extends java.lang.Object implements io.grpc.stub.StreamObserver
{
private org.apache.dubbo.common.config.configcenter.ConfigurationListener listener;
protected io.etcd.jetcd.api.WatchGrpc$WatchStub watchStub;
private io.grpc.stub.StreamObserver observer;
protected long watchId;
private io.grpc.ManagedChannel channel;
private final java.lang.String key;
private final java.lang.String group;
private java.lang.String normalizedKey;
final org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration this$0;
public void <init>(org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration, java.lang.String, java.lang.String, org.apache.dubbo.common.config.configcenter.ConfigurationListener)
{
org.apache.dubbo.common.config.configcenter.ConfigurationListener v;
io.grpc.ManagedChannel v;
org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration v;
org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher v;
java.lang.String v, v, v;
org.apache.dubbo.remoting.etcd.jetcd.JEtcdClient v;
v := @this: org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher;
v := @parameter: org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.dubbo.common.config.configcenter.ConfigurationListener;
v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: java.lang.String key> = v;
v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: java.lang.String group> = v;
v = specialinvoke v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration: java.lang.String convertKey(java.lang.String,java.lang.String)>(v, v);
v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: java.lang.String normalizedKey> = v;
v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: org.apache.dubbo.common.config.configcenter.ConfigurationListener listener> = v;
v = v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration: org.apache.dubbo.remoting.etcd.jetcd.JEtcdClient etcdClient>;
v = virtualinvoke v.<org.apache.dubbo.remoting.etcd.jetcd.JEtcdClient: io.grpc.ManagedChannel getChannel()>();
v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: io.grpc.ManagedChannel channel> = v;
return;
}
public void onNext(io.etcd.jetcd.api.WatchResponse)
{
org.apache.dubbo.common.config.configcenter.ConfigurationListener v;
long v;
org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher v;
org.apache.dubbo.common.config.configcenter.ConfigChangedEvent v;
java.nio.charset.Charset v;
org.apache.dubbo.common.config.configcenter.ConfigChangeType v;
io.etcd.jetcd.api.KeyValue v;
java.lang.String v, v, v;
boolean v;
io.etcd.jetcd.api.WatchResponse v;
io.etcd.jetcd.api.Event$EventType v, v;
java.util.Iterator v;
com.google.protobuf.ByteString v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher;
v := @parameter: io.etcd.jetcd.api.WatchResponse;
v = virtualinvoke v.<io.etcd.jetcd.api.WatchResponse: long getWatchId()>();
v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: long watchId> = v;
v = virtualinvoke v.<io.etcd.jetcd.api.WatchResponse: java.util.List getEventsList()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.apache.dubbo.common.config.configcenter.ConfigChangeType: org.apache.dubbo.common.config.configcenter.ConfigChangeType MODIFIED>;
v = virtualinvoke v.<io.etcd.jetcd.api.Event: io.etcd.jetcd.api.Event$EventType getType()>();
v = <io.etcd.jetcd.api.Event$EventType: io.etcd.jetcd.api.Event$EventType DELETE>;
if v != v goto label;
v = <org.apache.dubbo.common.config.configcenter.ConfigChangeType: org.apache.dubbo.common.config.configcenter.ConfigChangeType DELETED>;
label:
v = new org.apache.dubbo.common.config.configcenter.ConfigChangedEvent;
v = v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: java.lang.String key>;
v = v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: java.lang.String group>;
v = virtualinvoke v.<io.etcd.jetcd.api.Event: io.etcd.jetcd.api.KeyValue getKv()>();
v = virtualinvoke v.<io.etcd.jetcd.api.KeyValue: com.google.protobuf.ByteString getValue()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<com.google.protobuf.ByteString: java.lang.String toString(java.nio.charset.Charset)>(v);
specialinvoke v.<org.apache.dubbo.common.config.configcenter.ConfigChangedEvent: void <init>(java.lang.String,java.lang.String,java.lang.String,org.apache.dubbo.common.config.configcenter.ConfigChangeType)>(v, v, v, v);
v = v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: org.apache.dubbo.common.config.configcenter.ConfigurationListener listener>;
interfaceinvoke v.<org.apache.dubbo.common.config.configcenter.ConfigurationListener: void process(org.apache.dubbo.common.config.configcenter.ConfigChangedEvent)>(v);
goto label;
label:
return;
}
public void onError(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher v;
v := @this: org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher;
v := @parameter: java.lang.Throwable;
return;
}
public void onCompleted()
{
org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher v;
v := @this: org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher;
return;
}
public long getWatchId()
{
long v;
org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher v;
v := @this: org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher;
v = v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: long watchId>;
return v;
}
private void watch()
{
io.grpc.ManagedChannel v;
org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher v;
io.etcd.jetcd.api.WatchRequest$Builder v, v;
com.google.protobuf.ByteString v;
io.etcd.jetcd.api.WatchRequest v;
io.grpc.stub.StreamObserver v, v;
io.etcd.jetcd.api.WatchCreateRequest$Builder v, v, v;
io.etcd.jetcd.api.WatchGrpc$WatchStub v, v;
java.lang.String v;
v := @this: org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher;
v = v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: io.grpc.ManagedChannel channel>;
v = staticinvoke <io.etcd.jetcd.api.WatchGrpc: io.etcd.jetcd.api.WatchGrpc$WatchStub newStub(io.grpc.Channel)>(v);
v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: io.etcd.jetcd.api.WatchGrpc$WatchStub watchStub> = v;
v = v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: io.etcd.jetcd.api.WatchGrpc$WatchStub watchStub>;
v = virtualinvoke v.<io.etcd.jetcd.api.WatchGrpc$WatchStub: io.grpc.stub.StreamObserver watch(io.grpc.stub.StreamObserver)>(v);
v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: io.grpc.stub.StreamObserver observer> = v;
v = staticinvoke <io.etcd.jetcd.api.WatchCreateRequest: io.etcd.jetcd.api.WatchCreateRequest$Builder newBuilder()>();
v = v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: java.lang.String normalizedKey>;
v = staticinvoke <com.google.protobuf.ByteString: com.google.protobuf.ByteString copyFromUtf8(java.lang.String)>(v);
v = virtualinvoke v.<io.etcd.jetcd.api.WatchCreateRequest$Builder: io.etcd.jetcd.api.WatchCreateRequest$Builder setKey(com.google.protobuf.ByteString)>(v);
v = virtualinvoke v.<io.etcd.jetcd.api.WatchCreateRequest$Builder: io.etcd.jetcd.api.WatchCreateRequest$Builder setProgressNotify(boolean)>(1);
v = staticinvoke <io.etcd.jetcd.api.WatchRequest: io.etcd.jetcd.api.WatchRequest$Builder newBuilder()>();
v = virtualinvoke v.<io.etcd.jetcd.api.WatchRequest$Builder: io.etcd.jetcd.api.WatchRequest$Builder setCreateRequest(io.etcd.jetcd.api.WatchCreateRequest$Builder)>(v);
v = virtualinvoke v.<io.etcd.jetcd.api.WatchRequest$Builder: io.etcd.jetcd.api.WatchRequest build()>();
v = v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: io.grpc.stub.StreamObserver observer>;
interfaceinvoke v.<io.grpc.stub.StreamObserver: void onNext(java.lang.Object)>(v);
return;
}
private void cancelWatch()
{
io.etcd.jetcd.api.WatchCancelRequest v;
long v;
org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher v;
io.etcd.jetcd.api.WatchRequest$Builder v, v;
io.etcd.jetcd.api.WatchRequest v;
io.grpc.stub.StreamObserver v;
io.etcd.jetcd.api.WatchCancelRequest$Builder v, v;
v := @this: org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher;
v = staticinvoke <io.etcd.jetcd.api.WatchCancelRequest: io.etcd.jetcd.api.WatchCancelRequest$Builder newBuilder()>();
v = v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: long watchId>;
v = virtualinvoke v.<io.etcd.jetcd.api.WatchCancelRequest$Builder: io.etcd.jetcd.api.WatchCancelRequest$Builder setWatchId(long)>(v);
v = virtualinvoke v.<io.etcd.jetcd.api.WatchCancelRequest$Builder: io.etcd.jetcd.api.WatchCancelRequest build()>();
v = staticinvoke <io.etcd.jetcd.api.WatchRequest: io.etcd.jetcd.api.WatchRequest$Builder newBuilder()>();
v = virtualinvoke v.<io.etcd.jetcd.api.WatchRequest$Builder: io.etcd.jetcd.api.WatchRequest$Builder setCancelRequest(io.etcd.jetcd.api.WatchCancelRequest)>(v);
v = virtualinvoke v.<io.etcd.jetcd.api.WatchRequest$Builder: io.etcd.jetcd.api.WatchRequest build()>();
v = v.<org.apache.dubbo.configcenter.support.etcd.EtcdDynamicConfiguration$EtcdConfigWatcher: io.grpc.stub.StreamObserver observer>;
interfaceinvoke v.<io.grpc.stub.StreamObserver: void onNext(java.lang.Object)>(v);
return;
}
}