org.jacorb.orb.etf
Class StreamConnectionBase

java.lang.Object
  extended byorg.omg.CORBA.LocalObject
      extended byorg.omg.ETF._ConnectionLocalBase
          extended byorg.jacorb.orb.etf.ConnectionBase
              extended byorg.jacorb.orb.etf.StreamConnectionBase
All Implemented Interfaces:
org.apache.avalon.framework.configuration.Configurable, Connection, ConnectionOperations, IDLEntity, LocalInterface, Object, java.io.Serializable
Direct Known Subclasses:
IIOPConnection, IIOPLoopbackConnection

public abstract class StreamConnectionBase
extends ConnectionBase

This an abstract base implementation of the ETF::Connection interface.

Version:
$Id: StreamConnectionBase.java,v 1.3 2005/10/21 21:06:25 alphonse.bendt Exp $
Author:
Nicolas Noffke / Andre Spiegel
See Also:
Serialized Form

Field Summary
protected  java.io.InputStream in_stream
          Reads performed on this stream.
protected  java.io.OutputStream out_stream
          Writes performed on this stream.
 
Fields inherited from class org.jacorb.orb.etf.ConnectionBase
b_out, configuration, connected, connection_info, finalTimeout, logger, profile
 
Constructor Summary
protected StreamConnectionBase()
           
protected StreamConnectionBase(StreamConnectionBase other)
          Initialise this instance as a copy of another.
 
Method Summary
 void flush()
           
 boolean is_data_available()
          Simply return true if calling a read on this instance would find data in the connection.
 void read(BufferHolder data, int offset, int min_length, int max_length, long time_out)
          read actual messages
 void write(boolean is_first, boolean is_last, byte[] data, int offset, int length, long time_out)
           
 
Methods inherited from class org.jacorb.orb.etf.ConnectionBase
configure, get_server_profile, getTimeout, is_connected, setTimeout, supports_callback, to_COMM_FAILURE, turnOnFinalTimeout, use_handle_time_out, wait_next_data
 
Methods inherited from class org.omg.ETF._ConnectionLocalBase
_ids
 
Methods inherited from class org.omg.CORBA.LocalObject
_create_request, _create_request, _duplicate, _get_domain_managers, _get_interface_def, _get_interface, _get_policy, _hash, _invoke, _is_a, _is_equivalent, _is_local, _non_existent, _orb, _release, _releaseReply, _request, _request, _servant_postinvoke, _servant_preinvoke, _set_policy_override, validate_connection
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.omg.ETF.ConnectionOperations
close, connect
 
Methods inherited from interface org.omg.CORBA.Object
_create_request, _create_request, _duplicate, _get_domain_managers, _get_interface_def, _get_interface, _get_policy, _hash, _is_a, _is_equivalent, _non_existent, _release, _request, _set_policy_override
 

Field Detail

in_stream

protected java.io.InputStream in_stream
Reads performed on this stream.


out_stream

protected java.io.OutputStream out_stream
Writes performed on this stream.

Constructor Detail

StreamConnectionBase

protected StreamConnectionBase()

StreamConnectionBase

protected StreamConnectionBase(StreamConnectionBase other)
Initialise this instance as a copy of another. Intended for use within subclass constructors.

Method Detail

read

public void read(BufferHolder data,
                 int offset,
                 int min_length,
                 int max_length,
                 long time_out)
read actual messages


write

public void write(boolean is_first,
                  boolean is_last,
                  byte[] data,
                  int offset,
                  int length,
                  long time_out)

flush

public void flush()

is_data_available

public boolean is_data_available()
Simply return true if calling a read on this instance would find data in the connection. Otherwise, the function shall return false.