public class ServerMIOPConnection extends MIOPConnection implements Runnable
MIOPListener
,
Serialized Formin_stream, out_stream
b_out, configuration, connected, connection_info, finalTimeout, logger, orb, profile
Constructor and Description |
---|
ServerMIOPConnection()
Creates a new server MIOP connection that listen to the specified group.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close this connection.
|
void |
configure(Configuration config) |
void |
connect(org.omg.ETF.Profile profile,
long time_out)
Connect the socket.
|
protected int |
getTimeout() |
boolean |
is_data_available()
Tests if there is data available on this connection.
|
int |
read(org.omg.ETF.BufferHolder buffer,
int offset,
int minLength,
int maxLength,
long timeout)
Read data from the connection.
|
void |
run()
Run method.
|
protected void |
setTimeout(int timeout) |
boolean |
wait_next_data(long timeout)
Wait until there is some complete message ready data to be read from
connection.
|
handleCommFailure, isSSL, supports_callback
flush, silentClose, write
get_server_profile, getLocalhost, is_connected, to_COMM_FAILURE, turnOnFinalTimeout, use_handle_time_out
_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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
_create_request, _create_request, _duplicate, _get_domain_managers, _get_interface_def, _get_policy, _hash, _is_a, _is_equivalent, _non_existent, _release, _request, _set_policy_override
public ServerMIOPConnection()
public void connect(org.omg.ETF.Profile profile, long time_out)
connect
in interface org.omg.ETF.ConnectionOperations
profile
- time_out
- unused, we use SO_TIMEOUTpublic boolean is_data_available()
is_data_available
in interface org.omg.ETF.ConnectionOperations
is_data_available
in class MIOPConnection
public boolean wait_next_data(long timeout)
wait_next_data
in interface org.omg.ETF.ConnectionOperations
wait_next_data
in class ConnectionBase
timeout
- unused.public int read(org.omg.ETF.BufferHolder buffer, int offset, int minLength, int maxLength, long timeout)
read
in interface org.omg.ETF.ConnectionOperations
read
in class StreamConnectionBase
buffer
- the buffer holder.offset
- the buffer offset.minLength
- the minimum length to be read.maxLength
- the maximum length to be read.timeout
- unuseddata.value
is at the index offset
+ this return
value. This return type is a change to the ETF draft spec in JacORB.
It is needed because the mechanism suggested in the draft does not work
in Java.public void close()
close
in interface org.omg.ETF.ConnectionOperations
public void run()
protected int getTimeout()
getTimeout
in class ConnectionBase
protected void setTimeout(int timeout)
setTimeout
in class ConnectionBase
public void configure(Configuration config) throws ConfigurationException
configure
in interface Configurable
configure
in class ConnectionBase
ConfigurationException
Copyright © 2017 JacORB. All rights reserved.