/*
 * Copyright (c) 2011-2017 Contributors to the Eclipse Foundation
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License 2.0 which is available at
 * http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
 * which is available at https://www.apache.org/licenses/LICENSE-2.0.
 *
 * SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
 */

package io.vertx.core.net.impl;

import io.netty.channel.*;
import io.netty.util.concurrent.*;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

Author:Tim Fox
/** * @author <a href="http://tfox.org">Tim Fox</a> */
@SuppressWarnings("deprecation") public final class VertxEventLoopGroup extends AbstractEventExecutorGroup implements EventLoopGroup { private int pos; private final List<EventLoopHolder> workers = new ArrayList<>(); @Override public synchronized EventLoop next() { if (workers.isEmpty()) { throw new IllegalStateException(); } else { EventLoop worker = workers.get(pos).worker; pos++; checkPos(); return worker; } } @Override public Iterator<EventExecutor> iterator() { return children.iterator(); } @Override public ChannelFuture register(Channel channel) { return next().register(channel); } @Override public ChannelFuture register(Channel channel, ChannelPromise promise) { return next().register(channel, promise); } @Override public ChannelFuture register(ChannelPromise promise) { return next().register(promise); } @Override public boolean isShutdown() { return false; } @Override public boolean isTerminated() { return isShutdown(); } @Override public synchronized boolean awaitTermination(long timeout, TimeUnit unit) { return false; } public synchronized void addWorker(EventLoop worker) { EventLoopHolder holder = findHolder(worker); if (holder == null) { workers.add(new EventLoopHolder(worker)); } else { holder.count++; } } public synchronized void shutdown() { throw new UnsupportedOperationException("Should never be called"); } @Override public boolean isShuttingDown() { return false; } @Override public Future<?> shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit) { throw new UnsupportedOperationException("Should never be called"); } @Override public Future<?> terminationFuture() { throw new UnsupportedOperationException("Should never be called"); } private EventLoopHolder findHolder(EventLoop worker) { EventLoopHolder wh = new EventLoopHolder(worker); for (EventLoopHolder holder : workers) { if (holder.equals(wh)) { return holder; } } return null; } public synchronized void removeWorker(EventLoop worker) { //TODO can be optimised EventLoopHolder holder = findHolder(worker); if (holder != null) { holder.count--; if (holder.count == 0) { workers.remove(holder); } checkPos(); } else { throw new IllegalStateException("Can't find worker to remove"); } } public synchronized int workerCount() { return workers.size(); } private void checkPos() { if (pos == workers.size()) { pos = 0; } } private static class EventLoopHolder { int count = 1; final EventLoop worker; EventLoopHolder(EventLoop worker) { this.worker = worker; } @Override public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; EventLoopHolder that = (EventLoopHolder) o; if (worker != null ? !worker.equals(that.worker) : that.worker != null) return false; return true; } @Override public int hashCode() { return worker != null ? worker.hashCode() : 0; } } // private final Set<EventExecutor> children = new Set<EventExecutor>() { @Override public Iterator<EventExecutor> iterator() { return new EventLoopIterator(workers.iterator()); } @Override public int size() { return workers.size(); } @Override public boolean isEmpty() { return workers.isEmpty(); } @Override public boolean contains(Object o) { return workers.contains(o); } @Override public Object[] toArray() { return workers.toArray(); } @Override public <T> T[] toArray(T[] a) { return workers.toArray(a); } @Override public boolean add(EventExecutor eventExecutor) { throw new UnsupportedOperationException(); } @Override public boolean remove(Object o) { throw new UnsupportedOperationException(); } @Override public boolean containsAll(Collection<?> c) { return workers.containsAll(c); } @Override public boolean addAll(Collection<? extends EventExecutor> c) { throw new UnsupportedOperationException(); } @Override public boolean retainAll(Collection<?> c) { throw new UnsupportedOperationException(); } @Override public boolean removeAll(Collection<?> c) { throw new UnsupportedOperationException(); } @Override public void clear() { throw new UnsupportedOperationException(); } }; private static final class EventLoopIterator implements Iterator<EventExecutor> { private final Iterator<EventLoopHolder> holderIt; public EventLoopIterator(Iterator<EventLoopHolder> holderIt) { this.holderIt = holderIt; } @Override public boolean hasNext() { return holderIt.hasNext(); } @Override public EventExecutor next() { return holderIt.next().worker; } @Override public void remove() { throw new UnsupportedOperationException("read-only"); } } }