ORG.oclc.opserve.opsmanager
Class OpsManager

java.lang.Object
  |
  +--java.lang.Thread
        |
        +--ORG.oclc.opserve.opsmanager.OpsManager

Direct Known Subclasses:

JaSSIOpsManager, ZBaseOpsManager, ZBrokerOpsManager

public class OpsManager

extends Thread

implements OpsClient

Field Summary

static String	ACTIVATE
static int	COMMAND_STRING
protected int[]	fdThresholds
static String	FLUSHLOG
static String	FLUSHSTATS
static String	HOUSEKEEPING
static String	HOUSEKEEPING_TIMER
static int	LOG_TYPE
static String	LOGGING_TIMER
protected int[]	memThresholds
static int	METHOD
static int	PARMS
static String	POLL
static String	QUIESCE
static int	ROOT
static String	SERVER_LOG
static String	SESSION_TIMER
protected int[]	sessionThresholds
static String	SETTIMER
static String	SETTRACELEVEL
protected static ORG.oclc.opserve.opserve.ServerState	state
static String	STOP_GRACEFULLY
static String	STOP_IMMEDIATELY
static String	THREAD_TIMER
protected int[]	threadThresholds
static int	TIMER_TYPE
static int	TIMER_VALUE
static int	TRACE_LEVEL
static String	UPDATE
static String	USER_LOG

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

OpsManager()
Constructs an OpsManager object.

Method Summary

void	activate()
void	alert(Object alertData)
void	beginSession(Object user)
protected int	calcLoad(int value, int[] thresholds)
protected int	countThreads()
void	decrConnectedClients()
void	decrFD()
void	endSession(Object user)
void	flushLog(String whichLog)
void	flushStats()
String	getHostID()
static ORG.oclc.opserve.opserve.HostMap	getHostMap()
ServerLocation	getServerLocation(String serverName, String sessionId)
ORG.oclc.opserve.opserve.ServerState	getState()
void	houseKeeping()
void	incrConnectedClients()
void	incrFD()
void	init(IniFile ini)
void	listenForOpsCommands()
protected void	loadFactor()
DataDir	opActivate()
DataDir	opFlushLog(DataDir parms)
DataDir	opFlushStats()
DataDir	opHouseKeeping()
DataDir	opPoll()
DataDir	opQuiesce()
DataDir	opSetTimer(DataDir parms)
DataDir	opSetTraceLevel(DataDir parms)
void	opStopLater()
void	opStopNow()
DataDir	opUpdate(DataDir parms)
void	quiesce()
void	register(int serverPort)
void	responseTime(long timeToRespond)
void	run()
void	setConnectedClients(int clients)
void	setFD(int openFD)
void	setServerPort(int port)
void	setSessionCount(int sessions)
void	setTimer(long msec, String whichTimer)
void	setTraceLevel(int traceLevel, String whichLog)
void	stopGracefully()
void	stopImmediately()
String	toString()
void	unRegister()
void	update(String commandParms)
void	updateStatus(boolean force)
void	updateTransRate()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, yield

Methods inherited from class java.lang.Object

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

Field Detail

ROOT

public static final int ROOT

METHOD

public static final int METHOD

PARMS

public static final int PARMS

LOG_TYPE

public static final int LOG_TYPE

TRACE_LEVEL

public static final int TRACE_LEVEL

TIMER_TYPE

public static final int TIMER_TYPE

TIMER_VALUE

public static final int TIMER_VALUE

COMMAND_STRING

public static final int COMMAND_STRING

ACTIVATE

public static final String ACTIVATE

FLUSHLOG

public static final String FLUSHLOG

FLUSHSTATS

public static final String FLUSHSTATS

HOUSEKEEPING

public static final String HOUSEKEEPING

POLL

public static final String POLL

QUIESCE

public static final String QUIESCE

SETTIMER

public static final String SETTIMER

SETTRACELEVEL

public static final String SETTRACELEVEL

STOP_GRACEFULLY

public static final String STOP_GRACEFULLY

STOP_IMMEDIATELY

public static final String STOP_IMMEDIATELY

UPDATE

public static final String UPDATE

SERVER_LOG

public static final String SERVER_LOG

USER_LOG

