org.apache.yoko.orb.OB
Class GIOPConnectionThreaded

java.lang.Object
  extended by org.apache.yoko.orb.OB.GIOPConnection
      extended by org.apache.yoko.orb.OB.GIOPConnectionThreaded
All Implemented Interfaces:
DowncallEmitter, UpcallReturn

public final class GIOPConnectionThreaded
extends GIOPConnection


Nested Class Summary
 class GIOPConnectionThreaded.ReceiverThread
           
 class GIOPConnectionThreaded.ShutdownThread
           
 
Nested classes/interfaces inherited from class org.apache.yoko.orb.OB.GIOPConnection
GIOPConnection.AccessOp, GIOPConnection.Property, GIOPConnection.State
 
Field Summary
protected  boolean holding_
           
protected  Object holdingMonitor_
           
protected  LinkedList receiverThreads_
           
protected  Object sendMutex_
           
protected  Thread shutdownThread_
           
 
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_
 
Constructor Summary
GIOPConnectionThreaded(ORBInstance orbInstance, Transport transport, org.apache.yoko.orb.OB.GIOPClient client)
           
GIOPConnectionThreaded(ORBInstance orbInstance, Transport transport, OAInterface oa)
           
 
Method Summary
protected  void abortiveShutdown()
           
 void ACM_callback()
           
protected  void addReceiverThread()
           
protected  void cleanupDeadReceiverThreads()
           
 void enableConnectionModes(boolean client, boolean server)
           
 void execReceive()
           
 void execShutdown()
           
protected  void gracefulShutdown()
           
 void pause()
           
protected  void pauseThread()
           
 boolean receive(Downcall down, boolean block)
           
 void refresh()
           
 boolean send(Downcall down, boolean block)
           
 boolean sendReceive(Downcall down)
           
 void start()
           
 
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
 

Field Detail

shutdownThread_

protected Thread shutdownThread_

receiverThreads_

protected LinkedList receiverThreads_

holdingMonitor_

protected Object holdingMonitor_

holding_

protected boolean holding_

sendMutex_

protected Object sendMutex_
Constructor Detail

GIOPConnectionThreaded

public GIOPConnectionThreaded(ORBInstance orbInstance,
                              Transport transport,
                              org.apache.yoko.orb.OB.GIOPClient client)

GIOPConnectionThreaded

public GIOPConnectionThreaded(ORBInstance orbInstance,
                              Transport transport,
                              OAInterface oa)
Method Detail

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.