final class org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter extends java.lang.Object implements org.apache.mina.filter.codec.ProtocolCodecFactory
{
private final org.apache.mina.filter.codec.ProtocolEncoder encoder;
private final org.apache.mina.filter.codec.ProtocolDecoder decoder;
private final org.apache.dubbo.remoting.Codec codec;
private final org.apache.dubbo.common.URL url;
private final org.apache.dubbo.remoting.ChannelHandler handler;
private final int bufferSize;
public void <init>(org.apache.dubbo.remoting.Codec, org.apache.dubbo.common.URL, org.apache.dubbo.remoting.ChannelHandler)
{
org.apache.dubbo.remoting.ChannelHandler v;
org.apache.dubbo.remoting.Codec v;
org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder v;
org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter v;
org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalDecoder v;
org.apache.dubbo.common.URL v;
int v, v;
v := @this: org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter;
v := @parameter: org.apache.dubbo.remoting.Codec;
v := @parameter: org.apache.dubbo.common.URL;
v := @parameter: org.apache.dubbo.remoting.ChannelHandler;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder;
specialinvoke v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalEncoder: void <init>(org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter)>(v);
v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter: org.apache.mina.filter.codec.ProtocolEncoder encoder> = v;
v = new org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalDecoder;
specialinvoke v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter$InternalDecoder: void <init>(org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter)>(v);
v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter: org.apache.mina.filter.codec.ProtocolDecoder decoder> = v;
v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter: org.apache.dubbo.remoting.Codec codec> = v;
v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter: org.apache.dubbo.common.URL url> = v;
v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter: org.apache.dubbo.remoting.ChannelHandler handler> = v;
v = virtualinvoke v.<org.apache.dubbo.common.URL: int getPositiveParameter(java.lang.String,int)>("buffer", 8192);
if v < 1024 goto label;
if v > 16384 goto label;
v = v;
goto label;
label:
v = 8192;
label:
v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter: int bufferSize> = v;
return;
}
public org.apache.mina.filter.codec.ProtocolEncoder getEncoder()
{
org.apache.mina.filter.codec.ProtocolEncoder v;
org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter v;
v := @this: org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter;
v = v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter: org.apache.mina.filter.codec.ProtocolEncoder encoder>;
return v;
}
public org.apache.mina.filter.codec.ProtocolDecoder getDecoder()
{
org.apache.mina.filter.codec.ProtocolDecoder v;
org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter v;
v := @this: org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter;
v = v.<org.apache.dubbo.remoting.transport.mina.MinaCodecAdapter: org.apache.mina.filter.codec.ProtocolDecoder decoder>;
return v;
}
}