Skip navigation links

com.tangosol.net
Class NonBlockingTcpDatagramSocket.Impl

java.lang.Object
java.net.DatagramSocketImpl
com.tangosol.net.TcpDatagramSocket.Impl
com.tangosol.net.NonBlockingTcpDatagramSocket.Impl

All Implemented Interfaces:

java.net.SocketOptions

Enclosing class:

NonBlockingTcpDatagramSocket

public static class NonBlockingTcpDatagramSocket.Impl

extends TcpDatagramSocket.Impl

A specialization of TcpDatagramSocket.Impl which provides non-blocking functionality, see send(DatagramPacket).

Field Summary

Fields inherited from class com.tangosol.net.TcpDatagramSocket.Impl

HEADER_SIZE, PROTOCOL_MAGIC

Fields inherited from class java.net.DatagramSocketImpl

fd, localPort

Fields inherited from interface java.net.SocketOptions

IP_MULTICAST_IF, IP_MULTICAST_IF2, IP_MULTICAST_LOOP, IP_TOS, SO_BINDADDR, SO_BROADCAST, SO_KEEPALIVE, SO_LINGER, SO_OOBINLINE, SO_RCVBUF, SO_REUSEADDR, SO_SNDBUF, SO_TIMEOUT, TCP_NODELAY

Constructor Summary

NonBlockingTcpDatagramSocket.Impl()
Creates a new Impl.

NonBlockingTcpDatagramSocket.Impl(com.oracle.common.net.SocketProvider provider)
Creates a new Impl using a provider.

Method Summary

protected com.tangosol.net.TcpDatagramSocket.Impl.Connection	makeConnection(java.net.SocketAddress addr) Produce a new Connection for the specified destination address.
protected com.tangosol.net.TcpDatagramSocket.Impl.Connection	makeConnection(java.nio.channels.SocketChannel chan) Make a connection from an existing channel.
protected boolean	onConnectionHeader(com.tangosol.net.TcpDatagramSocket.Impl.ConnectionStatus status, java.nio.channels.SocketChannel chan) Process a pending connection header.
protected void	send(java.net.DatagramPacket packet)

Methods inherited from class com.tangosol.net.TcpDatagramSocket.Impl

bind, bind, close, closeInbound, closeOutbound, create, ensureConnection, ensureSocketException, getLocalPort, getOption, getTimeToLive, getTTL, join, joinGroup, leave, leaveGroup, logException, logProtocolWarning, nextKey, onAccept, onRead, peek, peekData, processRegistrations, provider, receive, scheduleRegistration, setOption, setPacketMagic, setTimeToLive, setTTL, toString, transferBytes

Methods inherited from class java.net.DatagramSocketImpl

connect, disconnect, getFileDescriptor

Constructor Detail

NonBlockingTcpDatagramSocket.Impl

public NonBlockingTcpDatagramSocket.Impl()
                                  throws java.net.SocketException

Creates a new Impl.

Throws:

java.net.SocketException - if any error happens during the bind, or if the port is unavailable

NonBlockingTcpDatagramSocket.Impl

public NonBlockingTcpDatagramSocket.Impl(com.oracle.common.net.SocketProvider provider)
                                  throws java.net.SocketException

Creates a new Impl using a provider.

Parameters:

provider - the provider used to create internal sockets

Throws:

java.net.SocketException - if any error happens during the bind, or if the port is unavailable

Method Detail

onConnectionHeader

protected boolean onConnectionHeader(com.tangosol.net.TcpDatagramSocket.Impl.ConnectionStatus status,
                                     java.nio.channels.SocketChannel chan)
                              throws java.io.IOException

Process a pending connection header.

Overrides:

onConnectionHeader in class TcpDatagramSocket.Impl

Parameters:

status - the associated ConnectionStatus

chan - the associated channel

Returns:

true if EOS has been reached

Throws:

java.io.IOException - if an I/O error occurs

makeConnection

protected com.tangosol.net.TcpDatagramSocket.Impl.Connection makeConnection(java.nio.channels.SocketChannel chan)
                                                                     throws java.io.IOException

Make a connection from an existing channel.

Parameters:

chan - the channel

Returns:

the connection

Throws:

java.io.IOException - if an I/O error occurs

makeConnection

protected com.tangosol.net.TcpDatagramSocket.Impl.Connection makeConnection(java.net.SocketAddress addr)
                                                                     throws java.io.IOException

Produce a new Connection for the specified destination address.

Overrides:

makeConnection in class TcpDatagramSocket.Impl

Parameters:

addr - the destination address

Returns:

the corresponding connection

Throws:

java.io.IOException - if an I/O error occurs

send

protected void send(java.net.DatagramPacket packet)
             throws java.io.IOException

Overrides:

send in class TcpDatagramSocket.Impl

Throws:

java.io.IOException

Skip navigation links