org.apache.river.discovery.internal

Class EndpointBasedClient

java.lang.Object

org.apache.river.discovery.internal.BaseProvider

org.apache.river.discovery.internal.EndpointBasedClient

All Implemented Interfaces:

DiscoveryFormatProvider, UnicastDiscoveryClient

public abstract class EndpointBasedClient
extends BaseProvider
implements UnicastDiscoveryClient

Provides an abstract endpoint-based UnicastDiscoveryClient implementation, which serves as a superclass for client-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	EndpointBasedClient(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)
UnicastResponse	doUnicastDiscovery(Socket socket, InvocationConstraints constraints, ClassLoader defaultLoader, ClassLoader verifierLoader, Collection context, ByteBuffer sent, ByteBuffer received)
protected abstract Endpoint	getEndpoint(SocketFactory factory, InvocationConstraints constraints) Returns an endpoint which uses the given socket factory, if non-null, and may incorporate information (such as the expected server principal) from the given set of constraints, if non-null.
protected abstract MessageDigest	handshakeHashAlgorithm() Returns a MessageDigest, subclasses may override to utilize different algorithms.
protected boolean	readAnnotationCertsGrantPerm(InputStream in, boolean verifyCodebaseIntegrity)
protected UnicastResponse	readUnicastResponse(InputStream in, ClassLoader defaultLoader, boolean verifyCodebaseIntegrity, ClassLoader verifierLoader, Collection context) Client providers can override to utilize a different format.

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

EndpointBasedClient

protected EndpointBasedClient(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 UnicastDiscoveryClient

Throws:

UnsupportedConstraintException

doUnicastDiscovery

public UnicastResponse doUnicastDiscovery(Socket socket,
                                          InvocationConstraints constraints,
                                          ClassLoader defaultLoader,
                                          ClassLoader verifierLoader,
                                          Collection context,
                                          ByteBuffer sent,
                                          ByteBuffer received)
                                   throws IOException,
                                          ClassNotFoundException

Specified by:

doUnicastDiscovery in interface UnicastDiscoveryClient

Throws:

IOException

ClassNotFoundException

readUnicastResponse

protected UnicastResponse readUnicastResponse(InputStream in,
                                              ClassLoader defaultLoader,
                                              boolean verifyCodebaseIntegrity,
                                              ClassLoader verifierLoader,
                                              Collection context)
                                       throws IOException,
                                              ClassNotFoundException

Client providers can override to utilize a different format.

Parameters:

in -

defaultLoader -

verifyCodebaseIntegrity -

verifierLoader -

context -

Returns:

Throws:

IOException

ClassNotFoundException

readAnnotationCertsGrantPerm

protected boolean readAnnotationCertsGrantPerm(InputStream in,
                                               boolean verifyCodebaseIntegrity)
                                        throws IOException

Throws:

IOException

getEndpoint

protected abstract Endpoint getEndpoint(SocketFactory factory,
                                        InvocationConstraints constraints)
                                 throws UnsupportedConstraintException

Returns an endpoint which uses the given socket factory, if non-null, and may incorporate information (such as the expected server principal) from the given set of constraints, if non-null. Other parameters of the endpoint, such as the target host and port, are irrelevant from the standpoint of this class and can be chosen arbitrarily. Throws an UnsupportedConstraintException if the given constraints lack information needed to construct the endpoint.

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: