Reverted java7 NIO changes, since classloading fixes for java6 for
Netty have been implemented
This commit is contained in:
parent
aae89891c0
commit
cb6f82dbda
@ -11,7 +11,6 @@ import com.barchart.udt.SocketUDT;
|
|||||||
import com.barchart.udt.TypeUDT;
|
import com.barchart.udt.TypeUDT;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.net.ProtocolFamily;
|
|
||||||
import java.nio.channels.DatagramChannel;
|
import java.nio.channels.DatagramChannel;
|
||||||
import java.nio.channels.Pipe;
|
import java.nio.channels.Pipe;
|
||||||
import java.nio.channels.spi.SelectorProvider;
|
import java.nio.channels.spi.SelectorProvider;
|
||||||
@ -137,9 +136,4 @@ public class SelectorProviderUDT extends SelectorProvider {
|
|||||||
public void setMaxSelectorSize(final int selectorSize) {
|
public void setMaxSelectorSize(final int selectorSize) {
|
||||||
maxSelectorSize = selectorSize;
|
maxSelectorSize = selectorSize;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public DatagramChannel openDatagramChannel(final ProtocolFamily family) throws IOException {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
@ -14,10 +14,7 @@ import org.slf4j.Logger;
|
|||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.net.SocketAddress;
|
|
||||||
import java.net.SocketOption;
|
|
||||||
import java.nio.channels.ServerSocketChannel;
|
import java.nio.channels.ServerSocketChannel;
|
||||||
import java.util.Set;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* {@link ServerSocketChannel}-like wrapper for {@link SocketUDT} can be either
|
* {@link ServerSocketChannel}-like wrapper for {@link SocketUDT} can be either
|
||||||
@ -139,29 +136,4 @@ public class ServerSocketChannelUDT extends ServerSocketChannel implements Chann
|
|||||||
public TypeUDT typeUDT() {
|
public TypeUDT typeUDT() {
|
||||||
return providerUDT().type();
|
return providerUDT().type();
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public ServerSocketChannel bind(final SocketAddress local, final int backlog) throws IOException {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public <T> ServerSocketChannel setOption(final SocketOption<T> name, final T value) throws IOException {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public <T> T getOption(final SocketOption<T> name) throws IOException {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Set<SocketOption<?>> supportedOptions() {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public SocketAddress getLocalAddress() throws IOException {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
@ -17,14 +17,12 @@ import org.slf4j.LoggerFactory;
|
|||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.net.InetSocketAddress;
|
import java.net.InetSocketAddress;
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
import java.net.SocketOption;
|
|
||||||
import java.nio.ByteBuffer;
|
import java.nio.ByteBuffer;
|
||||||
import java.nio.channels.ClosedChannelException;
|
import java.nio.channels.ClosedChannelException;
|
||||||
import java.nio.channels.ConnectionPendingException;
|
import java.nio.channels.ConnectionPendingException;
|
||||||
import java.nio.channels.IllegalBlockingModeException;
|
import java.nio.channels.IllegalBlockingModeException;
|
||||||
import java.nio.channels.SocketChannel;
|
import java.nio.channels.SocketChannel;
|
||||||
import java.nio.channels.UnresolvedAddressException;
|
import java.nio.channels.UnresolvedAddressException;
|
||||||
import java.util.Set;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* {@link SocketChannel}-like wrapper for {@link SocketUDT}, can be either
|
* {@link SocketChannel}-like wrapper for {@link SocketUDT}, can be either
|
||||||
@ -524,39 +522,4 @@ public class SocketChannelUDT extends SocketChannel implements ChannelUDT {
|
|||||||
return this;
|
return this;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public SocketAddress getRemoteAddress() throws IOException {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public <T> SocketChannel setOption(final SocketOption<T> name, final T value) throws IOException {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public <T> T getOption(final SocketOption<T> name) throws IOException {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Set<SocketOption<?>> supportedOptions() {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public SocketChannel shutdownInput() throws IOException {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public SocketChannel shutdownOutput() throws IOException {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public SocketAddress getLocalAddress() throws IOException {
|
|
||||||
throw new UnsupportedOperationException("feature not available");
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user