winstone.cluster

Class SimpleCluster

java.lang.Object

winstone.cluster.SimpleCluster

All Implemented Interfaces:

Runnable, Cluster

public class SimpleCluster
extends Object
implements Runnable, Cluster

Represents a cluster of winstone containers.

Version:

$Id: SimpleCluster.java,v 1.8 2006/08/10 06:38:31 rickknowles Exp $

Author:

Rick Knowles

Field Summary

Fields

Modifier and Type	Field and Description
static WinstoneResourceBundle	CLUSTER_RESOURCES

Constructor Summary

Constructors

Constructor and Description
SimpleCluster(Map args, Integer controlPort) Builds a cluster instance

Method Summary

Methods

Modifier and Type	Method and Description
WinstoneSession	askClusterForSession(String sessionId, WebAppConfiguration webAppConfig) Check if the other nodes in this cluster have a session for this sessionId.
void	clusterRequest(byte requestType, InputStream in, OutputStream out, Socket socket, HostGroup hostGroup) Accept a control socket request related to the cluster functions and process the request.
void	destroy() Destroy the maintenance thread if there is one.
void	handleClusterSessionRequest(Socket socket, InputStream in, OutputStream out, HostGroup hostGroup) Handles incoming socket requests for session search
void	handleNodeHeartBeatRequest(Socket socket, InputStream in) Handles heartbeats.
void	handleNodeListDownloadRequest(Socket socket, InputStream in, OutputStream out) Handles incoming socket requests for cluster node lists.
void	run() Send a heartbeat every now and then, and remove any nodes that haven't responded in 3 heartbeats.

Methods inherited from class java.lang.Object

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

Field Detail

CLUSTER_RESOURCES

public static final WinstoneResourceBundle CLUSTER_RESOURCES

Constructor Detail

SimpleCluster

public SimpleCluster(Map args,
             Integer controlPort)

Builds a cluster instance

Method Detail

destroy

public void destroy()

Description copied from interface: Cluster

Destroy the maintenance thread if there is one. Prepare for shutdown

Specified by:

destroy in interface Cluster

run

public void run()

Send a heartbeat every now and then, and remove any nodes that haven't responded in 3 heartbeats.

Specified by:

run in interface Runnable

askClusterForSession

public WinstoneSession askClusterForSession(String sessionId,
                                   WebAppConfiguration webAppConfig)

Check if the other nodes in this cluster have a session for this sessionId.

Specified by:

askClusterForSession in interface Cluster

Parameters:

sessionId - The id of the session to check for

webAppConfig - The web app that owns the session we want

Returns:

A valid session instance

clusterRequest

public void clusterRequest(byte requestType,
                  InputStream in,
                  OutputStream out,
                  Socket socket,
                  HostGroup hostGroup)
                    throws IOException

Accept a control socket request related to the cluster functions and process the request.

Specified by:

clusterRequest in interface Cluster

Parameters:

requestType - A byte indicating the request type

in - Socket input stream

outSocket - output stream

webAppConfig - Instance of the web app

Throws:

IOException

handleClusterSessionRequest

public void handleClusterSessionRequest(Socket socket,
                               InputStream in,
                               OutputStream out,
                               HostGroup hostGroup)
                                 throws IOException

Handles incoming socket requests for session search

Throws:

IOException

handleNodeListDownloadRequest

public void handleNodeListDownloadRequest(Socket socket,
                                 InputStream in,
                                 OutputStream out)
                                   throws IOException

Handles incoming socket requests for cluster node lists.

Throws:

IOException

handleNodeHeartBeatRequest

public void handleNodeHeartBeatRequest(Socket socket,
                              InputStream in)
                                throws IOException

Handles heartbeats. Just updates the date of this node's last heartbeat

Throws:

IOException