class org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder extends java.lang.Object implements org.apache.mina.filter.codec.ProtocolEncoder
{
final org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter this$0;
private void <init>(org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter)
{
org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder v;
org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter v;
v := @this: org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder;
v := @parameter: org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter;
v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder: org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void dispose(org.apache.mina.common.IoSession) throws java.lang.Exception
{
org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder v;
org.apache.mina.common.IoSession v;
v := @this: org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder;
v := @parameter: org.apache.mina.common.IoSession;
return;
}
public void encode(org.apache.mina.common.IoSession, java.lang.Object, org.apache.mina.filter.codec.ProtocolEncoderOutput) throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.dubbo.remoting.ChannelHandler v;
org.apache.dubbo.remoting.Codec v;
org.apache.mina.common.ByteBuffer v;
org.apache.dubbo.remoting.buffer.ChannelBuffer v;
org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder v;
org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter v, v, v;
java.nio.ByteBuffer v;
org.apache.mina.filter.codec.ProtocolEncoderOutput v;
org.apache.dubbo.common.URL v;
java.lang.Object v;
org.apache.mina.common.IoSession v;
org.apache.dubbo.remoting.transport.mina.MinaChannel v;
v := @this: org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder;
v := @parameter: org.apache.mina.common.IoSession;
v := @parameter: java.lang.Object;
v := @parameter: org.apache.mina.filter.codec.ProtocolEncoderOutput;
v = staticinvoke <org.apache.dubbo.remoting.buffer.ChannelBuffers: org.apache.dubbo.remoting.buffer.ChannelBuffer dynamicBuffer(int)>(1024);
v = v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder: org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter this$0>;
v = v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter: org.apache.dubbo.common.URL url>;
v = v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder: org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter this$0>;
v = v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter: org.apache.dubbo.remoting.ChannelHandler handler>;
v = staticinvoke <org.apache.dubbo.remoting.transport.mina.MinaChannel: org.apache.dubbo.remoting.transport.mina.MinaChannel getOrAddChannel(org.apache.mina.common.IoSession,org.apache.dubbo.common.URL,org.apache.dubbo.remoting.ChannelHandler)>(v, v, v);
label:
v = v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder: org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter this$0>;
v = v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter: org.apache.dubbo.remoting.Codec codec>;
interfaceinvoke v.<org.apache.dubbo.remoting.Codec2: void encode(org.apache.dubbo.remoting.Channel,org.apache.dubbo.remoting.buffer.ChannelBuffer,java.lang.Object)>(v, v, v);
label:
staticinvoke <org.apache.dubbo.remoting.transport.mina.MinaChannel: void removeChannelIfDisconnected(org.apache.mina.common.IoSession)>(v);
goto label;
label:
v := @caughtexception;
staticinvoke <org.apache.dubbo.remoting.transport.mina.MinaChannel: void removeChannelIfDisconnected(org.apache.mina.common.IoSession)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.dubbo.remoting.buffer.ChannelBuffer: java.nio.ByteBuffer toByteBuffer()>();
v = staticinvoke <org.apache.mina.common.ByteBuffer: org.apache.mina.common.ByteBuffer wrap(java.nio.ByteBuffer)>(v);
interfaceinvoke v.<org.apache.mina.filter.codec.ProtocolEncoderOutput: void write(org.apache.mina.common.ByteBuffer)>(v);
interfaceinvoke v.<org.apache.mina.filter.codec.ProtocolEncoderOutput: org.apache.mina.common.WriteFuture flush()>();
return;
catch java.lang.Throwable from label to label with label;
}
}