This commit is contained in:
Norman Maurer 2012-03-30 22:07:27 +02:00
parent c83fb3a3f0
commit 8eb3a30bd4

View File

@ -45,6 +45,7 @@ import java.nio.channels.CancelledKeyException;
import java.nio.channels.ClosedChannelException;
import java.nio.channels.ClosedSelectorException;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.util.Queue;
import java.util.Set;
import java.util.concurrent.Executor;
@ -68,6 +69,8 @@ public class SctpWorker extends NioWorker {
@Override
public void registerWithWorker(final Channel channel, final ChannelFuture future) {
final Selector selector = start();
try {
if (channel instanceof SctpServerChannelImpl) {
final SctpServerChannelImpl ch = (SctpServerChannelImpl) channel;