quamj.qps.plugins.oci_diffiop
Class Transport_impl

java.lang.Object
  |
  +--org.omg.CORBA.LocalObject
        |
        +--quamj.qps.plugins.oci_diffiop.Transport_impl

All Implemented Interfaces:

org.omg.CORBA.Object

public class Transport_impl

extends org.omg.CORBA.LocalObject

Field Summary

protected java.net.Socket

socket_

Constructor Summary

Transport_impl(com.ooc.OCI.Acceptor acceptor, java.net.Socket socket, org.omg.CORBA.ORB orb)

Transport_impl(com.ooc.OCI.Connector connector, java.net.Socket socket)

Method Summary

void	addTrafficListener(quamj.qps.control.SensorCollector sensor_listener)
void	close()
void	finalize()
com.ooc.OCI.TransportInfo	get_info()
java.lang.String	getLocalAddress()
int	getLocalPort()
java.lang.String	getRemoteAddress()
int	getRemotePort()
com.ooc.OCI.Connector	getRsvpConnector()
int	handle()
java.lang.String	id()
com.ooc.OCI.SendReceiveMode	mode()
boolean	receive_detect(com.ooc.OCI.Buffer buf, boolean block)
boolean	receive_timeout_detect(com.ooc.OCI.Buffer buf, int t)
void	receive_timeout(com.ooc.OCI.Buffer buf, int t)
void	receive(com.ooc.OCI.Buffer buf, boolean block)
void	removeTrafficListener()
boolean	send_detect(com.ooc.OCI.Buffer buf, boolean block)
boolean	send_timeout_detect(com.ooc.OCI.Buffer buf, int t)
void	send_timeout(com.ooc.OCI.Buffer buf, int t)
void	send(com.ooc.OCI.Buffer buf, boolean block)
void	shutdown()
int	tag()

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, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

socket_

protected java.net.Socket socket_

Constructor Detail

Transport_impl

public Transport_impl(com.ooc.OCI.Connector connector,
                      java.net.Socket socket)

Transport_impl

public Transport_impl(com.ooc.OCI.Acceptor acceptor,
                      java.net.Socket socket,
                      org.omg.CORBA.ORB orb)

Method Detail

id

public java.lang.String id()

tag

public int tag()

mode

public com.ooc.OCI.SendReceiveMode mode()

handle

public int handle()

get_info

public com.ooc.OCI.TransportInfo get_info()

close

public void close()

shutdown

public void shutdown()

receive

public void receive(com.ooc.OCI.Buffer buf,
                    boolean block)

receive_detect

public boolean receive_detect(com.ooc.OCI.Buffer buf,
                              boolean block)

receive_timeout

public void receive_timeout(com.ooc.OCI.Buffer buf,
                            int t)

receive_timeout_detect

public boolean receive_timeout_detect(com.ooc.OCI.Buffer buf,
                                      int t)

send

public void send(com.ooc.OCI.Buffer buf,
                 boolean block)

send_detect

public boolean send_detect(com.ooc.OCI.Buffer buf,
                           boolean block)

send_timeout

public void send_timeout(com.ooc.OCI.Buffer buf,
                         int t)

send_timeout_detect

public boolean send_timeout_detect(com.ooc.OCI.Buffer buf,
                                   int t)

getRsvpConnector

public com.ooc.OCI.Connector getRsvpConnector()

getLocalAddress

public java.lang.String getLocalAddress()

getLocalPort

public int getLocalPort()

getRemoteAddress

public java.lang.String getRemoteAddress()

getRemotePort

public int getRemotePort()

addTrafficListener

public void addTrafficListener(quamj.qps.control.SensorCollector sensor_listener)

removeTrafficListener

public void removeTrafficListener()

finalize

public void finalize()
              throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

java.lang.Throwable