org.apache.river.discovery.internal

Class EndpointBasedServer

java.lang.Object

org.apache.river.discovery.internal.BaseProvider

org.apache.river.discovery.internal.EndpointBasedServer

All Implemented Interfaces:

DiscoveryFormatProvider, UnicastDiscoveryServer

public abstract class EndpointBasedServer
extends BaseProvider
implements UnicastDiscoveryServer

Provides an abstract server endpoint-based UnicastDiscoveryServer implementation, which serves as a superclass for server-side providers for the net.jini.discovery.ssl and net.jini.discovery.kerberos unicast discovery formats.

Field Summary

Fields

Modifier and Type	Field and Description
protected EndpointInternals	endpointInternals Object providing access to non-public endpoint operations

Fields inherited from class org.apache.river.discovery.internal.BaseProvider

formatName

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	EndpointBasedServer(String formatName, EndpointInternals endpointInternals) Constructs instance with the given format name and object providing access to non-public endpoint operations.

Method Summary

Modifier and Type	Method and Description
protected byte[]	calcHandshakeHash(ByteBuffer request, ByteBuffer response) Returns the MessageDigest hash of the concatenation of the given unicast discovery request and response handshake bytes.
void	checkUnicastDiscoveryConstraints(InvocationConstraints constraints)
protected abstract ServerEndpoint	getServerEndpoint(ServerSocketFactory factory) Returns a server endpoint which uses the given server socket factory, if non-null.
void	handleUnicastDiscovery(UnicastResponse response, Socket socket, InvocationConstraints constraints, ClientSubjectChecker checker, Collection context, ByteBuffer received, ByteBuffer sent)
protected abstract MessageDigest	handshakeHashAlgorithm() Returns a MessageDigest, subclasses may override to utilize different algorithms.
protected void	writeClassAnnotationCerts(OutputStream out, UnicastResponse response)
protected void	writeUnicastResponse(OutputStream out, UnicastResponse response, Collection context) Allows server providers to use a different unicast response.

Methods inherited from class org.apache.river.discovery.internal.BaseProvider

getFormatName

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.river.discovery.DiscoveryFormatProvider

getFormatName

Field Detail

endpointInternals

protected final EndpointInternals endpointInternals

Object providing access to non-public endpoint operations

Constructor Detail

EndpointBasedServer

protected EndpointBasedServer(String formatName,
                              EndpointInternals endpointInternals)

Constructs instance with the given format name and object providing access to non-public endpoint operations.

Method Detail

checkUnicastDiscoveryConstraints

public void checkUnicastDiscoveryConstraints(InvocationConstraints constraints)
                                      throws UnsupportedConstraintException

Specified by:

checkUnicastDiscoveryConstraints in interface UnicastDiscoveryServer

Throws:

UnsupportedConstraintException

handleUnicastDiscovery

public void handleUnicastDiscovery(UnicastResponse response,
                                   Socket socket,
                                   InvocationConstraints constraints,
                                   ClientSubjectChecker checker,
                                   Collection context,
                                   ByteBuffer received,
                                   ByteBuffer sent)
                            throws IOException

Specified by:

handleUnicastDiscovery in interface UnicastDiscoveryServer

Throws:

IOException

writeUnicastResponse

protected void writeUnicastResponse(OutputStream out,
                                    UnicastResponse response,
                                    Collection context)
                             throws IOException

Allows server providers to use a different unicast response.

Parameters:

out -

response -

context -

Throws:

IOException

writeClassAnnotationCerts

protected void writeClassAnnotationCerts(OutputStream out,
                                         UnicastResponse response)
                                  throws IOException

Throws:

IOException

getServerEndpoint

protected abstract ServerEndpoint getServerEndpoint(ServerSocketFactory factory)
                                             throws UnsupportedConstraintException

Returns a server endpoint which uses the given server socket factory, if non-null. Other parameters of the server endpoint, such as the listen port, are irrelevant from the standpoint of this class and can be chosen arbitrarily.

Throws:

UnsupportedConstraintException

calcHandshakeHash

protected byte[] calcHandshakeHash(ByteBuffer request,
                                   ByteBuffer response)

Returns the MessageDigest hash of the concatenation of the given unicast discovery request and response handshake bytes.

handshakeHashAlgorithm

protected abstract MessageDigest handshakeHashAlgorithm()

Returns a MessageDigest, subclasses may override to utilize different algorithms.

Returns: