@Override
public void operationComplete(IoFuture future) {
    if (future.isDone()) {
        if (logger.isInfoEnabled()) {
            logger.info("[JobX] MinaRPC sent success, request id:{}", rpcFuture.getRequest().getId());
        }
        return;
    } else {
        if (logger.isInfoEnabled()) {
            logger.info("[JobX] MinaRPC sent failure, request id:{}", rpcFuture.getRequest().getId());
        }
        if (rpcFuture != null) {
            rpcFuture.caught(getConnect(rpcFuture.getRequest()).getException());
        }
    }
    futureTable.remove(rpcFuture.getRequest().getId());
}
 

public static boolean awaitUninterruptibly(Iterable<? extends IoFuture> futures, long timeoutMillis) {
    try {
        return await0(futures, timeoutMillis, false);
    } catch (InterruptedException e) {
        throw new InternalError();
    }
}
 

private static boolean await0(Iterable<? extends IoFuture> futures, long timeoutMillis, boolean interruptable)
        throws InterruptedException {
    long startTime = timeoutMillis <= 0 ? 0 : System.currentTimeMillis();
    long waitTime = timeoutMillis;

    boolean lastComplete = true;
    Iterator<? extends IoFuture> i = futures.iterator();
    while (i.hasNext()) {
        IoFuture f = i.next();
        do {
            if (interruptable) {
                lastComplete = f.await(waitTime);
            } else {
                lastComplete = f.awaitUninterruptibly(waitTime);
            }

            waitTime = timeoutMillis - (System.currentTimeMillis() - startTime);

            if (lastComplete || waitTime <= 0) {
                break;
            }
        } while (!lastComplete);

        if (waitTime <= 0) {
            break;
        }
    }

    return lastComplete && !i.hasNext();
}
 

/**
 * Close all the sessions
 * TODO disconnectSessions.
 *
 */
private void disconnectSessions() {
    if (!(service instanceof IoAcceptor)) {
        // We don't disconnect sessions for anything but an Acceptor
        return;
    }

    if (!((IoAcceptor) service).isCloseOnDeactivation()) {
        return;
    }

    Object lock = new Object();
    IoFutureListener<IoFuture> listener = new LockNotifyingListener(lock);

    for (IoSession s : managedSessions.values()) {
        s.close(true).addListener(listener);
    }

    try {
        synchronized (lock) {
            while (!managedSessions.isEmpty()) {
                lock.wait(500);
            }
        }
    } catch (InterruptedException ie) {
        // Ignored
    }
}
 

public void operationComplete(IoFuture future) {
    synchronized (TAKEN_LOCAL_ADDRESSES) {
        TAKEN_LOCAL_ADDRESSES.remove(future.getSession().getLocalAddress());
    }
}
 

void doFinishSessionInitialization(IoSession session, IoFuture future) {
    initSession(session, future, null);
}
 

public static void await(Iterable<? extends IoFuture> futures) throws InterruptedException {
    for (IoFuture f : futures) {
        f.await();
    }
}
 

public static void awaitUninterruptably(Iterable<? extends IoFuture> futures) {
    for (IoFuture f : futures) {
        f.awaitUninterruptibly();
    }
}
 

public static boolean await(Iterable<? extends IoFuture> futures, long timeout, TimeUnit unit)
        throws InterruptedException {
    return await(futures, unit.toMillis(timeout));
}
 

public static boolean await(Iterable<? extends IoFuture> futures, long timeoutMillis) throws InterruptedException {
    return await0(futures, timeoutMillis, true);
}
 

public static boolean awaitUninterruptibly(Iterable<? extends IoFuture> futures, long timeout, TimeUnit unit) {
    return awaitUninterruptibly(futures, unit.toMillis(timeout));
}
 

public void operationComplete(IoFuture future) {
    removeSession((AbstractIoSession) future.getSession());
}
 

public void operationComplete(IoFuture future) {
    synchronized (lock) {
        lock.notifyAll();
    }
}
 

@Override
public void operationComplete(IoFuture future) {
	Stat.getInstance().aiMessageSent++;
}
 

@Override
public void operationComplete(IoFuture future) {
	Stat.getInstance().aiMessageSent++;
}
 

@Override
public void operationComplete(IoFuture future) {
	Stat.getInstance().aiMessageSent++;
}
 

@Override
public void operationComplete(IoFuture future) {
	Stat.getInstance().messageClientSent++;
}
 

@Override
public void operationComplete(IoFuture future) {
	Stat.getInstance().messageClientSent++;
}
 

@Override
public void operationComplete(IoFuture future) {
	Stat.getInstance().rpcClientSent++;
}
 

@Override
public void operationComplete(IoFuture future) {
	Stat.getInstance().rpcClientSent++;
}
 

@Override
public void operationComplete(IoFuture future) {
	Stat.getInstance().gameClientSent++;
}
 

@Override
public IoFutureListener<IoFuture> getStatListener() {
	return statListener;
}
 

@Override
public void setStatListener(IoFutureListener<IoFuture> statListener) {
	this.statListener = statListener;
}
 

@Override
public IoFutureListener<IoFuture> getStatListener() {
	return statListener;
}
 

@Override
public void setStatListener(IoFutureListener<IoFuture> statListener) {
	this.statListener = statListener;
}
 

/**
 * Implement this method to perform additional tasks required for session
 * initialization. Do not call this method directly;
 * {@link #initSession(IoSession, IoFuture, IoSessionInitializer)} will call
 * this method instead.
 */
protected void finishSessionInitialization0(IoSession session, IoFuture future) {
    // Do nothing. Extended class might add some specific code 
}
 

/**
 * @return the statListener
 */
public abstract IoFutureListener<IoFuture> getStatListener();
 

/**
 * @param statListener the statListener to set
 */
public abstract void setStatListener(IoFutureListener<IoFuture> statListener);