package io.netty.handler.codec.serialization;

import g.a.a.a.a;
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 */
public class CompactObjectInputStream extends ObjectInputStream {
    private final ClassResolver classResolver;

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

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

    @Override // java.io.ObjectInputStream
    public void readStreamHeader() throws StreamCorruptedException {
        int i2 = readByte() & 255;
        if (i2 != 5) {
            throw new StreamCorruptedException(a.l("Unsupported version: ", i2));
        }
    }

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