package io.netty.handler.codec.serialization;

import g.a.a.a.a;
import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInput;
import java.io.StreamCorruptedException;
import java.util.Objects;

/* JADX INFO: loaded from: classes.dex */
public class ObjectDecoderInputStream extends InputStream implements ObjectInput {
    private final ClassResolver classResolver;
    private final DataInputStream in;
    private final int maxObjectSize;

    public ObjectDecoderInputStream(InputStream inputStream) {
        this(inputStream, (ClassLoader) null);
    }

    public ObjectDecoderInputStream(InputStream inputStream, int i2) {
        this(inputStream, null, i2);
    }

    public ObjectDecoderInputStream(InputStream inputStream, ClassLoader classLoader) {
        this(inputStream, classLoader, 1048576);
    }

    public ObjectDecoderInputStream(InputStream inputStream, ClassLoader classLoader, int i2) {
        Objects.requireNonNull(inputStream, "in");
        if (i2 <= 0) {
            throw new IllegalArgumentException(a.l("maxObjectSize: ", i2));
        }
        if (inputStream instanceof DataInputStream) {
            this.in = (DataInputStream) inputStream;
        } else {
            this.in = new DataInputStream(inputStream);
        }
        this.classResolver = ClassResolvers.weakCachingResolver(classLoader);
        this.maxObjectSize = i2;
    }

    @Override // java.io.InputStream, java.io.ObjectInput
    public int available() {
        return this.in.available();
    }

    @Override // java.io.InputStream, java.io.Closeable, java.lang.AutoCloseable, java.io.ObjectInput
    public void close() {
        this.in.close();
    }

    @Override // java.io.InputStream
    public void mark(int i2) {
        this.in.mark(i2);
    }

    @Override // java.io.InputStream
    public boolean markSupported() {
        return this.in.markSupported();
    }

    @Override // java.io.InputStream, java.io.ObjectInput
    public int read() {
        return this.in.read();
    }

    @Override // java.io.InputStream, java.io.ObjectInput
    public final int read(byte[] bArr) {
        return this.in.read(bArr);
    }

    @Override // java.io.InputStream, java.io.ObjectInput
    public final int read(byte[] bArr, int i2, int i3) {
        return this.in.read(bArr, i2, i3);
    }

    @Override // java.io.DataInput
    public final boolean readBoolean() {
        return this.in.readBoolean();
    }

    @Override // java.io.DataInput
    public final byte readByte() {
        return this.in.readByte();
    }

    @Override // java.io.DataInput
    public final char readChar() {
        return this.in.readChar();
    }

    @Override // java.io.DataInput
    public final double readDouble() {
        return this.in.readDouble();
    }

    @Override // java.io.DataInput
    public final float readFloat() {
        return this.in.readFloat();
    }

    @Override // java.io.DataInput
    public final void readFully(byte[] bArr) throws IOException {
        this.in.readFully(bArr);
    }

    @Override // java.io.DataInput
    public final void readFully(byte[] bArr, int i2, int i3) throws IOException {
        this.in.readFully(bArr, i2, i3);
    }

    @Override // java.io.DataInput
    public final int readInt() {
        return this.in.readInt();
    }

    @Override // java.io.DataInput
    @Deprecated
    public final String readLine() {
        return this.in.readLine();
    }

    @Override // java.io.DataInput
    public final long readLong() {
        return this.in.readLong();
    }

    @Override // java.io.ObjectInput
    public Object readObject() throws StreamCorruptedException {
        int i2 = readInt();
        if (i2 <= 0) {
            throw new StreamCorruptedException(a.l("invalid data length: ", i2));
        }
        if (i2 <= this.maxObjectSize) {
            return new CompactObjectInputStream(this.in, this.classResolver).readObject();
        }
        throw new StreamCorruptedException(a.w(a.G("data length too big: ", i2, " (max: "), this.maxObjectSize, ')'));
    }

    @Override // java.io.DataInput
    public final short readShort() {
        return this.in.readShort();
    }

    @Override // java.io.DataInput
    public final String readUTF() {
        return this.in.readUTF();
    }

    @Override // java.io.DataInput
    public final int readUnsignedByte() {
        return this.in.readUnsignedByte();
    }

    @Override // java.io.DataInput
    public final int readUnsignedShort() {
        return this.in.readUnsignedShort();
    }

    @Override // java.io.InputStream
    public void reset() {
        this.in.reset();
    }

    @Override // java.io.InputStream, java.io.ObjectInput
    public long skip(long j2) {
        return this.in.skip(j2);
    }

    @Override // java.io.DataInput
    public final int skipBytes(int i2) {
        return this.in.skipBytes(i2);
    }
}