|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.omg.CORBA.LocalObject
org.apache.yoko.orb.OCI.IIOP.Transport_impl
public final class Transport_impl
Field Summary | |
---|---|
Socket |
socket_
|
Constructor Summary | |
---|---|
Transport_impl(Acceptor acceptor,
Socket socket,
ListenerMap lm)
|
|
Transport_impl(Connector connector,
Socket socket,
ListenerMap lm)
|
Method Summary | |
---|---|
void |
close()
Closes the Transport. |
void |
finalize()
|
TransportInfo |
get_info()
Returns the information object associated with the Transport. |
int |
handle()
The "handle" for this Transport. |
String |
id()
The plugin id. |
SendReceiveMode |
mode()
The send/receive capabilities of this Transport. |
boolean |
receive_detect(Buffer buf,
boolean block)
Similar to receive , but it signals a connection
loss by returning FALSE instead of raising
COMM_FAILURE . |
boolean |
receive_timeout_detect(Buffer buf,
int t)
Similar to receive_timeout , but it signals a
connection loss by returning FALSE instead of
raising COMM_FAILURE . |
void |
receive_timeout(Buffer buf,
int t)
Similar to receive , but it is
possible to specify a timeout. |
void |
receive(Buffer buf,
boolean block)
Receives a buffer's contents. |
boolean |
send_detect(Buffer buf,
boolean block)
Similar to send , but it signals a connection loss
by returning FALSE instead of raising
COMM_FAILURE . |
boolean |
send_timeout_detect(Buffer buf,
int t)
Similar to send_timeout , but it signals a
connection loss by returning FALSE instead of
raising COMM_FAILURE . |
void |
send_timeout(Buffer buf,
int t)
Similar to send , but it is possible
to specify a timeout. |
void |
send(Buffer buf,
boolean block)
Sends a buffer's contents. |
void |
shutdown()
Shutdown the Transport. |
int |
tag()
The profile id tag. |
String |
toString()
|
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, wait, wait, wait |
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 |
---|
public Socket socket_
Constructor Detail |
---|
public Transport_impl(Connector connector, Socket socket, ListenerMap lm)
public Transport_impl(Acceptor acceptor, Socket socket, ListenerMap lm)
Method Detail |
---|
public String id()
TransportOperations
id
in interface TransportOperations
public int tag()
TransportOperations
tag
in interface TransportOperations
public SendReceiveMode mode()
TransportOperations
mode
in interface TransportOperations
public int handle()
TransportOperations
select()
on
Unix-based operating systems. All other uses (e.g., calls to
read()
, write()
,
close()
) are strictly non-compliant. A handle
value of -1 indicates that the protocol plug-in does not
support "selectable" Transports.
handle
in interface TransportOperations
public void close()
TransportOperations
close
, no
operations on this Transport object and its associated
TransportInfo object may be called. To ensure that no messages
get lost when close
is called,
shutdown
should be called first. Then dummy data
should be read from the Transport, using one of the
receive
operations, until either an exception is
raised, or until connection closure is detected. After that its
save to call close
, i.e., no messages can get
lost.
close
in interface TransportOperations
public void shutdown()
TransportOperations
receive
operations will return or
throw an exception. After calling shutdown
, no
operations on associated TransportInfo object may be called. To
fully close the Transport, close
must be called.
shutdown
in interface TransportOperations
public void receive(Buffer buf, boolean block)
TransportOperations
receive
in interface TransportOperations
buf
- The buffer to fill.block
- If set to TRUE
, the operation blocks
until the buffer is full. If set to FALSE
, the
operation fills as much of the buffer as possible without
blocking.public boolean receive_detect(Buffer buf, boolean block)
TransportOperations
receive
, but it signals a connection
loss by returning FALSE
instead of raising
COMM_FAILURE
.
receive_detect
in interface TransportOperations
buf
- The buffer to fill.block
- If set to TRUE
, the operation blocks
until the buffer is full. If set to FALSE
, the
operation fills as much of the buffer as possible without
blocking.
FALSE
if a connection loss is
detected, TRUE
otherwise.public void receive_timeout(Buffer buf, int t)
TransportOperations
receive
, but it is
possible to specify a timeout. On return the caller can test
whether there was a timeout by checking if the buffer has
been filled completely.
receive_timeout
in interface TransportOperations
buf
- The buffer to fill.t
- The timeout value in milliseconds. A zero
timeout is equivalent to calling receive(buf, FALSE)
.public boolean receive_timeout_detect(Buffer buf, int t)
TransportOperations
receive_timeout
, but it signals a
connection loss by returning FALSE
instead of
raising COMM_FAILURE
.
receive_timeout_detect
in interface TransportOperations
buf
- The buffer to fill.t
- The timeout value in milliseconds. A zero
timeout is equivalent to calling receive(buf, FALSE)
.
FALSE
if a connection loss is
detected, TRUE
otherwise.public void send(Buffer buf, boolean block)
TransportOperations
send
in interface TransportOperations
buf
- The buffer to send.block
- If set to TRUE
, the operation blocks
until the buffer has completely been sent. If set to
FALSE
, the operation sends as much of the buffer's
data as possible without blocking.public boolean send_detect(Buffer buf, boolean block)
TransportOperations
send
, but it signals a connection loss
by returning FALSE
instead of raising
COMM_FAILURE
.
send_detect
in interface TransportOperations
buf
- The buffer to fill.block
- If set to TRUE
, the operation blocks
until the entire buffer has been sent. If set to
FALSE
, the operation sends as much of the buffer's
data as possible without blocking.
FALSE
if a connection loss is
detected, TRUE
otherwise.public void send_timeout(Buffer buf, int t)
TransportOperations
send
, but it is possible
to specify a timeout. On return the caller can test whether
there was a timeout by checking if the buffer has
been sent completely.
send_timeout
in interface TransportOperations
buf
- The buffer to send.t
- The timeout value in milliseconds. A zero
timeout is equivalent to calling send(buf, FALSE)
.public boolean send_timeout_detect(Buffer buf, int t)
TransportOperations
send_timeout
, but it signals a
connection loss by returning FALSE
instead of
raising COMM_FAILURE
.
send_timeout_detect
in interface TransportOperations
buf
- The buffer to fill.t
- The timeout value in milliseconds. A zero
timeout is equivalent to calling send(buf, FALSE)
.
FALSE
if a connection loss is
detected, TRUE
otherwise.public TransportInfo get_info()
TransportOperations
get_info
in interface TransportOperations
public void finalize() throws Throwable
finalize
in class Object
Throwable
public String toString()
toString
in class Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |