public class org.finos.legend.engine.postgres.Messages extends java.lang.Object
{
private static final org.slf4j.Logger LOGGER;
private static final byte[] METHOD_NAME_CLIENT_AUTH;
private final org.finos.legend.engine.postgres.utils.ErrorMessageFormatter errorMessageFormatter;
public void <init>(org.finos.legend.engine.postgres.utils.ErrorMessageFormatter)
{
org.finos.legend.engine.postgres.utils.ErrorMessageFormatter v;
org.finos.legend.engine.postgres.Messages v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: org.finos.legend.engine.postgres.utils.ErrorMessageFormatter;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.finos.legend.engine.postgres.Messages: org.finos.legend.engine.postgres.utils.ErrorMessageFormatter errorMessageFormatter> = v;
return;
}
public io.netty.channel.ChannelFuture sendAuthenticationOK(io.netty.channel.Channel)
{
org.slf4j.Logger v;
io.netty.buffer.ByteBufAllocator v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
io.netty.channel.ChannelFutureListener v;
boolean v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer(int)>(9);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(82);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(8);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(0);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
v = <org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendAuthenticationOK_0__34: io.netty.channel.ChannelFutureListener bootstrap$()>();
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
label:
return v;
}
io.netty.channel.ChannelFuture sendCommandComplete(io.netty.channel.Channel, java.lang.String, long)
{
byte[] v;
io.netty.buffer.ByteBufAllocator v;
java.lang.String[] v;
long v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
java.nio.charset.Charset v;
java.util.Locale v;
io.netty.channel.ChannelFutureListener v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
boolean v, v, v;
org.slf4j.Logger v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v := @parameter: java.lang.String;
v := @parameter: long;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String,int)>(" ", 2);
v = v[0];
v = <java.util.Locale: java.util.Locale ENGLISH>;
v = virtualinvoke v.<java.lang.String: java.lang.String toUpperCase(java.util.Locale)>(v);
v = "BEGIN";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = "BEGIN";
goto label;
label:
v = "INSERT";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("INSERT 0 \u0001");
goto label;
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,long)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u \u0001");
label:
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
v = 4 + v;
v = v + 1;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = v + 1;
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer(int)>(v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(67);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(v);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture write(java.lang.Object)>(v);
v = <org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendCommandComplete_1__35: io.netty.channel.ChannelFutureListener bootstrap$()>();
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
label:
return v;
}
io.netty.channel.ChannelFuture sendReadyForQuery(io.netty.channel.Channel)
{
org.slf4j.Logger v;
io.netty.buffer.ByteBufAllocator v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
io.netty.channel.ChannelFutureListener v;
boolean v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer(int)>(6);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(90);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(5);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(73);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
v = <org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendReadyForQuery_2__36: io.netty.channel.ChannelFutureListener bootstrap$()>();
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
label:
return v;
}
void sendParameterStatus(io.netty.channel.Channel, java.lang.String, java.lang.String)
{
byte[] v, v;
io.netty.buffer.ByteBufAllocator v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
java.nio.charset.Charset v, v;
io.netty.channel.ChannelFutureListener v;
int v, v, v, v, v, v, v;
java.lang.String v, v;
boolean v;
org.slf4j.Logger v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
v = 4 + v;
v = v + 1;
v = lengthof v;
v = v + v;
v = v + 1;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = v + 1;
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer(int)>(v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(83);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(v);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture write(java.lang.Object)>(v);
v = <org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendParameterStatus_3__37: io.netty.channel.ChannelFutureListener bootstrap$(java.lang.String,java.lang.String)>(v, v);
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
label:
return;
}
void sendAuthenticationError(io.netty.channel.Channel, java.lang.String)
{
byte[] v, v, v, v;
org.slf4j.Logger v;
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
org.finos.legend.engine.postgres.PGErrorStatus v;
java.nio.charset.Charset v, v;
java.lang.String v, v, v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v := @parameter: java.lang.String;
v = <org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
if v == null goto label;
v = v;
goto label;
label:
v = "Unknown Auth Error";
label:
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = <org.finos.legend.engine.postgres.PGErrorStatus: org.finos.legend.engine.postgres.PGErrorStatus INVALID_AUTHORIZATION_SPECIFICATION>;
v = virtualinvoke v.<org.finos.legend.engine.postgres.PGErrorStatus: java.lang.String code()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = <org.finos.legend.engine.postgres.PGError: byte[] SEVERITY_FATAL>;
v = <org.finos.legend.engine.postgres.Messages: byte[] METHOD_NAME_CLIENT_AUTH>;
specialinvoke v.<org.finos.legend.engine.postgres.Messages: io.netty.channel.ChannelFuture sendErrorResponse(io.netty.channel.Channel,java.lang.String,byte[],byte[],byte[],byte[],byte[],byte[])>(v, v, v, v, null, null, v, v);
return;
}
private java.lang.String buildErrorMessage(java.lang.Throwable)
{
java.lang.Throwable v;
io.opentelemetry.context.Context v;
java.util.Set v;
java.util.HashMap v;
java.util.function.Consumer v;
io.opentelemetry.context.propagation.TextMapPropagator v;
java.util.stream.Stream v;
org.finos.legend.engine.postgres.Messages v;
io.opentelemetry.context.propagation.TextMapSetter v;
java.lang.StringBuilder v;
java.lang.String v, v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: java.lang.Throwable;
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_buildErrorMessage_4__38: io.opentelemetry.context.propagation.TextMapSetter bootstrap$()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = staticinvoke <org.finos.legend.engine.postgres.utils.OpenTelemetryUtil: io.opentelemetry.context.propagation.TextMapPropagator getPropagators()>();
v = staticinvoke <io.opentelemetry.context.Context: io.opentelemetry.context.Context current()>();
interfaceinvoke v.<io.opentelemetry.context.propagation.TextMapPropagator: void inject(io.opentelemetry.context.Context,java.lang.Object,io.opentelemetry.context.propagation.TextMapSetter)>(v, v, v);
v = new java.lang.StringBuilder;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
specialinvoke v.<java.lang.StringBuilder: void <init>(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_buildErrorMessage_5__39: java.util.function.Consumer bootstrap$(java.lang.StringBuilder)>(v);
interfaceinvoke v.<java.util.stream.Stream: void forEach(java.util.function.Consumer)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
io.netty.channel.ChannelFuture sendErrorResponse(io.netty.channel.Channel, java.lang.Throwable)
{
byte[] v, v, v, v, v, v, v;
io.netty.buffer.ByteBufAllocator v;
java.lang.StackTraceElement[] v;
java.lang.StringBuilder v;
java.lang.Throwable v, v;
org.finos.legend.engine.postgres.PostgresServerException v;
org.finos.legend.engine.postgres.PGError v;
org.finos.legend.engine.postgres.Messages v;
org.finos.legend.engine.postgres.PGErrorStatus v, v;
io.netty.buffer.ByteBuf v;
java.nio.charset.Charset v, v, v, v, v, v;
int v, v, v, v, v, v, v;
java.lang.StackTraceElement v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v;
org.finos.legend.engine.postgres.utils.ErrorMessageFormatter v;
io.netty.util.concurrent.GenericFutureListener v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v := @parameter: java.lang.Throwable;
v = staticinvoke <org.finos.legend.engine.postgres.PostgresServerException: org.finos.legend.engine.postgres.PostgresServerException wrapException(java.lang.Throwable)>(v);
v = v.<org.finos.legend.engine.postgres.Messages: org.finos.legend.engine.postgres.utils.ErrorMessageFormatter errorMessageFormatter>;
v = interfaceinvoke v.<org.finos.legend.engine.postgres.utils.ErrorMessageFormatter: java.lang.String format(java.lang.Throwable)>(v);
v = <org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
v = new org.finos.legend.engine.postgres.PGError;
v = <org.finos.legend.engine.postgres.PGErrorStatus: org.finos.legend.engine.postgres.PGErrorStatus INTERNAL_ERROR>;
specialinvoke v.<org.finos.legend.engine.postgres.PGError: void <init>(org.finos.legend.engine.postgres.PGErrorStatus,java.lang.String,java.lang.Throwable)>(v, v, v);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer()>();
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(69);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(0);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(83);
v = <org.finos.legend.engine.postgres.PGError: byte[] SEVERITY_ERROR>;
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(77);
v = virtualinvoke v.<org.finos.legend.engine.postgres.PGError: java.lang.String message()>();
if v != null goto label;
v = "Unknown Error";
goto label;
label:
v = virtualinvoke v.<org.finos.legend.engine.postgres.PGError: java.lang.String message()>();
label:
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(67);
v = virtualinvoke v.<org.finos.legend.engine.postgres.PGError: org.finos.legend.engine.postgres.PGErrorStatus status()>();
v = virtualinvoke v.<org.finos.legend.engine.postgres.PGErrorStatus: java.lang.String code()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.postgres.PGError: java.lang.Throwable throwable()>();
v = virtualinvoke v.<java.lang.Throwable: java.lang.StackTraceElement[] getStackTrace()>();
v = lengthof v;
if v <= 0 goto label;
v = v[0];
v = virtualinvoke v.<java.lang.StackTraceElement: java.lang.String getFileName()>();
if v == null goto label;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(70);
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
label:
v = virtualinvoke v.<java.lang.StackTraceElement: java.lang.String getMethodName()>();
if v == null goto label;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(82);
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
label:
v = virtualinvoke v.<java.lang.StackTraceElement: int getLineNumber()>();
if v < 0 goto label;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(76);
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
label:
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(87);
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = lengthof v;
v = staticinvoke <java.lang.Math: int min(int,int)>(v, 20);
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.lang.StackTraceElement: java.lang.String toString()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n");
v = v + 1;
goto label;
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
label:
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(0);
v = virtualinvoke v.<io.netty.buffer.ByteBuf: int writerIndex()>();
v = v - 1;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf setInt(int,int)>(1, v);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendErrorResponse_6__40: io.netty.util.concurrent.GenericFutureListener bootstrap$(org.finos.legend.engine.postgres.PGError)>(v);
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
return v;
}
private io.netty.channel.ChannelFuture sendErrorResponse(io.netty.channel.Channel, java.lang.String, byte[], byte[], byte[], byte[], byte[], byte[])
{
byte[] v, v, v, v, v, v;
io.netty.buffer.ByteBufAllocator v;
boolean v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
io.netty.channel.ChannelFutureListener v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v;
org.slf4j.Logger v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v := @parameter: byte[];
v := @parameter: byte[];
v := @parameter: byte[];
v := @parameter: byte[];
v := @parameter: byte[];
v = lengthof v;
v = v + 1;
v = 5 + v;
v = v + 1;
v = lengthof v;
v = v + 1;
v = v + v;
v = v + 1;
v = lengthof v;
v = v + 1;
v = v + v;
if v == null goto label;
v = lengthof v;
v = v + 1;
v = 1 + v;
goto label;
label:
v = 0;
label:
v = v + v;
if v == null goto label;
v = lengthof v;
v = v + 1;
v = 1 + v;
goto label;
label:
v = 0;
label:
v = v + v;
if v == null goto label;
v = lengthof v;
v = v + 1;
v = 1 + v;
goto label;
label:
v = 0;
label:
v = v + v;
v = v + 1;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = v + 1;
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer(int)>(v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(69);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(83);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(77);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(67);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
if v == null goto label;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(70);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
label:
if v == null goto label;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(76);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
label:
if v == null goto label;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(82);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
label:
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(0);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
v = <org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendErrorResponse_7__41: io.netty.channel.ChannelFutureListener bootstrap$(java.lang.String)>(v);
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
label:
return v;
}
void sendDataRow(io.netty.channel.Channel, org.finos.legend.engine.postgres.handler.PostgresResultSet, java.util.List, org.finos.legend.engine.postgres.FormatCodes$FormatCode[]) throws java.lang.Exception
{
io.netty.buffer.ByteBufAllocator v;
org.finos.legend.engine.postgres.FormatCodes$FormatCode[] v;
org.finos.legend.engine.postgres.PostgresServerException v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
org.eclipse.collections.api.block.function.Function v;
int[] v;
int v, v, v, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.postgres.handler.PostgresResultSetMetaData v;
java.lang.String v;
boolean v;
org.finos.legend.engine.postgres.handler.PostgresResultSet v;
java.lang.Exception v;
io.netty.channel.Channel v;
java.util.List v;
org.finos.legend.engine.postgres.FormatCodes$FormatCode v;
java.lang.Object v, v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v := @parameter: org.finos.legend.engine.postgres.handler.PostgresResultSet;
v := @parameter: java.util.List;
v := @parameter: org.finos.legend.engine.postgres.FormatCodes$FormatCode[];
v = 6;
v = interfaceinvoke v.<java.util.List: int size()>();
v = interfaceinvoke v.<org.finos.legend.engine.postgres.handler.PostgresResultSet: org.finos.legend.engine.postgres.handler.PostgresResultSetMetaData getMetaData()>();
v = interfaceinvoke v.<org.finos.legend.engine.postgres.handler.PostgresResultSetMetaData: int getColumnCount()>();
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendDataRow_72739a69_1__42: org.eclipse.collections.api.block.function.Function bootstrap$(org.finos.legend.engine.postgres.handler.PostgresResultSet,java.util.List)>(v, v);
staticinvoke <org.finos.legend.engine.shared.core.operational.Assert: void assertTrue(boolean,org.eclipse.collections.api.block.function.Function)>(v, v);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer()>();
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(68);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(0);
v = interfaceinvoke v.<java.util.List: int size()>();
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeShort(int)>(v);
v = 0;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
label:
v = v + 1;
v = interfaceinvoke v.<org.finos.legend.engine.postgres.handler.PostgresResultSet: java.lang.Object getObject(int)>(v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<io.netty.buffer.ByteBuf: boolean release()>();
throw v;
label:
if v != null goto label;
v = (int) -1;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(v);
v = v + 4;
goto label;
label:
v = staticinvoke <org.finos.legend.engine.postgres.FormatCodes: org.finos.legend.engine.postgres.FormatCodes$FormatCode getFormatCode(org.finos.legend.engine.postgres.FormatCodes$FormatCode[],int)>(v, v);
v = <org.finos.legend.engine.postgres.Messages$1: int[] $SwitchMap$org$finos$legend$engine$postgres$FormatCodes$FormatCode>;
v = virtualinvoke v.<org.finos.legend.engine.postgres.FormatCodes$FormatCode: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<org.finos.legend.engine.postgres.types.PGType: int writeAsText(io.netty.buffer.ByteBuf,java.lang.Object)>(v, v);
v = v + v;
goto label;
label:
v = virtualinvoke v.<org.finos.legend.engine.postgres.types.PGType: int writeAsBinary(io.netty.buffer.ByteBuf,java.lang.Object)>(v, v);
v = v + v;
goto label;
label:
virtualinvoke v.<io.netty.buffer.ByteBuf: boolean release()>();
v = new org.finos.legend.engine.postgres.PostgresServerException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.finos.legend.engine.postgres.FormatCodes$FormatCode)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unrecognized formatCode: \u0001");
specialinvoke v.<org.finos.legend.engine.postgres.PostgresServerException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v + 1;
goto label;
label:
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf setInt(int,int)>(1, v);
interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
return;
catch java.lang.Exception from label to label with label;
}
void writeCString(io.netty.buffer.ByteBuf, byte[])
{
byte[] v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.buffer.ByteBuf;
v := @parameter: byte[];
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeBytes(byte[])>(v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(0);
return;
}
void writeByteArray(io.netty.buffer.ByteBuf, byte[])
{
byte[] v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.buffer.ByteBuf;
v := @parameter: byte[];
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeBytes(byte[])>(v);
return;
}
void sendParameterDescription(io.netty.channel.Channel, java.sql.ParameterMetaData) throws java.sql.SQLException
{
io.netty.buffer.ByteBufAllocator v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
java.sql.ParameterMetaData v;
int v, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.postgres.types.PGType v;
java.lang.IllegalArgumentException v;
io.netty.channel.Channel v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v := @parameter: java.sql.ParameterMetaData;
v = interfaceinvoke v.<java.sql.ParameterMetaData: int getParameterCount()>();
v = v * 4;
v = 6 + v;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer(int)>(v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(116);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(v);
v = interfaceinvoke v.<java.sql.ParameterMetaData: int getParameterCount()>();
if v <= 32767 goto label;
virtualinvoke v.<io.netty.buffer.ByteBuf: boolean release()>();
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Too many parameters. Max supported: 32767");
throw v;
label:
v = interfaceinvoke v.<java.sql.ParameterMetaData: int getParameterCount()>();
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeShort(int)>(v);
v = 0;
label:
v = interfaceinvoke v.<java.sql.ParameterMetaData: int getParameterCount()>();
if v >= v goto label;
v = interfaceinvoke v.<java.sql.ParameterMetaData: int getParameterType(int)>(v);
v = interfaceinvoke v.<java.sql.ParameterMetaData: int getScale(int)>(v);
v = staticinvoke <org.finos.legend.engine.postgres.types.PGTypes: org.finos.legend.engine.postgres.types.PGType get(int,int)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.postgres.types.PGType: int oid()>();
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(v);
v = v + 1;
goto label;
label:
interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture write(java.lang.Object)>(v);
return;
}
void sendRowDescription(io.netty.channel.Channel, org.finos.legend.engine.postgres.handler.PostgresResultSetMetaData, org.finos.legend.engine.postgres.FormatCodes$FormatCode[]) throws java.lang.Exception
{
byte[] v;
io.netty.buffer.ByteBufAllocator v;
org.finos.legend.engine.postgres.FormatCodes$FormatCode[] v;
boolean v;
org.finos.legend.engine.postgres.types.PGType v;
short v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
java.nio.charset.Charset v;
io.netty.channel.ChannelFutureListener v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.postgres.handler.PostgresResultSetMetaData v;
java.lang.String v;
org.slf4j.Logger v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.FormatCodes$FormatCode v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v := @parameter: org.finos.legend.engine.postgres.handler.PostgresResultSetMetaData;
v := @parameter: org.finos.legend.engine.postgres.FormatCodes$FormatCode[];
v = 6;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<org.finos.legend.engine.postgres.handler.PostgresResultSetMetaData: int getColumnCount()>();
v = v * 28;
v = 6 + v;
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer(int)>(v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(84);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(0);
v = interfaceinvoke v.<org.finos.legend.engine.postgres.handler.PostgresResultSetMetaData: int getColumnCount()>();
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeShort(int)>(v);
v = 0;
label:
v = interfaceinvoke v.<org.finos.legend.engine.postgres.handler.PostgresResultSetMetaData: int getColumnCount()>();
if v >= v goto label;
v = v + 1;
v = interfaceinvoke v.<org.finos.legend.engine.postgres.handler.PostgresResultSetMetaData: java.lang.String getColumnName(int)>(v);
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = lengthof v;
v = v + 1;
v = v + v;
v = v + 18;
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeCString(io.netty.buffer.ByteBuf,byte[])>(v, v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(0);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeShort(int)>(v);
v = v + 1;
v = interfaceinvoke v.<org.finos.legend.engine.postgres.handler.PostgresResultSetMetaData: int getColumnType(int)>(v);
v = v + 1;
v = interfaceinvoke v.<org.finos.legend.engine.postgres.handler.PostgresResultSetMetaData: int getScale(int)>(v);
v = staticinvoke <org.finos.legend.engine.postgres.types.PGTypes: org.finos.legend.engine.postgres.types.PGType get(int,int)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.postgres.types.PGType: int oid()>();
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(v);
v = virtualinvoke v.<org.finos.legend.engine.postgres.types.PGType: short typeLen()>();
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeShort(int)>(v);
v = virtualinvoke v.<org.finos.legend.engine.postgres.types.PGType: int typeMod()>();
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(v);
v = staticinvoke <org.finos.legend.engine.postgres.FormatCodes: org.finos.legend.engine.postgres.FormatCodes$FormatCode getFormatCode(org.finos.legend.engine.postgres.FormatCodes$FormatCode[],int)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.postgres.FormatCodes$FormatCode: int ordinal()>();
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeShort(int)>(v);
v = v + 1;
goto label;
label:
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf setInt(int,int)>(1, v);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture write(java.lang.Object)>(v);
v = <org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendRowDescription_8__43: io.netty.channel.ChannelFutureListener bootstrap$()>();
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
label:
return;
}
void sendParseComplete(io.netty.channel.Channel)
{
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
specialinvoke v.<org.finos.legend.engine.postgres.Messages: void sendShortMsg(io.netty.channel.Channel,char,java.lang.String)>(v, 49, "sentParseComplete");
return;
}
void sendGssOutToken(io.netty.channel.Channel, byte[])
{
byte[] v;
io.netty.buffer.ByteBufAllocator v;
io.netty.util.concurrent.GenericFutureListener v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
int v, v, v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v := @parameter: byte[];
v = lengthof v;
v = v + 8;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = v + 1;
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer(int)>(v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(82);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(8);
virtualinvoke v.<org.finos.legend.engine.postgres.Messages: void writeByteArray(io.netty.buffer.ByteBuf,byte[])>(v, v);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendGssOutToken_9__44: io.netty.util.concurrent.GenericFutureListener bootstrap$()>();
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
return;
}
void sendBindComplete(io.netty.channel.Channel)
{
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
specialinvoke v.<org.finos.legend.engine.postgres.Messages: void sendShortMsg(io.netty.channel.Channel,char,java.lang.String)>(v, 50, "sentBindComplete");
return;
}
void sendEmptyQueryResponse(io.netty.channel.Channel)
{
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
specialinvoke v.<org.finos.legend.engine.postgres.Messages: void sendShortMsg(io.netty.channel.Channel,char,java.lang.String)>(v, 73, "sentEmptyQueryResponse");
return;
}
void sendNoData(io.netty.channel.Channel)
{
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
specialinvoke v.<org.finos.legend.engine.postgres.Messages: void sendShortMsg(io.netty.channel.Channel,char,java.lang.String)>(v, 110, "sentNoData");
return;
}
private void sendShortMsg(io.netty.channel.Channel, char, java.lang.String)
{
org.slf4j.Logger v;
io.netty.buffer.ByteBufAllocator v;
char v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
io.netty.channel.ChannelFutureListener v;
java.lang.String v;
boolean v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v := @parameter: char;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer(int)>(5);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(4);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture write(java.lang.Object)>(v);
v = <org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendShortMsg_10__45: io.netty.channel.ChannelFutureListener bootstrap$(java.lang.String)>(v);
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
label:
return;
}
void sendPortalSuspended(io.netty.channel.Channel)
{
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
specialinvoke v.<org.finos.legend.engine.postgres.Messages: void sendShortMsg(io.netty.channel.Channel,char,java.lang.String)>(v, 115, "sentPortalSuspended");
return;
}
void sendCloseComplete(io.netty.channel.Channel)
{
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
specialinvoke v.<org.finos.legend.engine.postgres.Messages: void sendShortMsg(io.netty.channel.Channel,char,java.lang.String)>(v, 51, "sentCloseComplete");
return;
}
void sendAuthenticationCleartextPassword(io.netty.channel.Channel)
{
org.slf4j.Logger v;
io.netty.buffer.ByteBufAllocator v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
io.netty.channel.ChannelFutureListener v;
boolean v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer(int)>(9);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(82);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(8);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(3);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
v = <org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendAuthenticationCleartextPassword_11__46: io.netty.channel.ChannelFutureListener bootstrap$()>();
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
label:
return;
}
void sendAuthenticationKerberos(io.netty.channel.Channel)
{
org.slf4j.Logger v;
io.netty.buffer.ByteBufAllocator v;
io.netty.util.concurrent.GenericFutureListener v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
boolean v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer(int)>(9);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(82);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(8);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(7);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
v = <org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendAuthenticationKerberos_12__47: io.netty.util.concurrent.GenericFutureListener bootstrap$()>();
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
label:
return;
}
void sendKeyData(io.netty.channel.Channel, int, int)
{
org.slf4j.Logger v;
io.netty.buffer.ByteBufAllocator v;
io.netty.channel.ChannelFuture v;
io.netty.channel.Channel v;
org.finos.legend.engine.postgres.Messages v;
io.netty.buffer.ByteBuf v;
io.netty.channel.ChannelFutureListener v;
int v, v;
boolean v;
v := @this: org.finos.legend.engine.postgres.Messages;
v := @parameter: io.netty.channel.Channel;
v := @parameter: int;
v := @parameter: int;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBuf buffer(int)>(13);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeByte(int)>(75);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(12);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(v);
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf writeInt(int)>(v);
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
v = <org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.postgres.Messages$lambda_sendKeyData_13__48: io.netty.channel.ChannelFutureListener bootstrap$()>();
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
label:
return;
}
static void <clinit>()
{
byte[] v;
org.slf4j.Logger v;
java.nio.charset.Charset v;
java.lang.String v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/finos/legend/engine/postgres/Messages;");
<org.finos.legend.engine.postgres.Messages: org.slf4j.Logger LOGGER> = v;
v = "ClientAuthentication";
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
<org.finos.legend.engine.postgres.Messages: byte[] METHOD_NAME_CLIENT_AUTH> = v;
return;
}
}