org.jacorb.orb.giop

Class GIOPConnection

Known Direct Subclasses:
ClientGIOPConnection, ServerGIOPConnection

public abstract class GIOPConnection
extends java.io.OutputStream

GIOPConnection.java Created: Sun Aug 12 21:30:48 2002

Version:
$Id: GIOPConnection.java,v 1.46 2004/05/06 12:40:00 nicolas Exp $

Author:
Nicolas Noffke

Field Summary

protected Object
connect_sync
protected ConnectionListener
connection_listener
protected boolean
discard_messages
protected boolean
do_close
protected Object
pendingUndecidedSync
protected Profile
profile
protected StatisticsProvider
statistics_provider
protected Connection
transport

Constructor Summary

GIOPConnection(Profile profile, Connection transport, RequestListener request_listener, ReplyListener reply_listener, StatisticsProvider statistics_provider)

Method Summary

static int
allocate_cubby_id()
void
close()
void
configure(Configuration configuration)
void
decPendingMessages()
void
flush()
protected RequestListener
getRequestListener()
Get the value of request_listener.
StatisticsProvider
getStatisticsProvider()
Get the statistics provider for transport usage statistics.
int
getTCS()
int
getTCSW()
Connection
getTransport()
protected void
getWriteLock()
Object
get_cubby(int id)
boolean
hasPendingMessages()
void
incPendingMessages()
boolean
isSSL()
boolean
isTCSNegotiated()
void
markTCSNegotiated()
protected void
readTimedOut()
void
receiveMessages()
protected void
releaseWriteLock()
void
sendReply(MessageOutputStream out)
void
sendRequest(MessageOutputStream out, boolean expect_reply)
void
setCodeSets(int TCS, int TCSW)
void
setConnectionListener(ConnectionListener connection_listener)
void
setReplyListener(ReplyListener v)
Set the value of reply_listener.
void
setRequestListener(RequestListener v)
Set the value of request_listener.
void
set_cubby(int id, Object obj)
protected void
streamClosed()
void
write(byte[] b)
void
write(byte[] fragment, int start, int size)
write (a fragment of) the message (passes it on to the wire)
void
write(int i)

Field Details

connect_sync

protected Object connect_sync


connection_listener

protected ConnectionListener connection_listener


discard_messages

protected boolean discard_messages


do_close

protected boolean do_close


pendingUndecidedSync

protected Object pendingUndecidedSync


profile

protected Profile profile


statistics_provider

protected StatisticsProvider statistics_provider


transport

protected Connection transport

Constructor Details

GIOPConnection

public GIOPConnection(Profile profile,
                      Connection transport,
                      RequestListener request_listener,
                      ReplyListener reply_listener,
                      StatisticsProvider statistics_provider)

Method Details

allocate_cubby_id

public static int allocate_cubby_id()


close

public void close()


configure

public void configure(Configuration configuration)
            throws ConfigurationException


decPendingMessages

public final void decPendingMessages()


flush

public final void flush()
            throws java.io.IOException


getRequestListener

protected final RequestListener getRequestListener()
Get the value of request_listener.

Returns:
value of request_listener.


getStatisticsProvider

public final StatisticsProvider getStatisticsProvider()
Get the statistics provider for transport usage statistics.


getTCS

public final int getTCS()


getTCSW

public final int getTCSW()


getTransport

public final Connection getTransport()


getWriteLock

protected final void getWriteLock()


get_cubby

public Object get_cubby(int id)


hasPendingMessages

public final boolean hasPendingMessages()


incPendingMessages

public final void incPendingMessages()


isSSL

public final boolean isSSL()


isTCSNegotiated

public final boolean isTCSNegotiated()


markTCSNegotiated

public final void markTCSNegotiated()


readTimedOut

protected void readTimedOut()


receiveMessages

public final void receiveMessages()
            throws IOException


releaseWriteLock

protected final void releaseWriteLock()


sendReply

public final void sendReply(MessageOutputStream out)
            throws IOException


sendRequest

public final void sendRequest(MessageOutputStream out,
                              boolean expect_reply)
            throws IOException


setCodeSets

public final void setCodeSets(int TCS,
                              int TCSW)


setConnectionListener

public final void setConnectionListener(ConnectionListener connection_listener)


setReplyListener

public final void setReplyListener(ReplyListener v)
Set the value of reply_listener.

Parameters:
v - Value to assign to reply_listener.


setRequestListener

public final void setRequestListener(RequestListener v)
Set the value of request_listener.

Parameters:
v - Value to assign to request_listener.


set_cubby

public void set_cubby(int id,
                      Object obj)


streamClosed

protected void streamClosed()


write

public final void write(byte[] b)
            throws java.io.IOException


write

public final void write(byte[] fragment,
                        int start,
                        int size)
write (a fragment of) the message (passes it on to the wire)


write

public final void write(int i)
            throws java.io.IOException