org.apache.yoko.orb.OB
Class GIOPConnection
java.lang.Object
org.apache.yoko.orb.OB.GIOPConnection
- All Implemented Interfaces:
- DowncallEmitter, UpcallReturn
- Direct Known Subclasses:
- GIOPConnectionThreaded
public abstract class GIOPConnection
- extends Object
- implements DowncallEmitter, UpcallReturn
Method Summary |
protected abstract void |
abortiveShutdown()
|
abstract void |
ACM_callback()
|
protected void |
ACM_disableIdleMonitor()
|
protected void |
ACM_enableIdleMonitor()
|
void |
activateClientSide(org.apache.yoko.orb.OB.GIOPClient client)
|
void |
activateServerSide()
|
boolean |
bidirConnection()
|
protected boolean |
canSendCloseConnection()
|
void |
destroy(boolean terminateNow)
|
boolean |
destroyed()
|
DowncallEmitter |
emitterInterface()
|
abstract void |
enableConnectionModes(boolean enableClient,
boolean enableServer)
|
protected abstract void |
gracefulShutdown()
|
protected void |
logClose(boolean initiatedClosure)
|
abstract void |
pause()
|
protected void |
processCloseConnection(GIOPIncomingMessage msg)
|
protected boolean |
processException(int state,
SystemException ex,
boolean completed)
|
protected void |
processFragment(GIOPIncomingMessage msg)
|
protected void |
processLocateReply(GIOPIncomingMessage msg)
|
protected void |
processLocateRequest(GIOPIncomingMessage msg)
|
protected Upcall |
processMessage(GIOPIncomingMessage msg)
|
protected void |
processMessageError(GIOPIncomingMessage msg)
|
protected void |
processReply(GIOPIncomingMessage msg)
|
protected Upcall |
processRequest(GIOPIncomingMessage msg)
|
protected void |
readCodeConverters(ServiceContext[] scl)
|
abstract void |
refresh()
|
boolean |
replySent()
|
boolean |
requestSent()
|
protected void |
sendUpcallReply(Buffer buf)
|
protected boolean |
setOAInterface(ProfileInfo pi)
|
void |
setState(int newState)
|
abstract void |
start()
|
int |
state()
|
Transport |
transport()
|
void |
upcallBeginReply(Upcall upcall,
ServiceContext[] scl)
|
void |
upcallBeginUserException(Upcall upcall,
ServiceContext[] scl)
|
void |
upcallEndReply(Upcall upcall)
|
void |
upcallEndUserException(Upcall upcall)
|
void |
upcallForward(Upcall upcall,
IOR ior,
boolean perm,
ServiceContext[] scl)
|
UpcallReturn |
upcallReturnInterface()
|
void |
upcallSystemException(Upcall upcall,
SystemException ex,
ServiceContext[] scl)
|
void |
upcallUserException(Upcall upcall,
UserException ex,
ServiceContext[] scl)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
orbInstance_
protected ORBInstance orbInstance_
transport_
protected Transport transport_
client_
protected org.apache.yoko.orb.OB.GIOPClient client_
oaInterface_
protected OAInterface oaInterface_
messageQueue_
protected MessageQueue messageQueue_
enabledOps_
protected int enabledOps_
properties_
protected int properties_
state_
protected int state_
upcallsInProgress_
protected int upcallsInProgress_
codeConverters_
protected CodeConverters codeConverters_
giopVersion_
protected Version giopVersion_
shutdownTimeout_
protected int shutdownTimeout_
idleTimeout_
protected int idleTimeout_
acmTimer_
protected Timer acmTimer_
acmTask_
protected org.apache.yoko.orb.OB.GIOPConnection.ACMTask acmTask_
GIOPConnection
public GIOPConnection(ORBInstance orbInstance,
Transport transport,
org.apache.yoko.orb.OB.GIOPClient client)
GIOPConnection
public GIOPConnection(ORBInstance orbInstance,
Transport transport,
OAInterface oa)
canSendCloseConnection
protected boolean canSendCloseConnection()
readCodeConverters
protected void readCodeConverters(ServiceContext[] scl)
setOAInterface
protected boolean setOAInterface(ProfileInfo pi)
logClose
protected void logClose(boolean initiatedClosure)
processMessage
protected Upcall processMessage(GIOPIncomingMessage msg)
processRequest
protected Upcall processRequest(GIOPIncomingMessage msg)
processReply
protected void processReply(GIOPIncomingMessage msg)
processLocateRequest
protected void processLocateRequest(GIOPIncomingMessage msg)
processLocateReply
protected void processLocateReply(GIOPIncomingMessage msg)
processCloseConnection
protected void processCloseConnection(GIOPIncomingMessage msg)
processMessageError
protected void processMessageError(GIOPIncomingMessage msg)
processFragment
protected void processFragment(GIOPIncomingMessage msg)
processException
protected boolean processException(int state,
SystemException ex,
boolean completed)
sendUpcallReply
protected void sendUpcallReply(Buffer buf)
abortiveShutdown
protected abstract void abortiveShutdown()
gracefulShutdown
protected abstract void gracefulShutdown()
ACM_enableIdleMonitor
protected void ACM_enableIdleMonitor()
ACM_disableIdleMonitor
protected void ACM_disableIdleMonitor()
upcallBeginReply
public void upcallBeginReply(Upcall upcall,
ServiceContext[] scl)
- Specified by:
upcallBeginReply
in interface UpcallReturn
upcallEndReply
public void upcallEndReply(Upcall upcall)
- Specified by:
upcallEndReply
in interface UpcallReturn
upcallBeginUserException
public void upcallBeginUserException(Upcall upcall,
ServiceContext[] scl)
- Specified by:
upcallBeginUserException
in interface UpcallReturn
upcallEndUserException
public void upcallEndUserException(Upcall upcall)
- Specified by:
upcallEndUserException
in interface UpcallReturn
upcallUserException
public void upcallUserException(Upcall upcall,
UserException ex,
ServiceContext[] scl)
- Specified by:
upcallUserException
in interface UpcallReturn
upcallSystemException
public void upcallSystemException(Upcall upcall,
SystemException ex,
ServiceContext[] scl)
- Specified by:
upcallSystemException
in interface UpcallReturn
upcallForward
public void upcallForward(Upcall upcall,
IOR ior,
boolean perm,
ServiceContext[] scl)
- Specified by:
upcallForward
in interface UpcallReturn
activateClientSide
public void activateClientSide(org.apache.yoko.orb.OB.GIOPClient client)
activateServerSide
public void activateServerSide()
emitterInterface
public DowncallEmitter emitterInterface()
upcallReturnInterface
public UpcallReturn upcallReturnInterface()
transport
public Transport transport()
state
public int state()
requestSent
public boolean requestSent()
replySent
public boolean replySent()
destroyed
public boolean destroyed()
bidirConnection
public boolean bidirConnection()
setState
public void setState(int newState)
destroy
public void destroy(boolean terminateNow)
ACM_callback
public abstract void ACM_callback()
start
public abstract void start()
refresh
public abstract void refresh()
pause
public abstract void pause()
enableConnectionModes
public abstract void enableConnectionModes(boolean enableClient,
boolean enableServer)
Copyright © 2006-2011 Apache Software Foundation. All Rights Reserved.