public class io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody extends okhttp.RequestBody
{
private long contentLength;
private java.io.InputStream inputStream;
private okhttp.OkHttpClient okHttpClient;
private io.fabric.kubernetes.client.Config clientConfig;
private java.lang.String name;
private java.lang.String namespace;
public void <init>(okhttp.OkHttpClient, io.fabric.kubernetes.client.Config, java.io.InputStream, long, java.lang.String, java.lang.String)
{
io.fabric.kubernetes.client.Config v;
okhttp.OkHttpClient v;
io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody v;
long v;
java.lang.String v, v;
java.io.InputStream v;
v := @this: io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody;
v := @parameter: okhttp.OkHttpClient;
v := @parameter: io.fabric.kubernetes.client.Config;
v := @parameter: java.io.InputStream;
v := @parameter: long;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
specialinvoke v.<okhttp.RequestBody: void <init>()>();
v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: long contentLength> = v;
v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: java.io.InputStream inputStream> = v;
v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: okhttp.OkHttpClient okHttpClient> = v;
v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: io.fabric.kubernetes.client.Config clientConfig> = v;
v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: java.lang.String name> = v;
v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: java.lang.String namespace> = v;
return;
}
public okhttp.MediaType contentType()
{
io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody v;
okhttp.MediaType v;
v := @this: io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody;
v = staticinvoke <okhttp.MediaType: okhttp.MediaType parse(java.lang.String)>("application/octet-stream");
return v;
}
public long contentLength() throws java.io.IOException
{
io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody v;
long v;
v := @this: io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody;
v = v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: long contentLength>;
return v;
}
public void writeTo(okio.BufferedSink) throws java.io.IOException
{
org.slf4j.Logger v, v;
io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody v;
java.io.IOException v;
java.lang.RuntimeException v;
okio.BufferedSink v;
java.lang.String v, v, v;
v := @this: io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody;
v := @parameter: okio.BufferedSink;
label:
virtualinvoke v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: void writeToSink(okio.BufferedSink)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl: org.slf4j.Logger logger>;
v = v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: java.lang.String name>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object)>("Failed to upload archive file for the build: {}", v);
v = <io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>("Please check cluster events via `oc get events` to see what could have possibly gone wrong");
v = virtualinvoke v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: java.lang.String getRecentEvents()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Can\'t instantiate binary build, due to error reading/writing stream. Can be caused if the output stream was closed by the server.See if something\'s wrong in recent events in Cluster = \u0001");
v = staticinvoke <io.fabric.kubernetes.client.KubernetesClientException: java.lang.RuntimeException launderThrowable(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
}
public void writeToSink(okio.BufferedSink) throws java.io.IOException
{
java.lang.Throwable v, v;
java.io.BufferedInputStream v;
okio.Source v;
okio.BufferedSink v;
io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody v;
java.io.InputStream v;
v := @this: io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody;
v := @parameter: okio.BufferedSink;
v = new java.io.BufferedInputStream;
v = v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: java.io.InputStream inputStream>;
specialinvoke v.<java.io.BufferedInputStream: void <init>(java.io.InputStream)>(v);
label:
v = staticinvoke <okio.Okio: okio.Source source(java.io.InputStream)>(v);
label:
interfaceinvoke v.<okio.BufferedSink: long writeAll(okio.Source)>(v);
label:
if v == null goto label;
interfaceinvoke v.<okio.Source: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
virtualinvoke v.<java.io.BufferedInputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected java.lang.String getRecentEvents()
{
io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody v;
int v, v;
java.lang.String v, v, v, v, v;
io.fabric.kubernetes.client.dsl.internal.core.v.EventOperationsImpl v;
io.fabric.kubernetes.client.Config v;
java.util.List v;
io.fabric.kubernetes.client.dsl.NonNamespaceOperation v;
okhttp.OkHttpClient v;
io.fabric.kubernetes.api.model.ObjectMeta v;
java.lang.Object v, v;
java.lang.StringBuilder v, v, v, v, v, v;
v := @this: io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = new io.fabric.kubernetes.client.dsl.internal.core.v.EventOperationsImpl;
v = v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: okhttp.OkHttpClient okHttpClient>;
v = v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: io.fabric.kubernetes.client.Config clientConfig>;
specialinvoke v.<io.fabric.kubernetes.client.dsl.internal.core.v.EventOperationsImpl: void <init>(okhttp.OkHttpClient,io.fabric.kubernetes.client.Config)>(v, v);
v = v.<io.fabric.openshift.client.dsl.internal.BuildConfigOperationsImpl$ArchiveFileInputStreamRequestBody: java.lang.String namespace>;
v = virtualinvoke v.<io.fabric.kubernetes.client.dsl.internal.core.v.EventOperationsImpl: io.fabric.kubernetes.client.dsl.NonNamespaceOperation inNamespace(java.lang.String)>(v);
v = interfaceinvoke v.<io.fabric.kubernetes.client.dsl.NonNamespaceOperation: java.lang.Object list()>();
v = virtualinvoke v.<io.fabric.kubernetes.api.model.EventList: java.util.List getItems()>();
staticinvoke <io.fabric.kubernetes.client.utils.KubernetesResourceUtil: void sortEventListBasedOnTimestamp(java.util.List)>(v);
v = 0;
label:
if v >= 10 goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = virtualinvoke v.<io.fabric.kubernetes.api.model.Event: java.lang.String getReason()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" ");
v = virtualinvoke v.<io.fabric.kubernetes.api.model.Event: io.fabric.kubernetes.api.model.ObjectMeta getMetadata()>();
v = virtualinvoke v.<io.fabric.kubernetes.api.model.ObjectMeta: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" ");
v = virtualinvoke v.<io.fabric.kubernetes.api.model.Event: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n");
v = v + 1;
goto label;
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
}