org.apache.mina.core

Class IoUtil

java.lang.Object

org.apache.mina.core.IoUtil

public class IoUtil
extends java.lang.Object

A utility class that provides various convenience methods related with IoSession and IoFuture.

Field Summary

Fields

Modifier and Type	Field and Description
private static IoSession[]	EMPTY_SESSIONS

Constructor Summary

Constructors

Modifier	Constructor and Description
private	IoUtil()

Method Summary

Modifier and Type	Method and Description
static void	await(java.lang.Iterable<? extends IoFuture> futures)
static boolean	await(java.lang.Iterable<? extends IoFuture> futures, long timeoutMillis)
static boolean	await(java.lang.Iterable<? extends IoFuture> futures, long timeout, java.util.concurrent.TimeUnit unit)
private static boolean	await0(java.lang.Iterable<? extends IoFuture> futures, long timeoutMillis, boolean interruptable)
static void	awaitUninterruptably(java.lang.Iterable<? extends IoFuture> futures)
static boolean	awaitUninterruptibly(java.lang.Iterable<? extends IoFuture> futures, long timeoutMillis)
static boolean	awaitUninterruptibly(java.lang.Iterable<? extends IoFuture> futures, long timeout, java.util.concurrent.TimeUnit unit)
static java.util.List<WriteFuture>	broadcast(java.lang.Object message, java.util.Collection<IoSession> sessions) Writes the specified message to the specified sessions.
static java.util.List<WriteFuture>	broadcast(java.lang.Object message, IoSession... sessions) Writes the specified message to the specified sessions.
static java.util.List<WriteFuture>	broadcast(java.lang.Object message, java.lang.Iterable<IoSession> sessions) Writes the specified message to the specified sessions.
static java.util.List<WriteFuture>	broadcast(java.lang.Object message, java.util.Iterator<IoSession> sessions) Writes the specified message to the specified sessions.
private static void	broadcast(java.lang.Object message, java.util.Iterator<IoSession> sessions, java.util.Collection<WriteFuture> answer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

EMPTY_SESSIONS

private static final IoSession[] EMPTY_SESSIONS

Constructor Detail

IoUtil

private IoUtil()

Method Detail

broadcast

public static java.util.List<WriteFuture> broadcast(java.lang.Object message,
                                                    java.util.Collection<IoSession> sessions)

Writes the specified message to the specified sessions. If the specified message is an IoBuffer, the buffer is automatically duplicated using IoBuffer.duplicate().

broadcast

public static java.util.List<WriteFuture> broadcast(java.lang.Object message,
                                                    java.lang.Iterable<IoSession> sessions)

Writes the specified message to the specified sessions. If the specified message is an IoBuffer, the buffer is automatically duplicated using IoBuffer.duplicate().

broadcast

public static java.util.List<WriteFuture> broadcast(java.lang.Object message,
                                                    java.util.Iterator<IoSession> sessions)

Writes the specified message to the specified sessions. If the specified message is an IoBuffer, the buffer is automatically duplicated using IoBuffer.duplicate().

broadcast

public static java.util.List<WriteFuture> broadcast(java.lang.Object message,
                                                    IoSession... sessions)

Writes the specified message to the specified sessions. If the specified message is an IoBuffer, the buffer is automatically duplicated using IoBuffer.duplicate().

broadcast

private static void broadcast(java.lang.Object message,
                              java.util.Iterator<IoSession> sessions,
                              java.util.Collection<WriteFuture> answer)

await

public static void await(java.lang.Iterable<? extends IoFuture> futures)
                  throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

awaitUninterruptably

public static void awaitUninterruptably(java.lang.Iterable<? extends IoFuture> futures)

await

public static boolean await(java.lang.Iterable<? extends IoFuture> futures,
                            long timeout,
                            java.util.concurrent.TimeUnit unit)
                     throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

await

public static boolean await(java.lang.Iterable<? extends IoFuture> futures,
                            long timeoutMillis)
                     throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

awaitUninterruptibly

public static boolean awaitUninterruptibly(java.lang.Iterable<? extends IoFuture> futures,
                                           long timeout,
                                           java.util.concurrent.TimeUnit unit)

awaitUninterruptibly

public static boolean awaitUninterruptibly(java.lang.Iterable<? extends IoFuture> futures,
                                           long timeoutMillis)

await0

private static boolean await0(java.lang.Iterable<? extends IoFuture> futures,
                              long timeoutMillis,
                              boolean interruptable)
                       throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException