package io.netty.buffer;

import io.netty.util.Recycler;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.nio.ByteBuffer;
import java.nio.channels.ClosedChannelException;
import java.nio.channels.FileChannel;
import java.nio.channels.GatheringByteChannel;
import java.nio.channels.ScatteringByteChannel;

/* JADX INFO: loaded from: classes.dex */
public final class PooledDirectByteBuf extends PooledByteBuf<ByteBuffer> {
    private static final Recycler<PooledDirectByteBuf> RECYCLER = new Recycler<PooledDirectByteBuf>() { // from class: io.netty.buffer.PooledDirectByteBuf.1
        /* JADX WARN: Can't rename method to resolve collision */
        @Override // io.netty.util.Recycler
        public PooledDirectByteBuf newObject(Recycler.Handle<PooledDirectByteBuf> handle) {
            return new PooledDirectByteBuf(handle, 0);
        }
    };

    private PooledDirectByteBuf(Recycler.Handle<PooledDirectByteBuf> handle, int i2) {
        super(handle, i2);
    }

    /* JADX WARN: Multi-variable type inference failed */
    private int getBytes(int i2, FileChannel fileChannel, long j2, int i3, boolean z2) {
        checkIndex(i2, i3);
        if (i3 == 0) {
            return 0;
        }
        ByteBuffer byteBufferInternalNioBuffer = z2 ? internalNioBuffer() : ((ByteBuffer) this.memory).duplicate();
        int iIdx = idx(i2);
        byteBufferInternalNioBuffer.clear().position(iIdx).limit(iIdx + i3);
        return fileChannel.write(byteBufferInternalNioBuffer, j2);
    }

    /* JADX WARN: Multi-variable type inference failed */
    private int getBytes(int i2, GatheringByteChannel gatheringByteChannel, int i3, boolean z2) {
        checkIndex(i2, i3);
        if (i3 == 0) {
            return 0;
        }
        ByteBuffer byteBufferInternalNioBuffer = z2 ? internalNioBuffer() : ((ByteBuffer) this.memory).duplicate();
        int iIdx = idx(i2);
        byteBufferInternalNioBuffer.clear().position(iIdx).limit(iIdx + i3);
        return gatheringByteChannel.write(byteBufferInternalNioBuffer);
    }

    /* JADX WARN: Multi-variable type inference failed */
    private void getBytes(int i2, OutputStream outputStream, int i3, boolean z2) throws IOException {
        checkIndex(i2, i3);
        if (i3 == 0) {
            return;
        }
        ByteBufUtil.readBytes(alloc(), z2 ? internalNioBuffer() : ((ByteBuffer) this.memory).duplicate(), idx(i2), i3, outputStream);
    }

    /* JADX WARN: Multi-variable type inference failed */
    private void getBytes(int i2, ByteBuffer byteBuffer, boolean z2) {
        checkIndex(i2, byteBuffer.remaining());
        ByteBuffer byteBufferInternalNioBuffer = z2 ? internalNioBuffer() : ((ByteBuffer) this.memory).duplicate();
        int iIdx = idx(i2);
        byteBufferInternalNioBuffer.clear().position(iIdx).limit(byteBuffer.remaining() + iIdx);
        byteBuffer.put(byteBufferInternalNioBuffer);
    }

    /* JADX WARN: Multi-variable type inference failed */
    private void getBytes(int i2, byte[] bArr, int i3, int i4, boolean z2) {
        checkDstIndex(i2, i4, i3, bArr.length);
        ByteBuffer byteBufferInternalNioBuffer = z2 ? internalNioBuffer() : ((ByteBuffer) this.memory).duplicate();
        int iIdx = idx(i2);
        byteBufferInternalNioBuffer.clear().position(iIdx).limit(iIdx + i4);
        byteBufferInternalNioBuffer.get(bArr, i3, i4);
    }

