public class HandleI extends java.lang.Object implements omero.cmd._HandleOperations, IHandle, SessionAware
Runnable
and is passed to a ThreadPool instance
Transitions: +------------------o [FINISHED] | o | | (CREATED) ---o READY o===o RUNNING o===o CANCELLING ---o [CANCELLED] | | o o | |---------------------------| | +--------------------------------------------------------+
修飾子とタイプ | クラスと説明 |
---|---|
static class |
HandleI.Cancel
|
コンストラクタと説明 |
---|
HandleI(int cancelTimeoutMs)
Create a
HandleI in the State#CREATED state with the
given cancel timeout in milliseconds. |
修飾子とタイプ | メソッドと説明 |
---|---|
void |
addCallback(omero.cmd.CmdCallbackPrx cb,
Ice.Current __current) |
boolean |
cancel(Ice.Current __current) |
void |
close(Ice.Current current) |
omero.cmd.Request |
getRequest(Ice.Current __current) |
omero.cmd.Response |
getResponse(Ice.Current __current) |
omero.cmd.Status |
getStatus(Ice.Current __current) |
void |
initialize(Ice.Identity id,
IRequest req,
java.util.Map<java.lang.String,java.lang.String> ctx)
Must be called on all instances exactly once before processing.
|
void |
notifyCallbacks()
Calls the proper notification on all callbacks based on the current
state . |
void |
removeCallback(omero.cmd.CmdCallbackPrx cb,
Ice.Current __current) |
void |
run()
NB: only executes if
state is State#CREATED . |
void |
setSession(SessionI session) |
java.util.List<java.lang.Object> |
steps(ome.util.SqlAction sql,
org.hibernate.Session session,
ome.system.ServiceFactory sf) |
public HandleI(int cancelTimeoutMs)
HandleI
in the State#CREATED
state with the
given cancel timeout in milliseconds.public void setSession(SessionI session) throws omero.ServerError
setSession
インタフェース内 SessionAware
omero.ServerError
public void initialize(Ice.Identity id, IRequest req, java.util.Map<java.lang.String,java.lang.String> ctx)
IHandle
initialize
インタフェース内 IHandle
id
- Ice identity of this instance. Cannot be null.req
- Request to be processed. Must also be an
Request
instance.ctx
- Possibly null call context which will be passed to
Executor.execute(Map, ome.system.Principal, ome.services.util.Executor.Work)
public void addCallback(omero.cmd.CmdCallbackPrx cb, Ice.Current __current)
addCallback
インタフェース内 omero.cmd._HandleOperations
public void removeCallback(omero.cmd.CmdCallbackPrx cb, Ice.Current __current)
removeCallback
インタフェース内 omero.cmd._HandleOperations
public void notifyCallbacks()
state
. If the State
is anything other than
State.CANCELLED
or State#FINISHED
then
CmdCallbackPrx.step(int, int)
is called.public omero.cmd.Request getRequest(Ice.Current __current)
getRequest
インタフェース内 omero.cmd._HandleOperations
public omero.cmd.Response getResponse(Ice.Current __current)
getResponse
インタフェース内 omero.cmd._HandleOperations
public omero.cmd.Status getStatus(Ice.Current __current)
getStatus
インタフェース内 omero.cmd._HandleOperations
public boolean cancel(Ice.Current __current) throws omero.LockTimeout
cancel
インタフェース内 omero.cmd._HandleOperations
omero.LockTimeout
public void close(Ice.Current current)
close
インタフェース内 omero.cmd._HandleOperations
close
インタフェース内 CloseableServant
public void run()
state
is State#CREATED
.run
インタフェース内 java.lang.Runnable
public java.util.List<java.lang.Object> steps(ome.util.SqlAction sql, org.hibernate.Session session, ome.system.ServiceFactory sf) throws HandleI.Cancel
HandleI.Cancel