omero.cmd

Class SessionI

java.lang.Object

omero.cmd.SessionI

All Implemented Interfaces:

Glacier2._SessionOperations

Direct Known Subclasses:

ServiceFactoryI

public class SessionI
extends Object
implements omero.cmd._SessionOperations

Since:

4.3.2

Author:

Josh Moore, josh at glencoesoftware.com

Field Summary

Fields

Modifier and Type	Field and Description
Ice.ObjectAdapter	adapter
protected omero.api.ClientCallbackPrx	callback
String	clientId
OmeroContext	context
Glacier2.SessionControlPrx	control
protected boolean	doClose
Executor	executor Executor to be used by servant implementations which do not delegate to the server package where all instances are wrapped with AOP for dealing with Hibernate.
ServantHolder	holder
Principal	principal
protected AtomicBoolean	reusedSession
SessionManager	sessionManager
String	token Token in the form of a UUID for securing method invocations.

Constructor Summary

Constructors

Constructor and Description
SessionI(boolean reusedSession, Ice.Current current, ServantHolder holder, Glacier2.SessionControlPrx control, OmeroContext context, SessionManager sessionManager, Executor executor, Principal principal, String token)

Method Summary

Modifier and Type	Method and Description
void	allow(Ice.ObjectPrx prx)
protected Ice.Object	callContextWrapper(Ice.Object servant)
void	cleanServants(boolean all) Use cleanServants(boolean, String, ServantHolder, Ice.ObjectAdapter) to clean up.
static void	cleanServants(boolean all, String clientId, ServantHolder holder, Ice.ObjectAdapter adapter) Clean all servants that are in the current holder and remove them from the adapter.
void	cleanupSelf() Called if this isn't a kill-everything event.
static String	clientId(Ice.Current current) Helpers method to extract the CLIENTUUID out of the given Ice.Current.
void	configureServant(Ice.Object servant) Apply proper AOP and call setters for any known injection properties.
protected Ice.Object	createServantDelegate(String name) Creates a proxy according to the servant definition for the given name.
void	destroy(Ice.Current current) Destruction simply decrements the reference count for a session to allow reconnecting to it.
void	doDestroy() Performs the actual cleanup operation on all the resources shared between this and other ServiceFactoryI instances in the same Session.
Ice.ObjectAdapter	getAdapter()
Executor	getExecutor()
Ice.Identity	getIdentity(String name)
Principal	getPrincipal()
void	handleCallbackException(Exception e) Reusable method for logging an exception that occurs on one-way communication with clients during callback notification.
protected void	internalServantConfig(Object obj)
Ice.Current	newCurrent(Ice.Identity id, String method)
static Ice.Current	newCurrent(Ice.Identity id, String method, Ice.ObjectAdapter adapter, String clientId)
Ice.ObjectPrx	registerServant(Ice.Identity id, Ice.Object servant) Registers the servant with the adapter (or throws an exception if one is already registered) as well as configures the servant in any post-Spring way necessary, based on the type of the servant.
Ice.Identity	sessionId() Returns the Identity for this instance as defined by sessionId(String, String)
static Ice.Identity	sessionId(String clientId, String uuid) Definition of session ids: "session-<CLIENTID>/<UUID>"
void	submit_async(omero.cmd.AMD_Session_submit __cb, omero.cmd.Request req, Ice.Current current)
String	toString()
void	unregisterServant(Ice.Identity id) Calls unregisterServant(Ice.Identity, Ice.ObjectAdapter, ServantHolder)
static void	unregisterServant(Ice.Identity id, Ice.ObjectAdapter adapter, ServantHolder holder) Reverts all the additions made by registerServant(Ice.Identity, Ice.Object) Now called by SessionManagerI in response to an UnregisterServantMessage.

Methods inherited from class java.lang.Object

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

Field Detail

clientId

public final String clientId

control

public final Glacier2.SessionControlPrx control

reusedSession

protected final AtomicBoolean reusedSession

doClose

protected boolean doClose

callback

protected omero.api.ClientCallbackPrx callback

holder

public final ServantHolder holder

sessionManager

public final SessionManager sessionManager

executor

public final Executor executor

Executor to be used by servant implementations which do not delegate to the server package where all instances are wrapped with AOP for dealing with Hibernate.

principal

public final Principal principal

context

public final OmeroContext context

adapter

public final Ice.ObjectAdapter adapter

token

public final String token

Token in the form of a UUID for securing method invocations.

Constructor Detail

SessionI

public SessionI(boolean reusedSession,
                Ice.Current current,
                ServantHolder holder,
                Glacier2.SessionControlPrx control,
                OmeroContext context,
                SessionManager sessionManager,
                Executor executor,
                Principal principal,
                String token)
         throws omero.ApiUsageException

Throws:

omero.ApiUsageException

Method Detail

getAdapter

public Ice.ObjectAdapter getAdapter()

getPrincipal

public Principal getPrincipal()

getExecutor

public Executor getExecutor()

submit_async