    public static PooledDirectByteBuf newInstance(int i2) {
        PooledDirectByteBuf pooledDirectByteBuf = RECYCLER.get();
        pooledDirectByteBuf.reuse(i2);
        return pooledDirectByteBuf;
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.AbstractByteBuf
    public byte _getByte(int i2) {
        return ((ByteBuffer) this.memory).get(idx(i2));
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.AbstractByteBuf
    public int _getInt(int i2) {
        return ((ByteBuffer) this.memory).getInt(idx(i2));
    }

    @Override // io.netty.buffer.AbstractByteBuf
    public int _getIntLE(int i2) {
        return ByteBufUtil.swapInt(_getInt(i2));
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.AbstractByteBuf
    public long _getLong(int i2) {
        return ((ByteBuffer) this.memory).getLong(idx(i2));
    }

    @Override // io.netty.buffer.AbstractByteBuf
    public long _getLongLE(int i2) {
        return ByteBufUtil.swapLong(_getLong(i2));
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.AbstractByteBuf
    public short _getShort(int i2) {
        return ((ByteBuffer) this.memory).getShort(idx(i2));
    }

    @Override // io.netty.buffer.AbstractByteBuf
    public short _getShortLE(int i2) {
        return ByteBufUtil.swapShort(_getShort(i2));
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.AbstractByteBuf
    public int _getUnsignedMedium(int i2) {
        int iIdx = idx(i2);
        return (((ByteBuffer) this.memory).get(iIdx + 2) & 255) | ((((ByteBuffer) this.memory).get(iIdx) & 255) << 16) | ((((ByteBuffer) this.memory).get(iIdx + 1) & 255) << 8);
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.AbstractByteBuf
    public int _getUnsignedMediumLE(int i2) {
        int iIdx = idx(i2);
        return ((((ByteBuffer) this.memory).get(iIdx + 2) & 255) << 16) | (((ByteBuffer) this.memory).get(iIdx) & 255) | ((((ByteBuffer) this.memory).get(iIdx + 1) & 255) << 8);
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.AbstractByteBuf
    public void _setByte(int i2, int i3) {
        ((ByteBuffer) this.memory).put(idx(i2), (byte) i3);
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.AbstractByteBuf
    public void _setInt(int i2, int i3) {
        ((ByteBuffer) this.memory).putInt(idx(i2), i3);
    }

    @Override // io.netty.buffer.AbstractByteBuf
    public void _setIntLE(int i2, int i3) {
        _setInt(i2, ByteBufUtil.swapInt(i3));
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.AbstractByteBuf
    public void _setLong(int i2, long j2) {
        ((ByteBuffer) this.memory).putLong(idx(i2), j2);
    }

    @Override // io.netty.buffer.AbstractByteBuf
    public void _setLongLE(int i2, long j2) {
        _setLong(i2, ByteBufUtil.swapLong(j2));
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.AbstractByteBuf
    public void _setMedium(int i2, int i3) {
        int iIdx = idx(i2);
        ((ByteBuffer) this.memory).put(iIdx, (byte) (i3 >>> 16));
        ((ByteBuffer) this.memory).put(iIdx + 1, (byte) (i3 >>> 8));
        ((ByteBuffer) this.memory).put(iIdx + 2, (byte) i3);
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.AbstractByteBuf
    public void _setMediumLE(int i2, int i3) {
        int iIdx = idx(i2);
        ((ByteBuffer) this.memory).put(iIdx, (byte) i3);
        ((ByteBuffer) this.memory).put(iIdx + 1, (byte) (i3 >>> 8));
        ((ByteBuffer) this.memory).put(iIdx + 2, (byte) (i3 >>> 16));
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.AbstractByteBuf
    public void _setShort(int i2, int i3) {
        ((ByteBuffer) this.memory).putShort(idx(i2), (short) i3);
    }

    @Override // io.netty.buffer.AbstractByteBuf
    public void _setShortLE(int i2, int i3) {
        _setShort(i2, ByteBufUtil.swapShort((short) i3));
    }

    @Override // io.netty.buffer.ByteBuf
    public byte[] array() {
        throw new UnsupportedOperationException("direct buffer");
    }

    @Override // io.netty.buffer.ByteBuf
    public int arrayOffset() {
        throw new UnsupportedOperationException("direct buffer");
    }

    @Override // io.netty.buffer.ByteBuf
    public ByteBuf copy(int i2, int i3) {
        checkIndex(i2, i3);
        ByteBuf byteBufDirectBuffer = alloc().directBuffer(i3, maxCapacity());
        byteBufDirectBuffer.writeBytes(this, i2, i3);
        return byteBufDirectBuffer;
    }

    @Override // io.netty.buffer.ByteBuf
    public int getBytes(int i2, FileChannel fileChannel, long j2, int i3) {
        return getBytes(i2, fileChannel, j2, i3, false);
    }

    @Override // io.netty.buffer.ByteBuf
    public int getBytes(int i2, GatheringByteChannel gatheringByteChannel, int i3) {
        return getBytes(i2, gatheringByteChannel, i3, false);
    }

    @Override // io.netty.buffer.ByteBuf
    public ByteBuf getBytes(int i2, ByteBuf byteBuf, int i3, int i4) {
        checkDstIndex(i2, i4, i3, byteBuf.capacity());
        if (byteBuf.hasArray()) {
            getBytes(i2, byteBuf.array(), byteBuf.arrayOffset() + i3, i4);
        } else if (byteBuf.nioBufferCount() > 0) {
            ByteBuffer[] byteBufferArrNioBuffers = byteBuf.nioBuffers(i3, i4);
            for (ByteBuffer byteBuffer : byteBufferArrNioBuffers) {
                int iRemaining = byteBuffer.remaining();
                getBytes(i2, byteBuffer);
                i2 += iRemaining;
            }
        } else {
            byteBuf.setBytes(i3, this, i2, i4);
        }
        return this;
    }

    @Override // io.netty.buffer.ByteBuf
    public ByteBuf getBytes(int i2, OutputStream outputStream, int i3) throws IOException {
        getBytes(i2, outputStream, i3, false);
        return this;
    }

    @Override // io.netty.buffer.ByteBuf
    public ByteBuf getBytes(int i2, ByteBuffer byteBuffer) {
        getBytes(i2, byteBuffer, false);
        return this;
    }

    @Override // io.netty.buffer.ByteBuf
    public ByteBuf getBytes(int i2, byte[] bArr, int i3, int i4) {
        getBytes(i2, bArr, i3, i4, false);
        return this;
    }

    @Override // io.netty.buffer.ByteBuf
    public boolean hasArray() {
        return false;
    }

    @Override // io.netty.buffer.ByteBuf
    public boolean hasMemoryAddress() {
        return false;
    }

    @Override // io.netty.buffer.ByteBuf
    public ByteBuffer internalNioBuffer(int i2, int i3) {
        checkIndex(i2, i3);
        int iIdx = idx(i2);
        return (ByteBuffer) internalNioBuffer().clear().position(iIdx).limit(iIdx + i3);
    }

    @Override // io.netty.buffer.ByteBuf
    public boolean isDirect() {
        return true;
    }

    @Override // io.netty.buffer.ByteBuf
    public long memoryAddress() {
        throw new UnsupportedOperationException();
    }

    @Override // io.netty.buffer.PooledByteBuf
    public ByteBuffer newInternalNioBuffer(ByteBuffer byteBuffer) {
        return byteBuffer.duplicate();
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // io.netty.buffer.ByteBuf
    public ByteBuffer nioBuffer(int i2, int i3) {
        checkIndex(i2, i3);
        int iIdx = idx(i2);
        return ((ByteBuffer) ((ByteBuffer) this.memory).duplicate().position(iIdx).limit(iIdx + i3)).slice();
    }

    @Override // io.netty.buffer.ByteBuf
    public int nioBufferCount() {
        return 1;
    }

    @Override // io.netty.buffer.ByteBuf
    public ByteBuffer[] nioBuffers(int i2, int i3) {
        return new ByteBuffer[]{nioBuffer(i2, i3)};
    }

    @Override // io.netty.buffer.AbstractByteBuf, io.netty.buffer.ByteBuf
    public int readBytes(FileChannel fileChannel, long j2, int i2) {
        checkReadableBytes(i2);
        int bytes = getBytes(this.readerIndex, fileChannel, j2, i2, true);
        this.readerIndex += bytes;
        return bytes;
    }

    @Override // io.netty.buffer.AbstractByteBuf, io.netty.buffer.ByteBuf
    public int readBytes(GatheringByteChannel gatheringByteChannel, int i2) {
        checkReadableBytes(i2);
        int bytes = getBytes(this.readerIndex, gatheringByteChannel, i2, true);
        this.readerIndex += bytes;
        return bytes;
    }

    @Override // io.netty.buffer.AbstractByteBuf, io.netty.buffer.ByteBuf
    public ByteBuf readBytes(OutputStream outputStream, int i2) throws IOException {
        checkReadableBytes(i2);
        getBytes(this.readerIndex, outputStream, i2, true);
        this.readerIndex += i2;
        return this;
    }

    @Override // io.netty.buffer.AbstractByteBuf, io.netty.buffer.ByteBuf
    public ByteBuf readBytes(ByteBuffer byteBuffer) {
        int iRemaining = byteBuffer.remaining();
        checkReadableBytes(iRemaining);
        getBytes(this.readerIndex, byteBuffer, true);
        this.readerIndex += iRemaining;
        return this;
    }

    @Override // io.netty.buffer.AbstractByteBuf, io.netty.buffer.ByteBuf
    public ByteBuf readBytes(byte[] bArr, int i2, int i3) {
        checkReadableBytes(i3);
        getBytes(this.readerIndex, bArr, i2, i3, true);
        this.readerIndex += i3;
        return this;
    }

    @Override // io.netty.buffer.ByteBuf
    public int setBytes(int i2, InputStream inputStream, int i3) throws IOException {
        checkIndex(i2, i3);
        byte[] bArr = new byte[i3];
        int i4 = inputStream.read(bArr);
        if (i4 <= 0) {
            return i4;
        }
        ByteBuffer byteBufferInternalNioBuffer = internalNioBuffer();
        byteBufferInternalNioBuffer.clear().position(idx(i2));
        byteBufferInternalNioBuffer.put(bArr, 0, i4);
        return i4;
    }

    @Override // io.netty.buffer.ByteBuf
    public int setBytes(int i2, FileChannel fileChannel, long j2, int i3) {
        checkIndex(i2, i3);
        ByteBuffer byteBufferInternalNioBuffer = internalNioBuffer();
        int iIdx = idx(i2);
        byteBufferInternalNioBuffer.clear().position(iIdx).limit(iIdx + i3);
        try {
            return fileChannel.read(byteBufferInternalNioBuffer, j2);
        } catch (ClosedChannelException unused) {
            return -1;
        }
    }

    @Override // io.netty.buffer.ByteBuf
    public int setBytes(int i2, ScatteringByteChannel scatteringByteChannel, int i3) {
        checkIndex(i2, i3);
        ByteBuffer byteBufferInternalNioBuffer = internalNioBuffer();
        int iIdx = idx(i2);
        byteBufferInternalNioBuffer.clear().position(iIdx).limit(iIdx + i3);
        try {
            return scatteringByteChannel.read(byteBufferInternalNioBuffer);
        } catch (ClosedChannelException unused) {
            return -1;
        }
    }

    @Override // io.netty.buffer.ByteBuf
    public ByteBuf setBytes(int i2, ByteBuf byteBuf, int i3, int i4) {
        checkSrcIndex(i2, i4, i3, byteBuf.capacity());
        if (byteBuf.hasArray()) {
            setBytes(i2, byteBuf.array(), byteBuf.arrayOffset() + i3, i4);
        } else if (byteBuf.nioBufferCount() > 0) {
            ByteBuffer[] byteBufferArrNioBuffers = byteBuf.nioBuffers(i3, i4);
            for (ByteBuffer byteBuffer : byteBufferArrNioBuffers) {
                int iRemaining = byteBuffer.remaining();
                setBytes(i2, byteBuffer);
                i2 += iRemaining;
            }
        } else {
            byteBuf.getBytes(i3, this, i2, i4);
        }
        return this;
    }

    @Override // io.netty.buffer.ByteBuf
    public ByteBuf setBytes(int i2, ByteBuffer byteBuffer) {
        checkIndex(i2, byteBuffer.remaining());
        ByteBuffer byteBufferInternalNioBuffer = internalNioBuffer();
        if (byteBuffer == byteBufferInternalNioBuffer) {
            byteBuffer = byteBuffer.duplicate();
        }
        int iIdx = idx(i2);
        byteBufferInternalNioBuffer.clear().position(iIdx).limit(byteBuffer.remaining() + iIdx);
        byteBufferInternalNioBuffer.put(byteBuffer);
        return this;
    }

    @Override // io.netty.buffer.ByteBuf
    public ByteBuf setBytes(int i2, byte[] bArr, int i3, int i4) {
        checkSrcIndex(i2, i4, i3, bArr.length);
        ByteBuffer byteBufferInternalNioBuffer = internalNioBuffer();
        int iIdx = idx(i2);
        byteBufferInternalNioBuffer.clear().position(iIdx).limit(iIdx + i4);
        byteBufferInternalNioBuffer.put(bArr, i3, i4);
        return this;
    }
}