class io.vertx.core.http.impl.HttpServerFileUploadImpl extends java.lang.Object implements io.vertx.core.http.HttpServerFileUpload
{
private final io.vertx.core.streams.ReadStream stream;
private final io.vertx.core.impl.ContextInternal context;
private final java.lang.String name;
private final java.lang.String filename;
private final java.lang.String contentType;
private final java.lang.String contentTransferEncoding;
private final java.nio.charset.Charset charset;
private io.vertx.core.Handler dataHandler;
private io.vertx.core.Handler endHandler;
private io.vertx.core.Handler exceptionHandler;
private long size;
private boolean lazyCalculateSize;
private io.vertx.core.file.AsyncFile file;
private io.vertx.core.streams.Pipe pipe;
private boolean cancelled;
void <init>(io.vertx.core.impl.ContextInternal, io.vertx.core.streams.ReadStream, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.nio.charset.Charset, long)
{
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
io.vertx.core.impl.ContextInternal v;
long v;
byte v;
java.nio.charset.Charset v;
io.vertx.core.streams.ReadStream v;
java.lang.String v, v, v, v;
io.vertx.core.Handler v, v, v;
boolean v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: io.vertx.core.streams.ReadStream;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.nio.charset.Charset;
v := @parameter: long;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.impl.ContextInternal context> = v;
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.streams.ReadStream stream> = v;
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: java.lang.String name> = v;
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: java.lang.String filename> = v;
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: java.lang.String contentType> = v;
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: java.lang.String contentTransferEncoding> = v;
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: java.nio.charset.Charset charset> = v;
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: long size> = v;
v = v cmp 0L;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: boolean lazyCalculateSize> = v;
v = staticinvoke <io.vertx.core.http.impl.HttpServerFileUploadImpl$handleData__1157: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.HttpServerFileUploadImpl)>(v);
interfaceinvoke v.<io.vertx.core.streams.ReadStream: io.vertx.core.streams.ReadStream handler(io.vertx.core.Handler)>(v);
v = staticinvoke <io.vertx.core.http.impl.HttpServerFileUploadImpl$handleException__1158: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.HttpServerFileUploadImpl)>(v);
interfaceinvoke v.<io.vertx.core.streams.ReadStream: io.vertx.core.streams.ReadStream exceptionHandler(io.vertx.core.Handler)>(v);
v = staticinvoke <io.vertx.core.http.impl.HttpServerFileUploadImpl$lambda_new_0__1159: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.HttpServerFileUploadImpl)>(v);
interfaceinvoke v.<io.vertx.core.streams.ReadStream: io.vertx.core.streams.ReadStream endHandler(io.vertx.core.Handler)>(v);
return;
}
public void handleData(io.vertx.core.buffer.Buffer)
{
java.lang.Throwable v;
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
io.vertx.core.impl.ContextInternal v;
long v, v;
io.vertx.core.buffer.Buffer v;
int v;
io.vertx.core.Handler v;
boolean v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v := @parameter: io.vertx.core.buffer.Buffer;
entermonitor v;
label:
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.Handler dataHandler>;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: boolean lazyCalculateSize>;
if v == 0 goto label;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: long size>;
v = interfaceinvoke v.<io.vertx.core.buffer.Buffer: int length()>();
v = v + v;
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: long size> = v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.impl.ContextInternal context>;
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void dispatch(java.lang.Object,io.vertx.core.Handler)>(v, v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void handleException(java.lang.Throwable)
{
java.lang.Throwable v, v;
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v := @parameter: java.lang.Throwable;
entermonitor v;
label:
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.Handler exceptionHandler>;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.impl.ContextInternal context>;
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void dispatch(java.lang.Object,io.vertx.core.Handler)>(v, v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void handleEnd()
{
java.lang.Throwable v;
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
entermonitor v;
label:
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: boolean lazyCalculateSize> = 0;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.Handler endHandler>;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.impl.ContextInternal context>;
interfaceinvoke v.<io.vertx.core.impl.ContextInternal: void dispatch(io.vertx.core.Handler)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
public java.lang.String filename()
{
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
java.lang.String v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: java.lang.String filename>;
return v;
}
public java.lang.String name()
{
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
java.lang.String v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: java.lang.String name>;
return v;
}
public java.lang.String contentType()
{
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
java.lang.String v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: java.lang.String contentType>;
return v;
}
public java.lang.String contentTransferEncoding()
{
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
java.lang.String v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: java.lang.String contentTransferEncoding>;
return v;
}
public java.lang.String charset()
{
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
java.lang.String v;
java.nio.charset.Charset v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: java.nio.charset.Charset charset>;
v = virtualinvoke v.<java.nio.charset.Charset: java.lang.String toString()>();
return v;
}
public synchronized long size()
{
long v;
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: long size>;
return v;
}
public synchronized io.vertx.core.http.HttpServerFileUpload handler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.Handler dataHandler> = v;
return v;
}
public io.vertx.core.http.HttpServerFileUpload pause()
{
io.vertx.core.streams.ReadStream v;
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.streams.ReadStream stream>;
interfaceinvoke v.<io.vertx.core.streams.ReadStream: io.vertx.core.streams.ReadStream pause()>();
return v;
}
public io.vertx.core.http.HttpServerFileUpload fetch(long)
{
io.vertx.core.streams.ReadStream v;
long v;
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v := @parameter: long;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.streams.ReadStream stream>;
interfaceinvoke v.<io.vertx.core.streams.ReadStream: io.vertx.core.streams.ReadStream fetch(long)>(v);
return v;
}
public io.vertx.core.http.HttpServerFileUpload resume()
{
io.vertx.core.streams.ReadStream v;
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.streams.ReadStream stream>;
interfaceinvoke v.<io.vertx.core.streams.ReadStream: io.vertx.core.streams.ReadStream resume()>();
return v;
}
public synchronized io.vertx.core.http.HttpServerFileUpload exceptionHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.Handler exceptionHandler> = v;
return v;
}
public synchronized io.vertx.core.http.HttpServerFileUpload endHandler(io.vertx.core.Handler)
{
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v := @parameter: io.vertx.core.Handler;
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.Handler endHandler> = v;
return v;
}
public void streamToFileSystem(java.lang.String, io.vertx.core.Handler)
{
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
java.lang.String v;
io.vertx.core.Handler v;
io.vertx.core.Future v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v := @parameter: java.lang.String;
v := @parameter: io.vertx.core.Handler;
v = virtualinvoke v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.Future streamToFileSystem(java.lang.String)>(v);
if v == null goto label;
interfaceinvoke v.<io.vertx.core.Future: io.vertx.core.Future onComplete(io.vertx.core.Handler)>(v);
label:
return;
}
public io.vertx.core.Future streamToFileSystem(java.lang.String)
{
java.lang.Throwable v;
io.vertx.core.impl.ContextInternal v, v;
java.util.function.Function v;
io.vertx.core.streams.Pipe v, v, v;
java.lang.String v;
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
io.vertx.core.impl.VertxInternal v;
io.vertx.core.file.OpenOptions v;
io.vertx.core.Future v, v, v;
io.vertx.core.file.FileSystem v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v := @parameter: java.lang.String;
entermonitor v;
label:
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.streams.Pipe pipe>;
if v == null goto label;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.impl.ContextInternal context>;
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.Future failedFuture(java.lang.String)>("Already streaming");
exitmonitor v;
label:
return v;
label:
v = virtualinvoke v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.streams.Pipe pipe()>();
v = interfaceinvoke v.<io.vertx.core.streams.Pipe: io.vertx.core.streams.Pipe endOnComplete(boolean)>(1);
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.streams.Pipe pipe> = v;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.impl.ContextInternal context>;
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.impl.VertxInternal owner()>();
v = interfaceinvoke v.<io.vertx.core.impl.VertxInternal: io.vertx.core.file.FileSystem fileSystem()>();
v = new io.vertx.core.file.OpenOptions;
specialinvoke v.<io.vertx.core.file.OpenOptions: void <init>()>();
v = interfaceinvoke v.<io.vertx.core.file.FileSystem: io.vertx.core.Future open(java.lang.String,io.vertx.core.file.OpenOptions)>(v, v);
v = staticinvoke <io.vertx.core.http.impl.HttpServerFileUploadImpl$lambda_streamToFileSystem_1__1160: io.vertx.core.Handler bootstrap$(io.vertx.core.http.impl.HttpServerFileUploadImpl)>(v);
interfaceinvoke v.<io.vertx.core.Future: io.vertx.core.Future onFailure(io.vertx.core.Handler)>(v);
v = staticinvoke <io.vertx.core.http.impl.HttpServerFileUploadImpl$lambda_streamToFileSystem_4__1161: java.util.function.Function bootstrap$(io.vertx.core.http.impl.HttpServerFileUploadImpl,io.vertx.core.file.FileSystem,java.lang.String)>(v, v, v);
v = interfaceinvoke v.<io.vertx.core.Future: io.vertx.core.Future compose(java.util.function.Function)>(v);
return v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public boolean cancelStreamToFileSystem()
{
java.lang.Throwable v;
io.vertx.core.file.AsyncFile v;
java.lang.IllegalStateException v;
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
io.vertx.core.streams.Pipe v, v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
entermonitor v;
label:
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.streams.Pipe pipe>;
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Not a streaming upload");
throw v;
label:
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.file.AsyncFile file>;
if v == null goto label;
exitmonitor v;
label:
return 0;
label:
v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: boolean cancelled> = 1;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.streams.Pipe pipe>;
interfaceinvoke v.<io.vertx.core.streams.Pipe: void close()>();
return 1;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public synchronized boolean isSizeAvailable()
{
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
boolean v, v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: boolean lazyCalculateSize>;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public synchronized io.vertx.core.file.AsyncFile file()
{
io.vertx.core.file.AsyncFile v;
io.vertx.core.http.impl.HttpServerFileUploadImpl v;
v := @this: io.vertx.core.http.impl.HttpServerFileUploadImpl;
v = v.<io.vertx.core.http.impl.HttpServerFileUploadImpl: io.vertx.core.file.AsyncFile file>;
return v;
}
}