com.github.alei121.rawsocketspi

Class RSDatagramChannel

java.lang.Object

java.nio.channels.spi.AbstractInterruptibleChannel

java.nio.channels.SelectableChannel

java.nio.channels.spi.AbstractSelectableChannel

java.nio.channels.DatagramChannel

com.github.alei121.rawsocketspi.RSDatagramChannel

All Implemented Interfaces:

Closeable, AutoCloseable, ByteChannel, Channel, GatheringByteChannel, InterruptibleChannel, MulticastChannel, NetworkChannel, ReadableByteChannel, ScatteringByteChannel, WritableByteChannel

public class RSDatagramChannel
extends DatagramChannel

This implements the Java DatagramChannel for the RawSocket SPI. The implementation leans towards the use of threads instead of nonblocking selector.

Author:

Alan Lei

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RSDatagramChannel(SelectorProvider provider)

Method Summary

Methods

Modifier and Type	Method and Description
DatagramChannel	bind(SocketAddress local)
DatagramChannel	connect(SocketAddress remote)
DatagramChannel	disconnect()
SocketAddress	getLocalAddress()
<T> T	getOption(SocketOption<T> arg0)
RawSocket	getRawSocket()
SocketAddress	getRemoteAddress()
protected void	implCloseSelectableChannel()
protected void	implConfigureBlocking(boolean block)
boolean	isConnected()
MembershipKey	join(InetAddress arg0, NetworkInterface arg1)
MembershipKey	join(InetAddress arg0, NetworkInterface arg1, InetAddress arg2)
int	read(ByteBuffer dst)
long	read(ByteBuffer[] dsts, int offset, int length)
SocketAddress	receive(ByteBuffer dst)
int	send(ByteBuffer src, SocketAddress target)
<T> DatagramChannel	setOption(SocketOption<T> name, T value)
DatagramSocket	socket()
Set<SocketOption<?>>	supportedOptions()
int	write(ByteBuffer src)
long	write(ByteBuffer[] srcs, int offset, int length)

Methods inherited from class java.nio.channels.DatagramChannel

open, open, read, validOps, write

Methods inherited from class java.nio.channels.spi.AbstractSelectableChannel

blockingLock, configureBlocking, implCloseChannel, isBlocking, isRegistered, keyFor, provider, register

Methods inherited from class java.nio.channels.SelectableChannel

register

Methods inherited from class java.nio.channels.spi.AbstractInterruptibleChannel

begin, close, end, isOpen

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.nio.channels.MulticastChannel

close

Methods inherited from interface java.nio.channels.Channel

isOpen

Constructor Detail

RSDatagramChannel

protected RSDatagramChannel(SelectorProvider provider)
                     throws IOException

Throws:

IOException

Method Detail

join

public MembershipKey join(InetAddress arg0,
                 NetworkInterface arg1)
                   throws IOException

Throws:

IOException

join

public MembershipKey join(InetAddress arg0,
                 NetworkInterface arg1,
                 InetAddress arg2)
                   throws IOException

Throws:

IOException

getLocalAddress

public SocketAddress getLocalAddress()
                              throws IOException

Throws:

IOException

getOption

public <T> T getOption(SocketOption<T> arg0)
            throws IOException

Throws:

IOException

supportedOptions

public Set<SocketOption<?>> supportedOptions()

bind

public DatagramChannel bind(SocketAddress local)
                     throws IOException

Specified by:

bind in interface NetworkChannel

Overrides:

bind in class DatagramChannel

Throws:

IOException

connect

public DatagramChannel connect(SocketAddress remote)
                        throws IOException

Specified by:

connect in class DatagramChannel

Throws:

IOException

disconnect

public DatagramChannel disconnect()
                           throws IOException

Specified by:

disconnect in class DatagramChannel

Throws:

IOException

getRemoteAddress

public SocketAddress getRemoteAddress()
                               throws IOException

Specified by:

getRemoteAddress in class DatagramChannel

Throws:

IOException

isConnected

public boolean isConnected()

Specified by:

isConnected in class DatagramChannel

read

public int read(ByteBuffer dst)
         throws IOException

Specified by:

read in interface ReadableByteChannel

Specified by:

read in class DatagramChannel

Throws:

IOException

read

public long read(ByteBuffer[] dsts,
        int offset,
        int length)
          throws IOException

Specified by:

read in interface ScatteringByteChannel

Specified by:

read in class DatagramChannel

Throws:

IOException

receive

public SocketAddress receive(ByteBuffer dst)
                      throws IOException

Specified by:

receive in class DatagramChannel

Throws:

IOException

send

public int send(ByteBuffer src,
       SocketAddress target)
         throws IOException

Specified by:

send in class DatagramChannel

Throws:

IOException

setOption

public <T> DatagramChannel setOption(SocketOption<T> name,
                            T value)
                          throws IOException

Specified by:

setOption in interface NetworkChannel

Specified by:

setOption in class DatagramChannel

Throws:

IOException

socket

public DatagramSocket socket()

Specified by:

socket in class DatagramChannel

write

public int write(ByteBuffer src)
          throws IOException

Specified by:

write in interface WritableByteChannel

Specified by:

write in class DatagramChannel

Throws:

IOException

write

public long write(ByteBuffer[] srcs,
         int offset,
         int length)
           throws IOException

Specified by:

write in interface GatheringByteChannel

Specified by:

write in class DatagramChannel

Throws:

IOException

implCloseSelectableChannel

protected void implCloseSelectableChannel()
                                   throws IOException

Specified by:

implCloseSelectableChannel in class AbstractSelectableChannel

Throws:

IOException

implConfigureBlocking

protected void implConfigureBlocking(boolean block)
                              throws IOException

Specified by:

implConfigureBlocking in class AbstractSelectableChannel

Throws:

IOException

getRawSocket

public RawSocket getRawSocket()