Skip navigation links

Oracle® Coherence Java API Reference
Release 3.7.0.0

E18683-01


com.tangosol.net
Class NonBlockingTcpDatagramSocket.Impl

java.lang.Object
  extended by java.net.DatagramSocketImpl
      extended by com.tangosol.net.TcpDatagramSocket.Impl
          extended by 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(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(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

Oracle® Coherence Java API Reference
Release 3.7.0.0

E18683-01


Copyright © 2000, 2011, Oracle and/or its affiliates. All rights reserved.