public void submit_async(omero.cmd.AMD_Session_submit __cb,
                         omero.cmd.Request req,
                         Ice.Current current)

destroy

public void destroy(Ice.Current current)

Destruction simply decrements the reference count for a session to allow reconnecting to it. This means that the Glacier timeout property is fairly unimportant. If a Glacier connection times out or is otherwise destroyed, a client can attempt to reconnect. However, in the case of only one reference to the session, if the Glacier2 timeout is greater than the session timeout, exceptions can be thrown when this method tries to clean up the session. Therefore all session access must be guarded by a try/finally block.

Specified by:

destroy in interface Glacier2._SessionOperations

Parameters:

current - The Current object for the invocation.

handleCallbackException

public void handleCallbackException(Exception e)

Reusable method for logging an exception that occurs on one-way communication with clients during callback notification.

cleanupSelf

public void cleanupSelf()

Called if this isn't a kill-everything event.

See Also:

Trac ticket #9330

doDestroy

public void doDestroy()

Performs the actual cleanup operation on all the resources shared between this and other ServiceFactoryI instances in the same Session. Since destroy(Current) is called regardless by the router, even when a client has just died, we have this internal method for handling the actual closing of resources. This method must take precautions to not throw a SessionException . See destroy(Current) for more information. When destroy(Current) is called but it isn't time to close down the entire instance, then we should still close down the stateless services for this instance as well as remove ourselves from the adapter.

See Also:

Trac ticket #9330

cleanServants

public void cleanServants(boolean all)

Use cleanServants(boolean, String, ServantHolder, Ice.ObjectAdapter) to clean up.

Parameters:

all - if stateful sessions should be shut down such that other clients cannot reattach (the servant is cleaned up)

cleanServants

public static void cleanServants(boolean all,
                                 String clientId,
                                 ServantHolder holder,
                                 Ice.ObjectAdapter adapter)

Clean all servants that are in the current holder and remove them from the adapter. If all is true, then all servants that are non-null will be processed. Otherwise, only servants that a) belong to this clientId and b) are not stateful (since stateful services may be used by other clients).

Parameters:

all - if stateful sessions should be shut down such that other clients cannot reattach (the servant is cleaned up)

clientId - Only used if all is false.

holder - ServantHolder to be cleaned.

adapter - from which the servants should be removed.

internalServantConfig

protected void internalServantConfig(Object obj)
                              throws omero.ServerError

Throws:

omero.ServerError

newCurrent

public static Ice.Current newCurrent(Ice.Identity id,
                                     String method,
                                     Ice.ObjectAdapter adapter,
                                     String clientId)

newCurrent

public Ice.Current newCurrent(Ice.Identity id,
                              String method)

allow

public void allow(Ice.ObjectPrx prx)

createServantDelegate

protected Ice.Object createServantDelegate(String name)
                                    throws omero.ServerError

Creates a proxy according to the servant definition for the given name. Injects the instance for this session so that all services are linked to a single session. Creates an ome.api.* service (mostly managed by Spring), wraps it with the interceptors which are in effect, and stores the instance away in the cache. Note: Since HardWiredInterceptor implements MethodInterceptor, all the Advice instances will be wrapped in Advisor instances and will be returned by Advised.getAdvisors().

Throws:

omero.ServerError

configureServant

public void configureServant(Ice.Object servant)
                      throws omero.ServerError

Apply proper AOP and call setters for any known injection properties.

Parameters:

servant - the servant

Throws:

omero.ServerError - if the configuration or tying failed

registerServant

public Ice.ObjectPrx registerServant(Ice.Identity id,
                                     Ice.Object servant)
                              throws omero.ServerError

Registers the servant with the adapter (or throws an exception if one is already registered) as well as configures the servant in any post-Spring way necessary, based on the type of the servant.

Throws:

omero.ServerError

callContextWrapper

protected Ice.Object callContextWrapper(Ice.Object servant)

unregisterServant

public void unregisterServant(Ice.Identity id)

Calls unregisterServant(Ice.Identity, Ice.ObjectAdapter, ServantHolder)

unregisterServant

public static void unregisterServant(Ice.Identity id,
                                     Ice.ObjectAdapter adapter,
                                     ServantHolder holder)

Reverts all the additions made by registerServant(Ice.Identity, Ice.Object) Now called by SessionManagerI in response to an UnregisterServantMessage.

getIdentity

public Ice.Identity getIdentity(String name)

sessionId

public static Ice.Identity sessionId(String clientId,
                                     String uuid)

Definition of session ids: "session-<CLIENTID>/<UUID>"

sessionId

public Ice.Identity sessionId()

Returns the Identity for this instance as defined by sessionId(String, String)

clientId

public static String clientId(Ice.Current current)
                       throws omero.ApiUsageException

Helpers method to extract the CLIENTUUID out of the given Ice.Current. Throws an ApiUsageException if none is present, since it is each client's responsibility to set this value. (Typically done in our SDKs)

Throws:

omero.ApiUsageException

toString

public String toString()

Overrides:

toString in class Object