org.jacorb.orb.iiop
Class IIOPConnection

java.lang.Object
  extended byorg.omg.CORBA.LocalObject
      extended byorg.omg.ETF._ConnectionLocalBase
          extended byorg.jacorb.orb.iiop.IIOPConnection
All Implemented Interfaces:
Connection, ConnectionOperations, IDLEntity, LocalInterface, Object, java.io.Serializable
Direct Known Subclasses:
ClientIIOPConnection, ServerIIOPConnection

public abstract class IIOPConnection
extends _ConnectionLocalBase

IIOPConnection.java Created: Sun Aug 12 20:18:47 2002

Version:
$Id: IIOPConnection.java,v 1.5 2004/02/05 15:57:12 nick.cross Exp $
Author:
Nicolas Noffke / Andre Spiegel
See Also:
Serialized Form

Field Summary
protected  boolean connected
           
protected  java.lang.String connection_info
           
protected  java.io.InputStream in_stream
           
protected  java.io.OutputStream out_stream
           
protected  java.net.Socket socket
           
 
Constructor Summary
IIOPConnection()
           
IIOPConnection(IIOPConnection other)
           
 
Method Summary
 void flush()
           
 boolean is_connected()
           
 boolean is_data_available()
          Simply return true if calling a read on this instance would find data in the connection.
abstract  boolean isSSL()
           
 void read(BufferHolder data, int offset, int min_length, int max_length, long time_out)
          read actual messages
 boolean supports_callback()
          A boolean flag describing whether this connection supports the Bidirectional GIOP mechanism as described by GIOP-1.2 in CORBA 2.3.1 (OMG Document: formal/99-10-07).
protected  COMM_FAILURE to_COMM_FAILURE(java.io.IOException ex)
           
 void turnOnFinalTimeout()
          This is used to tell the transport that a CloseConnection has been sent, and that it should set a timeout in case the client doesn't close its side of the connection right away.
 boolean use_handle_time_out()
          A flag directing the ORB to use either the Handle class to perform data queries with a time_out, or the transport layer (through this connection).
 boolean wait_next_data(long time_out)
          Wait for the given time_out period for incoming data on this connection.
 void write(boolean is_first, boolean is_last, byte[] data, int offset, int length, long time_out)
           
 
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, get_server_profile
 
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

connected

protected boolean connected

in_stream

protected java.io.InputStream in_stream

out_stream

protected java.io.OutputStream out_stream

connection_info

protected java.lang.String connection_info

socket

protected java.net.Socket socket
Constructor Detail

IIOPConnection

public IIOPConnection(IIOPConnection other)

IIOPConnection

public IIOPConnection()
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_connected

public boolean is_connected()

turnOnFinalTimeout

public void turnOnFinalTimeout()
This is used to tell the transport that a CloseConnection has been sent, and that it should set a timeout in case the client doesn't close its side of the connection right away. This should only be called on the thread that listens on the socket because timeouts are not applied until read() is called the next time.


isSSL

public abstract boolean isSSL()

to_COMM_FAILURE

protected COMM_FAILURE to_COMM_FAILURE(java.io.IOException ex)

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.


wait_next_data

public boolean wait_next_data(long time_out)
Wait for the given time_out period for incoming data on this connection. It shall return false if this call times out and no data is available. It may not throw a TIMEOUT exception. If data can already be read or arrives before the end of the time out, this function shall return true, immediately.


supports_callback

public boolean supports_callback()
A boolean flag describing whether this connection supports the Bidirectional GIOP mechanism as described by GIOP-1.2 in CORBA 2.3.1 (OMG Document: formal/99-10-07). It shall return true if it does, and false if it does not.


use_handle_time_out

public boolean use_handle_time_out()
A flag directing the ORB to use either the Handle class to perform data queries with a time_out, or the transport layer (through this connection). The instance shall return true, if the Handle should signal time outs for read operations. Then the ORB may not call wait_next_data. Otherwise, a false shall be returned, and the function wait_next_data shall be implemented by this class.