package io.netty.handler.codec;

import g.a.a.a.a;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import java.util.List;

/* JADX INFO: loaded from: classes.dex */
public class FixedLengthFrameDecoder extends ByteToMessageDecoder {
    private final int frameLength;

    public FixedLengthFrameDecoder(int i2) {
        if (i2 <= 0) {
            throw new IllegalArgumentException(a.l("frameLength must be a positive integer: ", i2));
        }
        this.frameLength = i2;
    }

    public Object decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf) {
        int i2 = byteBuf.readableBytes();
        int i3 = this.frameLength;
        if (i2 < i3) {
            return null;
        }
        return byteBuf.readRetainedSlice(i3);
    }

    @Override // io.netty.handler.codec.ByteToMessageDecoder
    public final void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) {
        Object objDecode = decode(channelHandlerContext, byteBuf);
        if (objDecode != null) {
            list.add(objDecode);
        }
    }
}