package io.netty.handler.codec.protobuf;

import com.google.protobuf.ExtensionRegistry;
import com.google.protobuf.ExtensionRegistryLite;
import com.google.protobuf.MessageLite;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToMessageDecoder;
import java.util.List;
import java.util.Objects;

/* JADX INFO: loaded from: classes.dex */
@ChannelHandler.Sharable
public class ProtobufDecoder extends MessageToMessageDecoder<ByteBuf> {
    private static final boolean HAS_PARSER;
    private final ExtensionRegistryLite extensionRegistry;
    private final MessageLite prototype;

    static {
        boolean z2 = false;
        try {
            MessageLite.class.getDeclaredMethod("getParserForType", new Class[0]);
            z2 = true;
        } catch (Throwable unused) {
        }
        HAS_PARSER = z2;
    }

    public ProtobufDecoder(MessageLite messageLite) {
        this(messageLite, (ExtensionRegistry) null);
    }

    public ProtobufDecoder(MessageLite messageLite, ExtensionRegistry extensionRegistry) {
        this(messageLite, (ExtensionRegistryLite) extensionRegistry);
    }

    public ProtobufDecoder(MessageLite messageLite, ExtensionRegistryLite extensionRegistryLite) {
        Objects.requireNonNull(messageLite, "prototype");
        this.prototype = messageLite.getDefaultInstanceForType();
        this.extensionRegistry = extensionRegistryLite;
    }

    /* JADX INFO: renamed from: decode, reason: avoid collision after fix types in other method */
    public void decode2(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) {
        byte[] bArrArray;
        MessageLite.Builder builderMergeFrom;
        Object from;
        int i2 = byteBuf.readableBytes();
        int iArrayOffset = 0;
        if (byteBuf.hasArray()) {
            bArrArray = byteBuf.array();
            iArrayOffset = byteBuf.arrayOffset() + byteBuf.readerIndex();
        } else {
            bArrArray = new byte[i2];
            byteBuf.getBytes(byteBuf.readerIndex(), bArrArray, 0, i2);
        }
        if (this.extensionRegistry == null) {
            if (HAS_PARSER) {
                from = this.prototype.getParserForType().parseFrom(bArrArray, iArrayOffset, i2);
            } else {
                builderMergeFrom = this.prototype.newBuilderForType().mergeFrom(bArrArray, iArrayOffset, i2);
                from = builderMergeFrom.build();
            }
        } else if (HAS_PARSER) {
            from = this.prototype.getParserForType().parseFrom(bArrArray, iArrayOffset, i2, this.extensionRegistry);
        } else {
            builderMergeFrom = this.prototype.newBuilderForType().mergeFrom(bArrArray, iArrayOffset, i2, this.extensionRegistry);
            from = builderMergeFrom.build();
        }
        list.add(from);
    }

    @Override // io.netty.handler.codec.MessageToMessageDecoder
    public /* bridge */ /* synthetic */ void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List list) {
        decode2(channelHandlerContext, byteBuf, (List<Object>) list);
    }
}