de.ipcon.db

Class DefaultServiceManager

java.lang.Object

de.ipcon.db.DefaultServiceManager

All Implemented Interfaces:

DBManEventListenerI, java.lang.Runnable

public class DefaultServiceManager
extends java.lang.Object
implements java.lang.Runnable, DBManEventListenerI

A common class handling the initialisation of services after serverstart and stopping/restarting of services after changes. Knows the current nodeNumber and only executes services configured to run on this node. Uses a LinkedBlockingQueue as a messagequeue internally to handle triggered changes asynchronously.

Constructor Summary

Constructors

Constructor and Description
DefaultServiceManager()

Method Summary

Modifier and Type	Method and Description
void	addService(BS s)
void	addWatchDog(ServiceInstanceI service, java.lang.String chewBone, long waitForMillis) Adds a Watchdog for a service with the key chewBone, which waits for a certain amount of time.
ServiceI	getByName(java.lang.String _n)
DBManConfigurationHelperI	getConf()
DBManLocalI	getDbm()
ErrorHandler	getEh()
netrexx.lang.Rexx	getSection() A WatchDog class that waits for a certain amount of time and looks after a service.
java.util.Map	getServices()
java.lang.Thread	getServiceThread()
boolean	hasWatchDog(java.lang.String chewBone) Checks if there exists a WatchDog that already chews this Bone.
void	init(DBManLocalI _dbm, netrexx.lang.Rexx _section)
void	keepWatchDog(java.lang.String chewBone, long keepForMoreMillis) This method updates the automatic waiting time of the watchdog for chewBone by keepForMore milliseconds.
void	maintainService(BS s)
void	notifyWatchDog(java.lang.String chewBone) Sets off the watchdog, which then tries to go after its target - if it is still alive.
void	processDBManEvent(DBManEvent e) Invoked when a subscribed DBManEvent occurs.
void	run()
void	setConf(DBManConfigurationHelperI $11)
void	setEh(ErrorHandler $12)
void	setSection(netrexx.lang.Rexx $9)
void	setServices(java.util.Map $13)
void	setServiceThread(java.lang.Thread $10)
void	startServiceManager()
static void	stop(ServiceInstanceI s) Stops the provided Worker-Thread or the current worker thread of the provided ServiceInstance.
static void	stop(ServiceInstanceI s, java.lang.Thread worker)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultServiceManager

public DefaultServiceManager()

Method Detail

init

public void init(DBManLocalI _dbm,
                 netrexx.lang.Rexx _section)

getDbm

public DBManLocalI getDbm()

startServiceManager

public void startServiceManager()

run

public void run()

Specified by:

run in interface java.lang.Runnable

processDBManEvent

public void processDBManEvent(DBManEvent e)

Description copied from interface: DBManEventListenerI

Invoked when a subscribed DBManEvent occurs. See DBManBOChangeEvent for events triggered after modification on BOs.

Specified by:

processDBManEvent in interface DBManEventListenerI

addService

public void addService(BS s)

maintainService

public void maintainService(BS s)

getByName

public ServiceI getByName(java.lang.String _n)

addWatchDog

public void addWatchDog(ServiceInstanceI service,
                        java.lang.String chewBone,
                        long waitForMillis)

Adds a Watchdog for a service with the key chewBone, which waits for a certain amount of time. If the Watchdog receives the same chewBone twice, it is notified.

Parameters:

service - the ServiceInstanceI which should be watched

chewBone - the key/name of the dog that watches this service

waitForMillis - how long does the dog chew before going after the service.

hasWatchDog

public boolean hasWatchDog(java.lang.String chewBone)

Checks if there exists a WatchDog that already chews this Bone.

Parameters:

chewBone - the key that should be checked for dogs.

Returns:

true if this bone already has a watchdog, false otherwise.

notifyWatchDog

public void notifyWatchDog(java.lang.String chewBone)

Sets off the watchdog, which then tries to go after its target - if it is still alive. It's key is then becomes dogless.

Parameters:

chewBone - the bone of the dog to notify

keepWatchDog

public void keepWatchDog(java.lang.String chewBone,
                         long keepForMoreMillis)

This method updates the automatic waiting time of the watchdog for chewBone by keepForMore milliseconds.

Parameters:

chewBone - the key of the dog to update

keepForMoreMillis - the dog sleeps again for keepForMoreMillis milliseconds the next time it wakes.

stop

public static void stop(ServiceInstanceI s)

Stops the provided Worker-Thread or the current worker thread of the provided ServiceInstance. The worker thread is interrupted if still alive. After 3 more seconds, the worked thread is stopped forcefully. Careful: If the service already exited on its own, e.g. due to an exception, then the provided ServiceInstanceI.getWorker() might already return new Worker after the immedeate restart.

Parameters:

s - a ServiceInstanceI that should be stopped, only use its worker if no explicit worker-thread to stop has been provided.

worker - optional, allows to explicitly specify a thread that is notified. If null, the currently used worker thread of the service instance is used.

stop

public static void stop(ServiceInstanceI s,
                        java.lang.Thread worker)

getSection

public netrexx.lang.Rexx getSection()

A WatchDog class that waits for a certain amount of time and looks after a service. If the timeout for this service is reached before it got reset (the dog got fed), the dog forcefully kills the service.

setSection

public void setSection(netrexx.lang.Rexx $9)

getServiceThread

public java.lang.Thread getServiceThread()

setServiceThread

public void setServiceThread(java.lang.Thread $10)

getConf

public DBManConfigurationHelperI getConf()

setConf

public void setConf(DBManConfigurationHelperI $11)

getEh

public ErrorHandler getEh()

setEh

public void setEh(ErrorHandler $12)

getServices

public java.util.Map getServices()

setServices

public void setServices(java.util.Map $13)