package io.netty.handler.codec.serialization;

import java.io.EOFException;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectStreamClass;
import java.io.StreamCorruptedException;

/* JADX INFO: loaded from: classes.dex */
class CompactObjectInputStream extends ObjectInputStream {
    private final ClassResolver classResolver;

    CompactObjectInputStream(InputStream inputStream, ClassResolver classResolver) throws IOException {
        super(inputStream);
        this.classResolver = classResolver;
    }

    @Override // java.io.ObjectInputStream
    protected ObjectStreamClass readClassDescriptor() throws IOException, ClassNotFoundException {
        int i2 = read();
        if (i2 < 0) {
            throw new EOFException();
        }
        if (i2 == 0) {
            return super.readClassDescriptor();
        }
        if (i2 == 1) {
            return ObjectStreamClass.lookupAny(this.classResolver.resolve(readUTF()));
        }
        throw new StreamCorruptedException("Unexpected class descriptor type: " + i2);
    }

    @Override // java.io.ObjectInputStream
    protected void readStreamHeader() throws IOException {
        int i2 = readByte() & 255;
        if (i2 == 5) {
            return;
        }
        throw new StreamCorruptedException("Unsupported version: " + i2);
    }

    @Override // java.io.ObjectInputStream
    protected Class<?> resolveClass(ObjectStreamClass objectStreamClass) throws IOException, ClassNotFoundException {
        try {
            return this.classResolver.resolve(objectStreamClass.getName());
        } catch (ClassNotFoundException unused) {
            return super.resolveClass(objectStreamClass);
        }
    }
}