public static final String USER_LOG

SESSION_TIMER

public static final String SESSION_TIMER

THREAD_TIMER

public static final String THREAD_TIMER

LOGGING_TIMER

public static final String LOGGING_TIMER

HOUSEKEEPING_TIMER

public static final String HOUSEKEEPING_TIMER

state

protected static ORG.oclc.opserve.opserve.ServerState state

memThresholds

protected int[] memThresholds

sessionThresholds

protected int[] sessionThresholds

fdThresholds

protected int[] fdThresholds

threadThresholds

protected int[] threadThresholds

Constructor Detail

OpsManager

public OpsManager()

Constructs an OpsManager object.

Method Detail

run

public void run()

Overrides:

run in class Thread

getHostMap

public static ORG.oclc.opserve.opserve.HostMap getHostMap()

register

public void register(int serverPort)
              throws Exception

Specified by:

register in interface OpsClient

init

public void init(IniFile ini)
          throws Exception

Specified by:

init in interface OpsClient

listenForOpsCommands

public void listenForOpsCommands()

Specified by:

listenForOpsCommands in interface OpsClient

getHostID

public String getHostID()

Specified by:

getHostID in interface OpsClient

unRegister

public void unRegister()
                throws Exception

Specified by:

unRegister in interface OpsClient

updateStatus

public void updateStatus(boolean force)
                  throws Exception

Specified by:

updateStatus in interface OpsClient

alert

public void alert(Object alertData)
           throws Exception

Specified by:

alert in interface OpsClient

setSessionCount

public void setSessionCount(int sessions)

Specified by:

setSessionCount in interface OpsClient

getServerLocation

public ServerLocation getServerLocation(String serverName,
                                        String sessionId)
                                 throws Exception

Specified by:

getServerLocation in interface OpsClient

beginSession

public void beginSession(Object user)

Specified by:

beginSession in interface OpsClient

endSession

public void endSession(Object user)

Specified by:

endSession in interface OpsClient

setFD

public final void setFD(int openFD)

Specified by:

setFD in interface OpsClient

incrFD

public final void incrFD()

Specified by:

incrFD in interface OpsClient

decrFD

public final void decrFD()

Specified by:

decrFD in interface OpsClient

setConnectedClients

public void setConnectedClients(int clients)

Specified by:

setConnectedClients in interface OpsClient

incrConnectedClients

public void incrConnectedClients()

Specified by:

incrConnectedClients in interface OpsClient

decrConnectedClients

public void decrConnectedClients()

Specified by:

decrConnectedClients in interface OpsClient

updateTransRate

public void updateTransRate()

Specified by:

updateTransRate in interface OpsClient

responseTime

public void responseTime(long timeToRespond)

Specified by:

responseTime in interface OpsClient

toString

public String toString()

Overrides:

toString in class Thread

setServerPort

public void setServerPort(int port)

Specified by:

setServerPort in interface OpsClient

stopGracefully

public void stopGracefully()

stopImmediately

public void stopImmediately()

activate

public void activate()

quiesce

public void quiesce()

flushLog

public void flushLog(String whichLog)

update

public void update(String commandParms)

flushStats

public void flushStats()

setTraceLevel

public void setTraceLevel(int traceLevel,
                          String whichLog)

setTimer

public void setTimer(long msec,
                     String whichTimer)

houseKeeping

public void houseKeeping()

opStopNow

public final void opStopNow()

opStopLater

public final void opStopLater()

opPoll

public final DataDir opPoll()

opActivate

public final DataDir opActivate()

opQuiesce

public final DataDir opQuiesce()

opFlushLog

public final DataDir opFlushLog(DataDir parms)

opUpdate

public final DataDir opUpdate(DataDir parms)

opFlushStats

public final DataDir opFlushStats()

opSetTraceLevel

public final DataDir opSetTraceLevel(DataDir parms)

opSetTimer

public final DataDir opSetTimer(DataDir parms)

opHouseKeeping

public final DataDir opHouseKeeping()

countThreads

protected int countThreads()

loadFactor

protected void loadFactor()

calcLoad

protected int calcLoad(int value,
                       int[] thresholds)

getState

public ORG.oclc.opserve.opserve.ServerState getState()