Class CallbackHandler

java.lang.Object

org.globus.net.BaseServer

org.globus.gram.CallbackHandler

All Implemented Interfaces:

Runnable

public class CallbackHandler
extends BaseServer

The Server class acts as a basic multi-threaded HTTPS server.

Version:

$Revision: 1.31 $

Field Summary

Fields

Modifier and Type	Field	Description
private Hashtable	_jobs	Registered jobs

Fields inherited from class BaseServer

_server, accept, authorization, credentials, deactivator, gssMode, SO_TIMEOUT, timeout, url

Constructor Summary

Constructors

Constructor	Description
CallbackHandler()	Construct a GRAM callback handler with default user credentials.
CallbackHandler(GSSCredential cred, int port)	Construct a GRAM callback handler with specifed credentials and given port.

Method Summary

Modifier and Type	Method	Description
protected GramJob	getJob(String url)
int	getRegisteredJobsSize()	Returns number of registered jobs
String	getURL()	Returns url of this server
protected void	handleConnection(Socket socket)	This method needs to be implemented by subclasses.
private void	init()
void	registerJob(GramJob job)	Registers gram job to listen for status updates
void	unregisterJob(GramJob job)	Unregisters gram job from listening to status updates

Methods inherited from class BaseServer

getCredentials, getHost, getHostname, getPort, getProtocol, getTimeout, initialize, registerDefaultDeactivator, run, setAuthorization, setGssMode, setTimeout, shutdown, start, unregisterDefaultDeactivator, wrapSocket

Methods inherited from class Object

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

Field Details

_jobs

private Hashtable _jobs

Registered jobs

Constructor Details

CallbackHandler

public CallbackHandler()
                throws IOException

Construct a GRAM callback handler with default user credentials. Port will be dynamically assigned.

Throws:

IOException

CallbackHandler

public CallbackHandler(GSSCredential cred,
 int port)
                throws IOException

Construct a GRAM callback handler with specifed credentials and given port.

Parameters:

cred - credentials to use. if null default user credentials will be used

port - server port to listen on. if set to 0 the port will be dynamically assigned

Throws:

IOException

Method Details

init

private void init()

registerJob

public void registerJob(GramJob job)

Registers gram job to listen for status updates

Parameters:

job - gram job

unregisterJob

public void unregisterJob(GramJob job)

Unregisters gram job from listening to status updates

Parameters:

job - gram job

getJob

protected GramJob getJob(String url)

getRegisteredJobsSize

public int getRegisteredJobsSize()

Returns number of registered jobs

Returns:

int number of jobs

getURL

public String getURL()

Description copied from class: BaseServer

Returns url of this server

Overrides:

getURL in class BaseServer

Returns:

url of this server

handleConnection

protected void handleConnection(Socket socket)

Description copied from class: BaseServer

This method needs to be implemented by subclasses. Optimmaly, it should be a non-blocking call starting a separate thread to handle the client. Note that to start an SSL handshake, you need to call socket.getInput(Output) stream().

Specified by:

handleConnection in class BaseServer