public class oadd.org.apache.calcite.avatica.remote.RemoteProtobufService extends oadd.org.apache.calcite.avatica.remote.ProtobufService
{
private static final org.slf4j.Logger LOG;
private final oadd.org.apache.calcite.avatica.remote.AvaticaHttpClient client;
private final oadd.org.apache.calcite.avatica.remote.ProtobufTranslation translation;
public void <init>(oadd.org.apache.calcite.avatica.remote.AvaticaHttpClient, oadd.org.apache.calcite.avatica.remote.ProtobufTranslation)
{
oadd.org.apache.calcite.avatica.remote.AvaticaHttpClient v;
oadd.org.apache.calcite.avatica.remote.ProtobufTranslation v;
oadd.org.apache.calcite.avatica.remote.RemoteProtobufService v;
v := @this: oadd.org.apache.calcite.avatica.remote.RemoteProtobufService;
v := @parameter: oadd.org.apache.calcite.avatica.remote.AvaticaHttpClient;
v := @parameter: oadd.org.apache.calcite.avatica.remote.ProtobufTranslation;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufService: void <init>()>();
v.<oadd.org.apache.calcite.avatica.remote.RemoteProtobufService: oadd.org.apache.calcite.avatica.remote.AvaticaHttpClient client> = v;
v.<oadd.org.apache.calcite.avatica.remote.RemoteProtobufService: oadd.org.apache.calcite.avatica.remote.ProtobufTranslation translation> = v;
return;
}
public oadd.org.apache.calcite.avatica.remote.Service$Response _apply(oadd.org.apache.calcite.avatica.remote.Service$Request)
{
byte[] v, v;
oadd.org.apache.calcite.avatica.remote.AvaticaHttpClient v;
oadd.org.apache.calcite.avatica.AvaticaClientRuntimeException v;
java.lang.String v;
boolean v;
oadd.org.apache.calcite.avatica.remote.Service$Request v;
org.slf4j.Logger v, v;
oadd.org.apache.calcite.avatica.remote.RemoteProtobufService v;
java.io.IOException v, v;
java.lang.RuntimeException v, v;
oadd.org.apache.calcite.avatica.remote.ProtobufTranslation v, v;
oadd.org.apache.calcite.avatica.remote.Service$Response v;
v := @this: oadd.org.apache.calcite.avatica.remote.RemoteProtobufService;
v := @parameter: oadd.org.apache.calcite.avatica.remote.Service$Request;
label:
v = v.<oadd.org.apache.calcite.avatica.remote.RemoteProtobufService: oadd.org.apache.calcite.avatica.remote.AvaticaHttpClient client>;
v = v.<oadd.org.apache.calcite.avatica.remote.RemoteProtobufService: oadd.org.apache.calcite.avatica.remote.ProtobufTranslation translation>;
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslation: byte[] serializeRequest(oadd.org.apache.calcite.avatica.remote.Service$Request)>(v);
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.remote.AvaticaHttpClient: byte[] send(byte[])>(v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.calcite.avatica.remote.RemoteProtobufService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Failed to execute remote request: {}", v);
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = v.<oadd.org.apache.calcite.avatica.remote.RemoteProtobufService: oadd.org.apache.calcite.avatica.remote.ProtobufTranslation translation>;
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslation: oadd.org.apache.calcite.avatica.remote.Service$Response parseResponse(byte[])>(v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.calcite.avatica.remote.RemoteProtobufService: org.slf4j.Logger LOG>;
v = staticinvoke <oadd.org.apache.calcite.avatica.AvaticaUtils: java.lang.String newStringUtf8(byte[])>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to deserialize reponse to {}. \'{}\'", v, v);
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = v instanceof oadd.org.apache.calcite.avatica.remote.Service$ErrorResponse;
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ErrorResponse: oadd.org.apache.calcite.avatica.AvaticaClientRuntimeException toException()>();
throw v;
label:
return v;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/calcite/avatica/remote/RemoteProtobufService;");
<oadd.org.apache.calcite.avatica.remote.RemoteProtobufService: org.slf4j.Logger LOG> = v;
return;
}
}