public class org.glassfish.grizzly.http.io.InputBuffer extends java.lang.Object { private static final java.util.logging.Logger LOGGER; private static final java.util.logging.Level LOGGER_LEVEL; private org.glassfish.grizzly.http.HttpHeader httpHeader; private org.glassfish.grizzly.filterchain.FilterChainContext ctx; private boolean processingChars; private boolean closed; private org.glassfish.grizzly.Buffer inputContentBuffer; private org.glassfish.grizzly.Connection connection; private int markPos; private int readAheadLimit; private int readCount; private java.lang.String encoding; private java.nio.charset.CharsetDecoder decoder; private final java.util.Map decoders; private boolean contentRead; private org.glassfish.grizzly.ReadHandler handler; private int requestedSize; private final java.nio.CharBuffer singleCharBuf; private float averageCharsPerByte; private boolean isWaitingDataAsynchronously; protected java.util.Map trailers; public void () { java.nio.CharBuffer v, v; int v, v; java.util.HashMap v; java.lang.String v; org.glassfish.grizzly.http.io.InputBuffer v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; specialinvoke v.()>(); v = (int) -1; v. = v; v = (int) -1; v. = v; v. = 0; v = ; v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = staticinvoke (1); v = virtualinvoke v.(1); v. = v; v. = 1.0F; return; } public void initialize(org.glassfish.grizzly.http.HttpHeader, org.glassfish.grizzly.filterchain.FilterChainContext) { java.lang.Object[] v; org.glassfish.grizzly.Buffer v, v; java.lang.IllegalArgumentException v; java.util.logging.Logger v; java.util.logging.Level v; org.glassfish.grizzly.filterchain.FilterChainContext v; org.glassfish.grizzly.Connection v; java.lang.Object v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v, v, v; org.glassfish.grizzly.http.HttpHeader v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: org.glassfish.grizzly.http.HttpHeader; v := @parameter: org.glassfish.grizzly.filterchain.FilterChainContext; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("ctx cannot be null."); throw v; label: v. = v; v. = v; v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v = v instanceof org.glassfish.grizzly.http.HttpContent; if v == 0 goto label; staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; v = v.; if v == 0 goto label; specialinvoke v.(); label: virtualinvoke v.(); v = ; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = newarray (java.lang.Object)[2]; v[0] = v; v = v.; v[1] = v; staticinvoke ("InputBuffer %s initialize with ready content: %s", v); label: return; } public void setDefaultEncoding(java.lang.String) { java.lang.String v; org.glassfish.grizzly.http.io.InputBuffer v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: java.lang.String; v. = v; return; } public void recycle() { java.nio.CharBuffer v, v; org.glassfish.grizzly.Buffer v; int v, v, v, v; java.lang.String v; org.glassfish.grizzly.http.io.InputBuffer v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; interfaceinvoke v.(); v. = null; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v. = null; v. = null; v. = null; v. = null; v. = null; v. = 0; v. = 0; v. = 0; v = (int) -1; v. = v; v = (int) -1; v. = v; v = (int) -1; v. = v; v. = 0; v. = 1.0F; v. = 0; v = ; v. = v; return; } public void processingChars() { float v; java.lang.String v; java.nio.charset.CharsetDecoder v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v; org.glassfish.grizzly.http.HttpHeader v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; if v != 0 goto label; v. = 1; v = v.; v = virtualinvoke v.(); if v == null goto label; v. = v; v = specialinvoke v.(); v = virtualinvoke v.(); v. = v; label: return; } public int readByte() throws java.io.IOException { java.lang.Object[] v; java.util.logging.Level v; short v; byte v; int v, v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v, v; org.glassfish.grizzly.Buffer v, v, v; java.io.IOException v; java.util.logging.Logger v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = ; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = newarray (java.lang.Object)[2]; v[0] = v; v = v.; v[1] = v; staticinvoke ("InputBuffer %s readByte. Ready content: %s", v); label: v = v.; if v == 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Already closed"); throw v; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = specialinvoke v.(1); v = (int) -1; if v != v goto label; v = (int) -1; return v; label: specialinvoke v.(1L); v = v.; v = interfaceinvoke v.(); v = v & 255; return v; } public int read(byte[], int, int) throws java.io.IOException { byte[] v; java.lang.Object[] v; java.lang.Integer v; java.util.logging.Level v; int v, v, v, v, v, v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v, v, v; org.glassfish.grizzly.Buffer v, v, v, v, v; java.io.IOException v; java.util.logging.Logger v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: byte[]; v := @parameter: int; v := @parameter: int; v = ; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = newarray (java.lang.Object)[3]; v[0] = v; v = staticinvoke (v); v[1] = v; v = v.; v[2] = v; staticinvoke ("InputBuffer %s read byte array of len: %s. Ready content: %s", v); label: v = v.; if v == 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Already closed"); throw v; label: if v != 0 goto label; return 0; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = specialinvoke v.(1); v = (int) -1; if v != v goto label; v = (int) -1; return v; label: v = v.; v = interfaceinvoke v.(); v = staticinvoke (v, v); v = v.; interfaceinvoke v.(v, v, v); v = specialinvoke v.(v); if v != 0 goto label; v = v.; interfaceinvoke v.(); label: return v; } public int readyData() { int v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; if v == 0 goto label; return 0; label: v = v.; if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); label: return v; } public int available() { int v; org.glassfish.grizzly.Buffer v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; if v == 0 goto label; v = 0; goto label; label: v = v.; v = interfaceinvoke v.(); label: return v; } public org.glassfish.grizzly.Buffer getBuffer() { java.lang.Object[] v; org.glassfish.grizzly.Buffer v, v, v; java.util.logging.Logger v; java.util.logging.Level v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = ; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = newarray (java.lang.Object)[2]; v[0] = v; v = v.; v[1] = v; staticinvoke ("InputBuffer %s getBuffer. Ready content: %s", v); label: v = v.; v = interfaceinvoke v.(); return v; } public org.glassfish.grizzly.Buffer readBuffer() { java.lang.Object[] v; org.glassfish.grizzly.Buffer v, v, v; java.util.logging.Logger v; java.util.logging.Level v; int v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = ; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = newarray (java.lang.Object)[2]; v[0] = v; v = v.; v[1] = v; staticinvoke ("InputBuffer %s readBuffer. Ready content: %s", v); label: v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); return v; } public org.glassfish.grizzly.Buffer readBuffer(int) { java.lang.IllegalStateException v; java.lang.Object[] v; java.lang.Integer v; java.util.logging.Level v; int v, v, v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v; org.glassfish.grizzly.Buffer v, v, v, v, v, v, v; java.util.logging.Logger v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: int; v = ; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = newarray (java.lang.Object)[3]; v[0] = v; v = staticinvoke (v); v[1] = v; v = v.; v[2] = v; staticinvoke ("InputBuffer %s readBuffer(size), size: %s. Ready content: %s", v); label: v = v.; v = interfaceinvoke v.(); if v <= v goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Can not read more bytes than available"); throw v; label: if v != v goto label; v = v.; v = ; v. = v; goto label; label: v = v.; v = v.; v = interfaceinvoke v.(); v = v + v; v = interfaceinvoke v.(v); v = v.; v. = v; label: return v; } public org.glassfish.grizzly.ReadHandler getReadHandler() { org.glassfish.grizzly.http.io.InputBuffer v; org.glassfish.grizzly.ReadHandler v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; return v; } public int read(java.nio.CharBuffer) throws java.io.IOException { java.lang.IllegalStateException v; java.lang.Object[] v; java.nio.CharBuffer v; org.glassfish.grizzly.Buffer v; java.io.IOException v; java.lang.IllegalArgumentException v; java.util.logging.Logger v; java.util.logging.Level v; int v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v, v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: java.nio.CharBuffer; v = ; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = newarray (java.lang.Object)[2]; v[0] = v; v = v.; v[1] = v; staticinvoke ("InputBuffer %s read(CharBuffer). Ready content: %s", v); label: v = v.; if v == 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Already closed"); throw v; label: v = v.; if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.()>(); throw v; label: if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("target cannot be null."); throw v; label: v = specialinvoke v.(1, v); specialinvoke v.(v); return v; } public int readChar() throws java.io.IOException { java.lang.IllegalStateException v; java.lang.Object[] v; java.util.logging.Level v; int v, v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v, v, v; java.nio.CharBuffer v, v, v, v; org.glassfish.grizzly.Buffer v; char v; java.io.IOException v; java.util.logging.Logger v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = ; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = newarray (java.lang.Object)[2]; v[0] = v; v = v.; v[1] = v; staticinvoke ("InputBuffer %s readChar. Ready content: %s", v); label: v = v.; if v == 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Already closed"); throw v; label: v = v.; if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.()>(); throw v; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(v); v = (int) -1; if v != v goto label; v = (int) -1; return v; label: v = v.; v = virtualinvoke v.(); return v; } public int read(char[], int, int) throws java.io.IOException { java.lang.IllegalStateException v; java.lang.Object[] v; java.lang.Integer v; java.util.logging.Level v; int v, v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v, v; java.nio.CharBuffer v; org.glassfish.grizzly.Buffer v; java.io.IOException v; java.util.logging.Logger v; char[] v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: char[]; v := @parameter: int; v := @parameter: int; v = ; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = newarray (java.lang.Object)[3]; v[0] = v; v = staticinvoke (v); v[1] = v; v = v.; v[2] = v; staticinvoke ("InputBuffer %s read char array, len: %s. Ready content: %s", v); label: v = v.; if v == 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Already closed"); throw v; label: v = v.; if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.()>(); throw v; label: if v != 0 goto label; return 0; label: v = staticinvoke (v, v, v); v = virtualinvoke v.(v); return v; } public boolean ready() { java.lang.IllegalStateException v; org.glassfish.grizzly.Buffer v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v, v, v, v; org.glassfish.grizzly.http.HttpHeader v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; if v == 0 goto label; return 0; label: v = v.; if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.()>(); throw v; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } public void fillFully(int) throws java.io.IOException { java.lang.Object[] v; org.glassfish.grizzly.Buffer v, v; java.util.logging.Logger v; java.lang.Integer v; java.util.logging.Level v; int v, v, v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: int; v = ; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = newarray (java.lang.Object)[3]; v[0] = v; v = staticinvoke (v); v[1] = v; v = v.; v[2] = v; staticinvoke ("InputBuffer %s fillFully, len: %s. Ready content: %s", v); label: if v != 0 goto label; return; label: if v <= 0 goto label; v = v.; v = interfaceinvoke v.(); v = v - v; if v <= 0 goto label; specialinvoke v.(v); goto label; label: v = (int) -1; specialinvoke v.(v); label: return; } public int availableChar() { java.nio.CharBuffer v, v, v, v, v, v; org.glassfish.grizzly.Buffer v; int v, v, v, v; float v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(); v = v.; v = specialinvoke v.(1, v); if v != 0 goto label; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); return 0; label: v = v.; virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); v = v.; v = v * v; v = 1 + v; return v; } public void mark(int) { int v, v; org.glassfish.grizzly.Buffer v; org.glassfish.grizzly.http.io.InputBuffer v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: int; if v <= 0 goto label; v = v.; v = interfaceinvoke v.(); v. = v; v. = 0; v. = v; label: return; } public boolean markSupported() { java.lang.IllegalStateException v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.()>(); throw v; label: return 1; } public void reset() throws java.io.IOException { org.glassfish.grizzly.Buffer v; java.io.IOException v, v; int v, v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; if v == 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Already closed"); throw v; label: v = v.; v = (int) -1; if v != v goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Mark not set"); throw v; label: v. = 0; v = v.; v = v.; interfaceinvoke v.(v); return; } public void close() throws java.io.IOException { org.glassfish.grizzly.http.io.InputBuffer v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v. = 1; return; } public long skip(long, boolean) throws java.io.IOException { long v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: long; v := @parameter: boolean; v = virtualinvoke v.(v); return v; } public long skip(long) throws java.io.IOException { byte v, v, v, v; java.lang.Long v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v, v, v; java.nio.CharBuffer v; org.glassfish.grizzly.Buffer v, v, v, v, v, v, v; java.util.logging.Logger v; java.lang.Object[] v; long v, v, v; java.util.logging.Level v; int v, v, v, v, v, v, v, v, v; java.lang.IllegalArgumentException v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: long; v = ; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = newarray (java.lang.Object)[3]; v[0] = v; v = staticinvoke (v); v[1] = v; v = v.; v[2] = v; staticinvoke ("InputBuffer %s skip %s bytes. Ready content: %s", v); label: v = v.; if v != 0 goto label; v = v cmp 0L; if v > 0 goto label; return 0L; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = specialinvoke v.(v); v = (int) -1; if v != v goto label; return -1L; label: v = v.; v = interfaceinvoke v.(); v = v cmp v; if v >= 0 goto label; specialinvoke v.(v); label: v = v.; v = interfaceinvoke v.(); v = staticinvoke (v, v); v = v.; v = v.; v = interfaceinvoke v.(); v = v + v; interfaceinvoke v.(v); v = specialinvoke v.(v); if v != 0 goto label; v = v.; interfaceinvoke v.(); label: return v; label: v = v cmp 0L; if v >= 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.()>(); throw v; label: v = v cmp 0L; if v != 0 goto label; return 0L; label: v = staticinvoke (v); v = specialinvoke v.(v, v); v = (int) -1; if v != v goto label; return 0L; label: v = virtualinvoke v.(); v = staticinvoke (v, v); return v; } public java.util.Map getTrailers() { org.glassfish.grizzly.http.io.InputBuffer v; java.util.Map v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; return v; } public boolean areTrailersAvailable() { org.glassfish.grizzly.http.io.InputBuffer v; boolean v; java.util.Map v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; if v == null goto label; v = 1; goto label; label: v = 0; label: return v; } protected void finished() { java.util.concurrent.Executor v; org.glassfish.grizzly.ReadHandler v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; if v != 0 goto label; v. = 1; v = v.; specialinvoke v.(); if v == null goto label; v. = null; v = virtualinvoke v.(); specialinvoke v.(v, v); label: return; } private void finishedInTheCurrentThread(org.glassfish.grizzly.ReadHandler) { org.glassfish.grizzly.http.io.InputBuffer v; org.glassfish.grizzly.ReadHandler v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: org.glassfish.grizzly.ReadHandler; v = v.; if v != 0 goto label; v. = 1; specialinvoke v.(); if v == null goto label; specialinvoke v.(v, null); label: return; } private void invokeHandlerAllRead(org.glassfish.grizzly.ReadHandler, java.util.concurrent.Executor) { java.lang.Throwable v; java.util.concurrent.Executor v; org.glassfish.grizzly.ReadHandler v; org.glassfish.grizzly.http.io.InputBuffer v; org.glassfish.grizzly.http.io.InputBuffer$1 v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: org.glassfish.grizzly.ReadHandler; v := @parameter: java.util.concurrent.Executor; if v == null goto label; v = new org.glassfish.grizzly.http.io.InputBuffer$1; specialinvoke v.(org.glassfish.grizzly.http.io.InputBuffer,org.glassfish.grizzly.ReadHandler)>(v, v); interfaceinvoke v.(v); goto label; label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; interfaceinvoke v.(v); label: return; catch java.lang.Throwable from label to label with label; } private void processTrailers() { java.util.Iterator v; org.glassfish.grizzly.http.util.MimeHeaders v; java.util.HashMap v; java.lang.Iterable v; java.util.Map v, v, v; int v; java.lang.Object v; java.lang.String v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v; org.glassfish.grizzly.http.HttpHeader v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; if v != null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v <= 0 goto label; v = new java.util.HashMap; specialinvoke v.(int)>(v); v. = v; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); interfaceinvoke v.(v, v); goto label; label: v = staticinvoke (); v. = v; label: return; } public void replayPayload(org.glassfish.grizzly.Buffer) { java.lang.IllegalStateException v; java.lang.Object[] v; org.glassfish.grizzly.Buffer v; java.util.logging.Logger v; java.util.logging.Level v; int v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: org.glassfish.grizzly.Buffer; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Can\'t replay when InputBuffer is not closed"); throw v; label: v = ; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; staticinvoke ("InputBuffer %s replayPayload to %s", v); label: v. = 0; v. = 0; v = (int) -1; v. = v; v = (int) -1; v. = v; v. = v; return; } public boolean isFinished() { org.glassfish.grizzly.http.io.InputBuffer v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; return v; } public boolean isClosed() { org.glassfish.grizzly.http.io.InputBuffer v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; return v; } public void notifyAvailable(org.glassfish.grizzly.ReadHandler) { org.glassfish.grizzly.http.io.InputBuffer v; org.glassfish.grizzly.ReadHandler v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: org.glassfish.grizzly.ReadHandler; virtualinvoke v.(v, 1); return; } public void notifyAvailable(org.glassfish.grizzly.ReadHandler, int) { java.lang.Throwable v, v; java.lang.IllegalStateException v; org.glassfish.grizzly.ReadHandler v, v; java.lang.IllegalArgumentException v, v; int v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v, v, v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: org.glassfish.grizzly.ReadHandler; v := @parameter: int; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("handler cannot be null."); throw v; label: if v > 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("size should be positive integer"); throw v; label: v = v.; if v == null goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Illegal attempt to register a new handler before the existing handler has been notified"); throw v; label: v = v.; if v != 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; interfaceinvoke v.(v); label: return; label: v = virtualinvoke v.(); v = staticinvoke (v, v); if v == 0 goto label; label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; interfaceinvoke v.(v); label: return; label: v. = v; v. = v; v = v.; if v != 0 goto label; v. = 1; virtualinvoke v.(); label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public boolean append(org.glassfish.grizzly.http.HttpContent) throws java.io.IOException { java.lang.Throwable v; org.glassfish.grizzly.ReadHandler v, v; org.glassfish.grizzly.Buffer v; org.glassfish.grizzly.http.HttpContent v; int v, v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v, v, v, v, v, v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: org.glassfish.grizzly.http.HttpContent; v. = 0; v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.(); v = v.; if v == 0 goto label; interfaceinvoke v.(); return 0; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; if v == null goto label; v = 1; goto label; label: v = 0; label: v = v; v = 0; v = interfaceinvoke v.(); if v == 0 goto label; virtualinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = v.; if v < v goto label; v = 1; v = 0; label: if v == 0 goto label; v. = 1; return 1; label: v. = null; if v == 0 goto label; staticinvoke (v); label: specialinvoke v.(v, v, v); goto label; label: v = v.; v. = null; v = virtualinvoke v.(); specialinvoke v.(v, v); label: return 0; } public boolean isAsyncEnabled() { org.glassfish.grizzly.http.io.InputBuffer v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; return 1; } public void setAsyncEnabled(boolean) { org.glassfish.grizzly.http.io.InputBuffer v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: boolean; return; } public void terminate() { java.util.concurrent.CancellationException v; org.glassfish.grizzly.ReadHandler v; org.glassfish.grizzly.Connection v; org.glassfish.grizzly.http.io.InputBuffer v; java.io.EOFException v; java.lang.Exception v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; if v == null goto label; v. = null; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = new java.util.concurrent.CancellationException; v = v; specialinvoke v.()>(); goto label; label: v = new java.io.EOFException; v = v; specialinvoke v.()>(); label: interfaceinvoke v.(v); label: return; } public void initiateAsyncronousDataReceiving() { org.glassfish.grizzly.filterchain.FilterChainContext v, v; org.glassfish.grizzly.filterchain.NextAction v; org.glassfish.grizzly.http.io.InputBuffer v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); return; } protected java.util.concurrent.Executor getThreadPool() { org.glassfish.grizzly.Transport v; org.glassfish.grizzly.Connection v; org.glassfish.grizzly.http.io.InputBuffer v; java.util.concurrent.ExecutorService v, v; boolean v, v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = staticinvoke (); if v != 0 goto label; return null; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = v; goto label; label: v = null; label: return v; } private void invokeErrorHandlerOnProperThread(org.glassfish.grizzly.ReadHandler, java.lang.Throwable) { java.lang.Throwable v; java.util.concurrent.Executor v; org.glassfish.grizzly.ReadHandler v; org.glassfish.grizzly.http.io.InputBuffer v; org.glassfish.grizzly.http.io.InputBuffer$2 v; boolean v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: org.glassfish.grizzly.ReadHandler; v := @parameter: java.lang.Throwable; v = v.; if v != 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = new org.glassfish.grizzly.http.io.InputBuffer$2; specialinvoke v.(org.glassfish.grizzly.http.io.InputBuffer,org.glassfish.grizzly.ReadHandler,java.lang.Throwable)>(v, v, v); interfaceinvoke v.(v); goto label; label: interfaceinvoke v.(v); label: return; } private void invokeHandlerOnProperThread(org.glassfish.grizzly.ReadHandler, boolean, boolean) throws java.io.IOException { org.glassfish.grizzly.http.io.InputBuffer$3 v; java.util.concurrent.Executor v; org.glassfish.grizzly.ReadHandler v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: org.glassfish.grizzly.ReadHandler; v := @parameter: boolean; v := @parameter: boolean; v = virtualinvoke v.(); if v == null goto label; v = new org.glassfish.grizzly.http.io.InputBuffer$3; specialinvoke v.(org.glassfish.grizzly.http.io.InputBuffer,org.glassfish.grizzly.ReadHandler,boolean,boolean)>(v, v, v, v); interfaceinvoke v.(v); goto label; label: specialinvoke v.(v, v, v); label: return; } private void invokeHandler(org.glassfish.grizzly.ReadHandler, boolean, boolean) { java.lang.Throwable v; org.glassfish.grizzly.ReadHandler v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: org.glassfish.grizzly.ReadHandler; v := @parameter: boolean; v := @parameter: boolean; label: if v == 0 goto label; interfaceinvoke v.(); label: if v == 0 goto label; specialinvoke v.(v); label: goto label; label: v := @caughtexception; interfaceinvoke v.(v); label: return; catch java.lang.Throwable from label to label with label; } protected org.glassfish.grizzly.http.HttpContent blockingRead() throws java.io.IOException { org.glassfish.grizzly.filterchain.FilterChainContext v; java.lang.Object v; org.glassfish.grizzly.ReadResult v; org.glassfish.grizzly.http.io.InputBuffer v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); return v; } private int fill(int) throws java.io.IOException { java.lang.Throwable v, v; org.glassfish.grizzly.Buffer v; java.io.IOException v; org.glassfish.grizzly.http.HttpContent v; int v, v, v, v, v; org.glassfish.grizzly.http.io.InputBuffer v; org.glassfish.grizzly.http.HttpBrokenContentException v; boolean v, v; org.glassfish.grizzly.http.HttpHeader v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: int; v = 0; label: v = (int) -1; if v == v goto label; if v >= v goto label; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); label: v = virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); if v == null goto label; v = v; goto label; label: v = v; label: v = staticinvoke (v); throw v; label: v = interfaceinvoke v.(); v = v + v; virtualinvoke v.(v); virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: if v > 0 goto label; if v != 0 goto label; label: return v; label: v = (int) -1; return v; catch org.glassfish.grizzly.http.HttpBrokenContentException from label to label with label; } private int fillChars(int, java.nio.CharBuffer) throws java.io.IOException { java.nio.ByteBuffer v; org.glassfish.grizzly.http.io.InputBuffer v; boolean v, v, v, v, v, v, v; java.nio.CharBuffer v, v, v, v; org.glassfish.grizzly.Buffer v, v, v, v, v, v, v; java.nio.charset.CharsetDecoder v; org.glassfish.grizzly.http.HttpHeader v, v; java.nio.charset.CoderResult v, v; org.glassfish.grizzly.http.HttpContent v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; char v; v := @this: org.glassfish.grizzly.http.io.InputBuffer; v := @parameter: int; v := @parameter: java.nio.CharBuffer; v = 0; v = v.; if v == v goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = 1; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v - v; v = specialinvoke v.(v, v); v = v + v; label: if v < v goto label; virtualinvoke v.(); return v; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(); if v <= 0 goto label; v = v; goto label; label: v = (int) -1; v = v; label: return v; label: v = specialinvoke v.(); v = 0; v = 0; label: if v >= v goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; if v != 0 goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; label: v = virtualinvoke v.