class oadd.org.apache.hadoop.security.SaslRpcClient$WrappedOutputStream extends java.io.FilterOutputStream
{
final oadd.org.apache.hadoop.security.SaslRpcClient this$0;
public void <init>(oadd.org.apache.hadoop.security.SaslRpcClient, java.io.OutputStream) throws java.io.IOException
{
java.io.OutputStream v;
oadd.org.apache.hadoop.security.SaslRpcClient v;
oadd.org.apache.hadoop.security.SaslRpcClient$WrappedOutputStream v;
v := @this: oadd.org.apache.hadoop.security.SaslRpcClient$WrappedOutputStream;
v := @parameter: oadd.org.apache.hadoop.security.SaslRpcClient;
v := @parameter: java.io.OutputStream;
v.<oadd.org.apache.hadoop.security.SaslRpcClient$WrappedOutputStream: oadd.org.apache.hadoop.security.SaslRpcClient this$0> = v;
specialinvoke v.<java.io.FilterOutputStream: void <init>(java.io.OutputStream)>(v);
return;
}
public void write(byte[], int, int) throws java.io.IOException
{
byte[] v, v;
javax.security.sasl.SaslClient v;
oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto$Builder v, v, v;
int v, v, v;
java.lang.String v;
boolean v;
java.io.OutputStream v;
oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto v;
org.slf4j.Logger v, v;
oadd.org.apache.hadoop.security.SaslRpcClient$WrappedOutputStream v;
oadd.org.apache.hadoop.security.SaslRpcClient v, v;
oadd.com.google.protobuf.ByteString v;
oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto$SaslState v;
v := @this: oadd.org.apache.hadoop.security.SaslRpcClient$WrappedOutputStream;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = <oadd.org.apache.hadoop.security.SaslRpcClient: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.hadoop.security.SaslRpcClient: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("wrapping token of length:\u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
v = v.<oadd.org.apache.hadoop.security.SaslRpcClient$WrappedOutputStream: oadd.org.apache.hadoop.security.SaslRpcClient this$0>;
v = v.<oadd.org.apache.hadoop.security.SaslRpcClient: javax.security.sasl.SaslClient saslClient>;
v = interfaceinvoke v.<javax.security.sasl.SaslClient: byte[] wrap(byte[],int,int)>(v, v, v);
v = staticinvoke <oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto: oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto$Builder newBuilder()>();
v = <oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto$SaslState: oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto$SaslState WRAP>;
v = virtualinvoke v.<oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto$Builder: oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto$Builder setState(oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto$SaslState)>(v);
v = lengthof v;
v = staticinvoke <oadd.com.google.protobuf.ByteString: oadd.com.google.protobuf.ByteString copyFrom(byte[],int,int)>(v, 0, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto$Builder: oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto$Builder setToken(oadd.com.google.protobuf.ByteString)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto$Builder: oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto build()>();
v = v.<oadd.org.apache.hadoop.security.SaslRpcClient$WrappedOutputStream: oadd.org.apache.hadoop.security.SaslRpcClient this$0>;
v = v.<oadd.org.apache.hadoop.security.SaslRpcClient$WrappedOutputStream: java.io.OutputStream out>;
specialinvoke v.<oadd.org.apache.hadoop.security.SaslRpcClient: void sendSaslMessage(java.io.OutputStream,oadd.org.apache.hadoop.ipc.protobuf.RpcHeaderProtos$RpcSaslProto)>(v, v);
return;
}
}