com.goldencode.p2j.util

Class AgentPool.UnboundPool

java.lang.Object

com.goldencode.p2j.util.AgentPool

com.goldencode.p2j.util.AgentPool.UnboundPool

Enclosing class:

AgentPool

static class AgentPool.UnboundPool
extends AgentPool

Class implementing the behavior for STATE-FREE and STATELESS operating modes. In these modes, no agent is bound to the connection when the connection is established.

Nested Class Summary

Nested classes/interfaces inherited from class com.goldencode.p2j.util.AgentPool

AgentPool.BoundPool, AgentPool.UnboundPool

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Map<java.lang.String,Agent>	connections The reserved agent, for each connection.
private boolean	free Flag indicating this is a STATE-FREE mode.

Fields inherited from class com.goldencode.p2j.util.AgentPool

persistentProcedures

Constructor Summary

Constructors

Constructor and Description
UnboundPool(AppServerDefinition appDef, boolean free) Build a new agent pool, for the specified appserver.

Method Summary

Modifier and Type	Method and Description
(package private) Agent	acquireAgent(java.lang.String id, java.lang.String code, int agentId) Get the agent associated with the given connection id.
(package private) boolean	deactivateAgentOnRemoveProcedure(java.lang.String id, java.lang.Object referent) Determine if the agent must be unbound and deactivate procedure invoked, when there are no more persistent procedures bound to it.
(package private) java.lang.String	newConnection() Establish a new connection.
(package private) void	releaseAgent(java.lang.String id, Agent agent) Release the given agent and place it back in the pool, but only if is still unbound.
(package private) void	terminateConnection(java.lang.String id, boolean running) Terminate the connection with the given ID and unbind the agent.

Methods inherited from class com.goldencode.p2j.util.AgentPool

acquireAgent, addProcedure, available, connect, disableLegacyErrors, disconnect, getActivate, getAgent, getAppserver, getDeactivate, getDef, getExports, getFromMainPool, getName, getOperatingMode, getPropath, getServerConnectionContext, getShutdown, getStartup, getStartupParameter, hasProcedure, isDisabledLegacyErrors, isEmpty, isPasoe, newPool, nextId, poolAgent, removeAgent, removeProcedure, restartAgents, setExports, setServerConnectionContext, size, start, terminateAll, trimAgents

Methods inherited from class java.lang.Object

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

Field Detail

connections

private final java.util.Map<java.lang.String,Agent> connections

The reserved agent, for each connection. This map is populated only when the agent becomes bound to the connection.

free

private final boolean free

Flag indicating this is a STATE-FREE mode.

Constructor Detail

UnboundPool

UnboundPool(AppServerDefinition appDef,
            boolean free)

Build a new agent pool, for the specified appserver.

Parameters:

appDef - The appserver definition.

free - Flag indicating this is a STATE-FREE mode.

Method Detail

acquireAgent

Agent acquireAgent(java.lang.String id,
                   java.lang.String code,
                   int agentId)
            throws NumberedException

Get the agent associated with the given connection id. If no agent is yet bound to the connection or to the persistent procedure, it extracts a new agent from the pool.

Specified by:

acquireAgent in class AgentPool

Parameters:

id - The connection ID.

code - The code of a persistent external procedure to which the agent is associated. May be null.

agentId - When non-negative, the agent ID which created the persistent procedure.

Returns:

See above.

Throws:

NumberedException - If there was no agent available.

releaseAgent

void releaseAgent(java.lang.String id,
                  Agent agent)

Release the given agent and place it back in the pool, but only if is still unbound.

Specified by:

releaseAgent in class AgentPool

Parameters:

id - The connection ID.

agent - The agent which needs to be released.

newConnection

java.lang.String newConnection()

Establish a new connection.

Specified by:

newConnection in class AgentPool

Returns:

The connection ID.

terminateConnection

void terminateConnection(java.lang.String id,
                         boolean running)

Terminate the connection with the given ID and unbind the agent.

Overrides:

terminateConnection in class AgentPool

Parameters:

id - The connection ID.

running - Flag indicating the Agent is already processing a command.

deactivateAgentOnRemoveProcedure

boolean deactivateAgentOnRemoveProcedure(java.lang.String id,
                                         java.lang.Object referent)

Determine if the agent must be unbound and deactivate procedure invoked, when there are no more persistent procedures bound to it.

Specified by:

deactivateAgentOnRemoveProcedure in class AgentPool

Parameters:

id - The connection ID.

referent - The persistent procedure.

Returns:

true if the deactivate can be invoked and the agent unbound.