org.apache.yoko.orb.OB
Class GIOPConnectionThreaded
java.lang.Object
org.apache.yoko.orb.OB.GIOPConnection
org.apache.yoko.orb.OB.GIOPConnectionThreaded
- All Implemented Interfaces:
- DowncallEmitter, UpcallReturn
public final class GIOPConnectionThreaded
- extends GIOPConnection
Fields inherited from class org.apache.yoko.orb.OB.GIOPConnection |
acmTask_, acmTimer_, client_, codeConverters_, enabledOps_, giopVersion_, idleTimeout_, messageQueue_, oaInterface_, orbInstance_, properties_, shutdownTimeout_, state_, transport_, upcallsInProgress_ |
Methods inherited from class org.apache.yoko.orb.OB.GIOPConnection |
ACM_disableIdleMonitor, ACM_enableIdleMonitor, activateClientSide, activateServerSide, bidirConnection, canSendCloseConnection, destroy, destroyed, emitterInterface, logClose, processCloseConnection, processException, processFragment, processLocateReply, processLocateRequest, processMessage, processMessageError, processReply, processRequest, readCodeConverters, replySent, requestSent, sendUpcallReply, setOAInterface, setState, state, transport, upcallBeginReply, upcallBeginUserException, upcallEndReply, upcallEndUserException, upcallForward, upcallReturnInterface, upcallSystemException, upcallUserException |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
shutdownThread_
protected Thread shutdownThread_
receiverThreads_
protected LinkedList receiverThreads_
holdingMonitor_
protected Object holdingMonitor_
holding_
protected boolean holding_
sendMutex_
protected Object sendMutex_
GIOPConnectionThreaded
public GIOPConnectionThreaded(ORBInstance orbInstance,
Transport transport,
org.apache.yoko.orb.OB.GIOPClient client)
GIOPConnectionThreaded
public GIOPConnectionThreaded(ORBInstance orbInstance,
Transport transport,
OAInterface oa)
addReceiverThread
protected void addReceiverThread()
cleanupDeadReceiverThreads
protected void cleanupDeadReceiverThreads()
pauseThread
protected void pauseThread()
abortiveShutdown
protected void abortiveShutdown()
- Specified by:
abortiveShutdown
in class GIOPConnection
gracefulShutdown
protected void gracefulShutdown()
- Specified by:
gracefulShutdown
in class GIOPConnection
execShutdown
public void execShutdown()
execReceive
public void execReceive()
ACM_callback
public void ACM_callback()
- Specified by:
ACM_callback
in class GIOPConnection
send
public boolean send(Downcall down,
boolean block)
receive
public boolean receive(Downcall down,
boolean block)
sendReceive
public boolean sendReceive(Downcall down)
start
public void start()
- Specified by:
start
in class GIOPConnection
refresh
public void refresh()
- Specified by:
refresh
in class GIOPConnection
pause
public void pause()
- Specified by:
pause
in class GIOPConnection
enableConnectionModes
public void enableConnectionModes(boolean client,
boolean server)
- Specified by:
enableConnectionModes
in class GIOPConnection
Copyright © 2006-2011 Apache Software Foundation. All Rights Reserved.