package io.netty.channel.kqueue;

import io.netty.channel.Channel;
import io.netty.channel.ChannelMetadata;
import io.netty.channel.ChannelOutboundBuffer;
import io.netty.channel.EventLoop;
import io.netty.channel.ServerChannel;
import io.netty.channel.kqueue.AbstractKQueueChannel;
import java.net.InetSocketAddress;
import java.net.SocketAddress;

/* JADX INFO: loaded from: classes.dex */
public abstract class AbstractKQueueServerChannel extends AbstractKQueueChannel implements ServerChannel {
    private static final ChannelMetadata METADATA = new ChannelMetadata(false, 16);

    public final class KQueueServerSocketUnsafe extends AbstractKQueueChannel.AbstractKQueueUnsafe {
        public static final /* synthetic */ boolean $assertionsDisabled = false;
        private final byte[] acceptedAddress;

        public KQueueServerSocketUnsafe() {
            super();
            this.acceptedAddress = new byte[26];
        }

        /* JADX WARN: Code restructure failed: missing block: B:9:0x0030, code lost:
        
            r9.lastBytesRead(-1);
         */
        @Override // io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe
        /*
            Code decompiled incorrectly, please refer to instructions dump.
            To view partially-correct add '--show-bad-code' argument
        */
        public void readReady(io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle r9) {
            /*
                r8 = this;
                io.netty.channel.kqueue.AbstractKQueueServerChannel r0 = io.netty.channel.kqueue.AbstractKQueueServerChannel.this
                io.netty.channel.kqueue.KQueueChannelConfig r0 = r0.config()
                io.netty.channel.kqueue.AbstractKQueueServerChannel r1 = io.netty.channel.kqueue.AbstractKQueueServerChannel.this
                boolean r1 = r1.shouldBreakReadReady(r0)
                if (r1 == 0) goto L12
                r8.clearReadFilter0()
                return
            L12:
                io.netty.channel.kqueue.AbstractKQueueServerChannel r1 = io.netty.channel.kqueue.AbstractKQueueServerChannel.this
                io.netty.channel.ChannelPipeline r1 = r1.pipeline()
                r9.reset(r0)
                r2 = 1
                r9.attemptedBytesRead(r2)
                r8.readReadyBefore()
                r3 = 0
            L23:
                io.netty.channel.kqueue.AbstractKQueueServerChannel r4 = io.netty.channel.kqueue.AbstractKQueueServerChannel.this     // Catch: java.lang.Throwable -> L51
                io.netty.channel.kqueue.BsdSocket r4 = r4.socket     // Catch: java.lang.Throwable -> L51
                byte[] r5 = r8.acceptedAddress     // Catch: java.lang.Throwable -> L51
                int r4 = r4.accept(r5)     // Catch: java.lang.Throwable -> L51
                r5 = -1
                if (r4 != r5) goto L34
                r9.lastBytesRead(r5)     // Catch: java.lang.Throwable -> L51
                goto L53
            L34:
                r9.lastBytesRead(r2)     // Catch: java.lang.Throwable -> L51
                r9.incMessagesRead(r2)     // Catch: java.lang.Throwable -> L51
                r5 = 0
                r8.readPending = r5     // Catch: java.lang.Throwable -> L51
                io.netty.channel.kqueue.AbstractKQueueServerChannel r6 = io.netty.channel.kqueue.AbstractKQueueServerChannel.this     // Catch: java.lang.Throwable -> L51
                byte[] r7 = r8.acceptedAddress     // Catch: java.lang.Throwable -> L51
                r5 = r7[r5]     // Catch: java.lang.Throwable -> L51
                io.netty.channel.Channel r4 = r6.newChildChannel(r4, r7, r2, r5)     // Catch: java.lang.Throwable -> L51
                r1.fireChannelRead(r4)     // Catch: java.lang.Throwable -> L51
                boolean r4 = r9.continueReading()     // Catch: java.lang.Throwable -> L51
                if (r4 != 0) goto L23
                goto L53
            L51:
                r2 = move-exception
                r3 = r2
            L53:
                r9.readComplete()     // Catch: java.lang.Throwable -> L62
                r1.fireChannelReadComplete()     // Catch: java.lang.Throwable -> L62
                if (r3 == 0) goto L5e
                r1.fireExceptionCaught(r3)     // Catch: java.lang.Throwable -> L62
            L5e:
                r8.readReadyFinally(r0)
                return
            L62:
                r9 = move-exception
                r8.readReadyFinally(r0)
                throw r9
            */
            throw new UnsupportedOperationException("Method not decompiled: io.netty.channel.kqueue.AbstractKQueueServerChannel.KQueueServerSocketUnsafe.readReady(io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle):void");
        }
    }

    public AbstractKQueueServerChannel(BsdSocket bsdSocket) {
        this(bsdSocket, AbstractKQueueChannel.isSoErrorZero(bsdSocket));
    }

    public AbstractKQueueServerChannel(BsdSocket bsdSocket, boolean z2) {
        super((Channel) null, bsdSocket, z2);
    }

    @Override // io.netty.channel.kqueue.AbstractKQueueChannel
    public boolean doConnect(SocketAddress socketAddress, SocketAddress socketAddress2) {
        throw new UnsupportedOperationException();
    }

    @Override // io.netty.channel.AbstractChannel
    public void doWrite(ChannelOutboundBuffer channelOutboundBuffer) {
        throw new UnsupportedOperationException();
    }

    @Override // io.netty.channel.AbstractChannel
    public Object filterOutboundMessage(Object obj) {
        throw new UnsupportedOperationException();
    }

    @Override // io.netty.channel.kqueue.AbstractKQueueChannel, io.netty.channel.Channel
    public /* bridge */ /* synthetic */ boolean isActive() {
        return super.isActive();
    }

    @Override // io.netty.channel.kqueue.AbstractKQueueChannel, io.netty.channel.AbstractChannel
    public boolean isCompatible(EventLoop eventLoop) {
        return eventLoop instanceof KQueueEventLoop;
    }

    @Override // io.netty.channel.kqueue.AbstractKQueueChannel, io.netty.channel.Channel
    public /* bridge */ /* synthetic */ boolean isOpen() {
        return super.isOpen();
    }

    @Override // io.netty.channel.kqueue.AbstractKQueueChannel, io.netty.channel.Channel
    public ChannelMetadata metadata() {
        return METADATA;
    }

    public abstract Channel newChildChannel(int i2, byte[] bArr, int i3, int i4);

    @Override // io.netty.channel.kqueue.AbstractKQueueChannel, io.netty.channel.AbstractChannel
    public AbstractKQueueChannel.AbstractKQueueUnsafe newUnsafe() {
        return new KQueueServerSocketUnsafe();
    }

    @Override // io.netty.channel.kqueue.AbstractKQueueChannel, io.netty.channel.AbstractChannel
    public InetSocketAddress remoteAddress0() {
        return null;
    }
}