org.apache.yoko.orb.OB
Class GIOPConnection

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

public abstract class GIOPConnection
extends Object
implements DowncallEmitter, UpcallReturn


Nested Class Summary
static class GIOPConnection.AccessOp
           
static class GIOPConnection.Property
           
static class GIOPConnection.State
           
 
Field Summary
protected  org.apache.yoko.orb.OB.GIOPConnection.ACMTask acmTask_
           
protected  Timer acmTimer_
           
protected  org.apache.yoko.orb.OB.GIOPClient client_
           
protected  CodeConverters codeConverters_
           
protected  int enabledOps_
           
protected  Version giopVersion_
           
protected  int idleTimeout_
           
protected  MessageQueue messageQueue_
           
protected  OAInterface oaInterface_
           
protected  ORBInstance orbInstance_
           
protected  int properties_
           
protected  int shutdownTimeout_
           
protected  int state_
           
protected  Transport transport_
           
protected  int upcallsInProgress_
           
 
Constructor Summary
GIOPConnection(ORBInstance orbInstance, Transport transport, org.apache.yoko.orb.OB.GIOPClient client)
           
GIOPConnection(ORBInstance orbInstance, Transport transport, OAInterface oa)
           
 
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
 
Methods inherited from interface org.apache.yoko.orb.OB.DowncallEmitter
receive, send, sendReceive
 

Field Detail

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_
Constructor Detail

GIOPConnection

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

GIOPConnection

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

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.