// 
// Decompiled by Procyon v0.6.0
// 

package io.netty.util.concurrent;

import java.util.Arrays;

final class DefaultFutureListeners
{
    private GenericFutureListener<? extends Future<?>>[] listeners;
    private int size;
    private int progressiveSize;
    
    DefaultFutureListeners(final GenericFutureListener<? extends Future<?>> first, final GenericFutureListener<? extends Future<?>> second) {
        (this.listeners = new GenericFutureListener[2])[0] = first;
        this.listeners[1] = second;
        this.size = 2;
        if (first instanceof GenericProgressiveFutureListener) {
            ++this.progressiveSize;
        }
        if (second instanceof GenericProgressiveFutureListener) {
            ++this.progressiveSize;
        }
    }
    
    public void add(final GenericFutureListener<? extends Future<?>> l) {
        GenericFutureListener<? extends Future<?>>[] listeners = this.listeners;
        final int size = this.size;
        if (size == listeners.length) {
            listeners = (this.listeners = Arrays.copyOf(listeners, size << 1));
        }
        listeners[size] = l;
        this.size = size + 1;
        if (l instanceof GenericProgressiveFutureListener) {
            ++this.progressiveSize;
        }
    }
    
    public void remove(final GenericFutureListener<? extends Future<?>> l) {
        final GenericFutureListener<? extends Future<?>>[] listeners = this.listeners;
        for (int size = this.size, i = 0; i < size; ++i) {
            if (listeners[i] == l) {
                final int listenersToMove = size - i - 1;
                if (listenersToMove > 0) {
                    System.arraycopy(listeners, i + 1, listeners, i, listenersToMove);
                }
                listeners[--size] = null;
                this.size = size;
                if (l instanceof GenericProgressiveFutureListener) {
                    --this.progressiveSize;
                }
                return;
            }
        }
    }
    
    public GenericFutureListener<? extends Future<?>>[] listeners() {
        return this.listeners;
    }
    
    public int size() {
        return this.size;
    }
    
    public int progressiveSize() {
        return this.progressiveSize;
    }
}