com.ibm.ulc.corba
Class UlcCorbaBasedTransport

java.lang.Object
  |
  +--com.ibm.ulc.comm.UlcTransport
        |
        +--com.ibm.ulc.corba.UlcCorbaBasedTransport
Direct Known Subclasses:
UlcCorbaTransport

public class UlcCorbaBasedTransport
extends UlcTransport

An implemention for ULC transports using CORBA.

See Also:
UlcTransport, Serialized Form

Field Summary
 UlcCorbaServant fReceiver
           
 java.lang.String fReceiverIOR
           
 com.ibm.ulc.corba.generated.UlcCorbaObject fSender
           
 
Fields inherited from class com.ibm.ulc.comm.UlcTransport
fConnection, fgDebug, fTerminated, fWriterQueue
 
Constructor Summary
UlcCorbaBasedTransport()
          UlcCorbaTransport constructor.
UlcCorbaBasedTransport(java.lang.String urlString)
          UlcCorbaTransport constructor.
UlcCorbaBasedTransport(com.ibm.ulc.corba.generated.UlcCorbaObject sender, UlcCorbaServant receiver, java.lang.String receiverIOR)
          UlcCorbaTransport constructor.
 
Method Summary
 java.lang.String getLocalUrlString()
          Return an URL String describing this transports local endpoint.
static org.omg.CORBA.ORB getOrb()
           
protected  void initPeerConnection()
          Initialize connection to peer if necessary.
 boolean readsAsynch()
          Does the transport asynchronous reads itself? Otherwise it inherits the automatic asynchronous read support of this class by overriding readRequests().
protected  void sendDirect(Request r, boolean flush)
          Sends a request directly (without using WriterThread)
 UlcCorbaServant startReceiver()
           
 com.ibm.ulc.corba.generated.UlcCorbaObject startSender()
           
 void stopReceiver()
           
 void stopSender()
           
protected  void termPeerConnection()
          Method to perform connection termination with peer.
 boolean writesAsynch()
          Does the transport asynchronous writes itself? Otherwise it inherits the automatic asynchronous write support of this class by overriding writeRequests().
 
Methods inherited from class com.ibm.ulc.comm.UlcTransport
close, create, flushWriter, getConnection, getHost, getPort, getProperties, getRemoteUrlString, getUrlFile, getUrlString, readRequests, receive, send, setConnection, setUrlString, start, writeRequests
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

fReceiver

public UlcCorbaServant fReceiver

fSender

public com.ibm.ulc.corba.generated.UlcCorbaObject fSender

fReceiverIOR

public java.lang.String fReceiverIOR
Constructor Detail

UlcCorbaBasedTransport

public UlcCorbaBasedTransport()
UlcCorbaTransport constructor.

UlcCorbaBasedTransport

public UlcCorbaBasedTransport(com.ibm.ulc.corba.generated.UlcCorbaObject sender,
                              UlcCorbaServant receiver,
                              java.lang.String receiverIOR)
UlcCorbaTransport constructor. Will use the passed in Corba client object.
Parameters:
sender - com.ibm.ulc.corba.UlcCorbaObject
receiver - com.ibm.ulc.corba.UlcCorbaServant
receiverIOR - java.lang.String

UlcCorbaBasedTransport

public UlcCorbaBasedTransport(java.lang.String urlString)
UlcCorbaTransport constructor. Will use the passed in URL to create a connection to a Corba servant object.
Parameters:
urlString - java.lang.String
Method Detail

getLocalUrlString

public java.lang.String getLocalUrlString()
Description copied from class: UlcTransport
Return an URL String describing this transports local endpoint.
Overrides:
getLocalUrlString in class UlcTransport

getOrb

public static org.omg.CORBA.ORB getOrb()

initPeerConnection

protected void initPeerConnection()
                           throws UlcTransportException
Initialize connection to peer if necessary.
Overrides:
initPeerConnection in class UlcTransport

readsAsynch

public boolean readsAsynch()
Description copied from class: UlcTransport
Does the transport asynchronous reads itself? Otherwise it inherits the automatic asynchronous read support of this class by overriding readRequests().
Overrides:
readsAsynch in class UlcTransport

sendDirect

protected void sendDirect(Request r,
                          boolean flush)
Description copied from class: UlcTransport
Sends a request directly (without using WriterThread)
Overrides:
sendDirect in class UlcTransport

startReceiver

public UlcCorbaServant startReceiver()
                              throws UlcTransportException

startSender

public com.ibm.ulc.corba.generated.UlcCorbaObject startSender()
                                                       throws UlcTransportException

stopReceiver

public void stopReceiver()

stopSender

public void stopSender()

termPeerConnection

protected void termPeerConnection()
Description copied from class: UlcTransport
Method to perform connection termination with peer.
Overrides:
termPeerConnection in class UlcTransport

writesAsynch

public boolean writesAsynch()
Description copied from class: UlcTransport
Does the transport asynchronous writes itself? Otherwise it inherits the automatic asynchronous write support of this class by overriding writeRequests().
Overrides:
writesAsynch in class UlcTransport