96 lines
2.2 KiB
Java
96 lines
2.2 KiB
Java
|
package o;
|
||
|
|
||
|
import java.io.IOException;
|
||
|
import java.io.InputStream;
|
||
|
import java.util.Queue;
|
||
|
|
||
|
/* loaded from: classes.dex */
|
||
|
public final class cST extends InputStream {
|
||
|
public static final Queue<cST> b = FKd.e(0);
|
||
|
public IOException c;
|
||
|
public InputStream d;
|
||
|
|
||
|
public static cST e(InputStream inputStream) {
|
||
|
cST poll;
|
||
|
Queue<cST> queue = b;
|
||
|
synchronized (queue) {
|
||
|
poll = queue.poll();
|
||
|
}
|
||
|
if (poll == null) {
|
||
|
poll = new cST();
|
||
|
}
|
||
|
poll.d = inputStream;
|
||
|
return poll;
|
||
|
}
|
||
|
|
||
|
cST() {
|
||
|
}
|
||
|
|
||
|
@Override // java.io.InputStream
|
||
|
public final int available() throws IOException {
|
||
|
return this.d.available();
|
||
|
}
|
||
|
|
||
|
@Override // java.io.InputStream, java.io.Closeable, java.lang.AutoCloseable
|
||
|
public final void close() throws IOException {
|
||
|
this.d.close();
|
||
|
}
|
||
|
|
||
|
@Override // java.io.InputStream
|
||
|
public final void mark(int i) {
|
||
|
this.d.mark(i);
|
||
|
}
|
||
|
|
||
|
@Override // java.io.InputStream
|
||
|
public final boolean markSupported() {
|
||
|
return this.d.markSupported();
|
||
|
}
|
||
|
|
||
|
@Override // java.io.InputStream
|
||
|
public final int read() throws IOException {
|
||
|
try {
|
||
|
return this.d.read();
|
||
|
} catch (IOException e) {
|
||
|
this.c = e;
|
||
|
throw e;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
@Override // java.io.InputStream
|
||
|
public final int read(byte[] bArr) throws IOException {
|
||
|
try {
|
||
|
return this.d.read(bArr);
|
||
|
} catch (IOException e) {
|
||
|
this.c = e;
|
||
|
throw e;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
@Override // java.io.InputStream
|
||
|
public final int read(byte[] bArr, int i, int i2) throws IOException {
|
||
|
try {
|
||
|
return this.d.read(bArr, i, i2);
|
||
|
} catch (IOException e) {
|
||
|
this.c = e;
|
||
|
throw e;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
@Override // java.io.InputStream
|
||
|
public final void reset() throws IOException {
|
||
|
synchronized (this) {
|
||
|
this.d.reset();
|
||
|
}
|
||
|
}
|
||
|
|
||
|
@Override // java.io.InputStream
|
||
|
public final long skip(long j) throws IOException {
|
||
|
try {
|
||
|
return this.d.skip(j);
|
||
|
} catch (IOException e) {
|
||
|
this.c = e;
|
||
|
throw e;
|
||
|
}
|
||
|
}
|
||
|
}
|