package io.netty.handler.codec.http.websocketx;

import com.cvte.vman.instance.InvokeCmd;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToMessageEncoder;
import java.util.List;

/* JADX INFO: loaded from: classes.dex */
@ChannelHandler.Sharable
public class WebSocket00FrameEncoder extends MessageToMessageEncoder<WebSocketFrame> implements WebSocketFrameEncoder {
    private static final ByteBuf _0X00 = Unpooled.unreleasableBuffer(Unpooled.directBuffer(1, 1).writeByte(0));
    private static final ByteBuf _0XFF = Unpooled.unreleasableBuffer(Unpooled.directBuffer(1, 1).writeByte(-1));
    private static final ByteBuf _0XFF_0X00 = Unpooled.unreleasableBuffer(Unpooled.directBuffer(2, 2).writeByte(-1).writeByte(0));

    /* JADX INFO: renamed from: encode, reason: avoid collision after fix types in other method */
    public void encode2(ChannelHandlerContext channelHandlerContext, WebSocketFrame webSocketFrame, List<Object> list) {
        ByteBuf byteBuf;
        if (webSocketFrame instanceof TextWebSocketFrame) {
            ByteBuf byteBufContent = webSocketFrame.content();
            list.add(_0X00.duplicate());
            list.add(byteBufContent.retain());
            byteBuf = _0XFF;
        } else {
            if (!(webSocketFrame instanceof CloseWebSocketFrame)) {
                ByteBuf byteBufContent2 = webSocketFrame.content();
                int i2 = byteBufContent2.readableBytes();
                ByteBuf byteBufBuffer = channelHandlerContext.alloc().buffer(5);
                try {
                    byteBufBuffer.writeByte(-128);
                    int i3 = (i2 >>> 28) & InvokeCmd.CMD_SYSTEMCTRL_IS_PRODUCTION_MODE;
                    int i4 = (i2 >>> 14) & InvokeCmd.CMD_SYSTEMCTRL_IS_PRODUCTION_MODE;
                    int i5 = (i2 >>> 7) & InvokeCmd.CMD_SYSTEMCTRL_IS_PRODUCTION_MODE;
                    int i6 = i2 & InvokeCmd.CMD_SYSTEMCTRL_IS_PRODUCTION_MODE;
                    if (i3 != 0) {
                        byteBufBuffer.writeByte(i3 | 128);
                        byteBufBuffer.writeByte(i4 | 128);
                        byteBufBuffer.writeByte(i5 | 128);
                    } else if (i4 != 0) {
                        byteBufBuffer.writeByte(i4 | 128);
                        byteBufBuffer.writeByte(i5 | 128);
                    } else if (i5 != 0) {
                        byteBufBuffer.writeByte(i5 | 128);
                    }
                    byteBufBuffer.writeByte(i6);
                    list.add(byteBufBuffer);
                    list.add(byteBufContent2.retain());
                    return;
                } catch (Throwable th) {
                    byteBufBuffer.release();
                    throw th;
                }
            }
            byteBuf = _0XFF_0X00;
        }
        list.add(byteBuf.duplicate());
    }

    @Override // io.netty.handler.codec.MessageToMessageEncoder
    public /* bridge */ /* synthetic */ void encode(ChannelHandlerContext channelHandlerContext, WebSocketFrame webSocketFrame, List list) {
        encode2(channelHandlerContext, webSocketFrame, (List<Object>) list);
    }
}