|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--com.ibm.ulc.comm.UlcTransport
An abstraction for ULC transports.
UlcConnection
, Serialized FormField Summary | |
protected UlcConnection |
fConnection
|
static boolean |
fgDebug
|
protected boolean |
fTerminated
|
protected UnboundedBuffer |
fWriterQueue
|
Constructor Summary | |
protected |
UlcTransport()
UlcTransport constructor |
|
UlcTransport(java.lang.String urlString)
UlcTransport constructor |
Method Summary | |
void |
close()
|
static UlcTransport |
create(java.lang.String urlString)
The factory method to create a concrete transport depending on the protocol specified in the URL. |
protected void |
flushWriter()
During the shutdown of the connection any pending requests in tbe output queue should be flushed before the connection is taken down. |
UlcConnection |
getConnection()
|
java.lang.String |
getHost()
|
abstract java.lang.String |
getLocalUrlString()
Return an URL String describing this transports local endpoint. |
int |
getPort()
|
static java.util.Properties |
getProperties()
|
java.lang.String |
getRemoteUrlString()
Return an URL String describing this transports remote endpoint. |
java.lang.String |
getUrlFile()
|
java.lang.String |
getUrlString()
Return an URL String describing this transport's remote endpoint. |
protected abstract void |
initPeerConnection()
Method to perform connection initialization with peer. |
protected void |
readRequests()
Read loop. |
abstract boolean |
readsAsynch()
Does the transport asynchronous reads itself? Otherwise it inherits the automatic asynchronous read support of this class by overriding readRequests(). |
void |
receive(Request r)
|
void |
send(Request r)
Sends a request. |
protected abstract void |
sendDirect(Request r,
boolean flush)
Sends a request directly (without using WriterThread) |
void |
setConnection(UlcConnection connection)
|
protected void |
setUrlString(java.lang.String urlString)
|
void |
start()
|
protected abstract void |
termPeerConnection()
Method to perform connection termination with peer. |
protected void |
writeRequests()
Write loop. |
abstract 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 java.lang.Object |
clone,
equals,
finalize,
getClass,
hashCode,
notify,
notifyAll,
toString,
wait,
wait,
wait |
Field Detail |
public static boolean fgDebug
protected UlcConnection fConnection
protected UnboundedBuffer fWriterQueue
protected boolean fTerminated
Constructor Detail |
protected UlcTransport()
public UlcTransport(java.lang.String urlString)
urlString
- java.lang.StringMethod Detail |
public void close()
public static UlcTransport create(java.lang.String urlString) throws UlcTransportException
urlString
- java.lang.Stringprotected void flushWriter()
public UlcConnection getConnection()
public java.lang.String getHost()
public abstract java.lang.String getLocalUrlString()
public int getPort()
public static java.util.Properties getProperties()
public java.lang.String getRemoteUrlString()
public java.lang.String getUrlFile()
public java.lang.String getUrlString()
protected abstract void initPeerConnection() throws UlcTransportException
protected void readRequests()
public abstract boolean readsAsynch()
public final void receive(Request r)
public final void send(Request r)
protected abstract void sendDirect(Request r, boolean flush)
public void setConnection(UlcConnection connection)
protected void setUrlString(java.lang.String urlString)
public final void start() throws UlcTransportException
protected abstract void termPeerConnection()
protected void writeRequests()
public abstract boolean writesAsynch()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |