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)
.
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 |
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 |
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(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
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
Copyright © 2000, 2011, Oracle and/or its affiliates. All rights reserved.