ParkNPark.middletier
Class ReplicationManager

java.lang.Object
  org.omg.PortableServer.Servant
      ParkNPark.interfaces.ReplicationManagerPOA
          ParkNPark.middletier.ReplicationManager

All Implemented Interfaces:

InvokeHandler, ReplicationManagerOperations

public class ReplicationManager
extends ReplicationManagerPOA

Field Summary

protected static PrintStream	inputEater Shared static instance of the input eater output stream wrapped in a PrintStream
private NamingContextExt	nameServer Naming context
private ORB	orb Object request broker
private NamingContext	parkNParkContext Our naming service's ParkNPark context, which contains server registrations
private POA	rootPOA Root POA
private ArrayList<ServerState>	servers List of active servers

Constructor Summary

ReplicationManager()

Method Summary

void	checkServers() Check whether or not servers are active
protected void	initializeServerListFromParkNParkContext() Initializes the server List from the ParkNParkContext in the name service.
static void	main(String[] args) Entry point of replication manager
private boolean	refreshParkNParkContext() Refreshes the parkNParkContext name service object that we use to get server bindings on.
void	serverRegistered(String ipAddress, String serviceName, ClientManagerFactory cmf) Called by servers when they start up.
void	setPrimary(int index) Set one of the active servers as the primary
private void	setupRMObjects(String[] args) Setup CORBA objects
void	startServer(ServerState s, boolean corrupted) Start a new server or restart a corrupted server
void	unbindServer(ServerState s) Unbind the failed server's service name from the naming service

Methods inherited from class ParkNPark.interfaces.ReplicationManagerPOA

_all_interfaces, _invoke, _this, _this

Methods inherited from class org.omg.PortableServer.Servant

_default_POA, _get_delegate, _get_interface_def, _is_a, _non_existent, _object_id, _orb, _poa, _set_delegate, _this_object, _this_object

Methods inherited from class java.lang.Object

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

Field Detail

servers

private ArrayList<ServerState> servers

List of active servers

nameServer

private NamingContextExt nameServer

Naming context

parkNParkContext

private NamingContext parkNParkContext

Our naming service's ParkNPark context, which contains server registrations

orb

private ORB orb

Object request broker

rootPOA

private POA rootPOA

Root POA

inputEater

protected static PrintStream inputEater

Shared static instance of the input eater output stream wrapped in a PrintStream

Constructor Detail

ReplicationManager

public ReplicationManager()

Method Detail

main

public static void main(String[] args)

Entry point of replication manager

Parameters:

args -

serverRegistered

public void serverRegistered(String ipAddress,
                             String serviceName,
                             ClientManagerFactory cmf)

Called by servers when they start up.

Parameters:

ipAddress -

serviceName -

cmf -

checkServers

public void checkServers()

Check whether or not servers are active

setPrimary

public void setPrimary(int index)

Set one of the active servers as the primary

Parameters:

index -

unbindServer

public void unbindServer(ServerState s)

Unbind the failed server's service name from the naming service

Parameters:

s -

startServer

public void startServer(ServerState s,
                        boolean corrupted)

Start a new server or restart a corrupted server

Parameters:

s -

corrupted -

setupRMObjects

private void setupRMObjects(String[] args)

Setup CORBA objects

refreshParkNParkContext

private boolean refreshParkNParkContext()

Refreshes the parkNParkContext name service object that we use to get server bindings on. The name service is contacted from scratch in this method

Returns:

True if the parkNParkContext was refreshed or false if it was not

initializeServerListFromParkNParkContext

protected void initializeServerListFromParkNParkContext()

Initializes the server List from the ParkNParkContext in the name service. As a prerequisite, the caller must ensure that parkNParkContext is not null