org.jacorb.orb.miop

Class ServerMIOPConnection

java.lang.Object

org.omg.CORBA.LocalObject

org.omg.ETF._ConnectionLocalBase

org.jacorb.orb.etf.ConnectionBase

org.jacorb.orb.etf.StreamConnectionBase

org.jacorb.orb.miop.MIOPConnection

org.jacorb.orb.miop.ServerMIOPConnection

All Implemented Interfaces:

Serializable, Runnable, Configurable, LocalInterface, Object, IDLEntity, org.omg.ETF.Connection, org.omg.ETF.ConnectionOperations

public class ServerMIOPConnection
extends MIOPConnection
implements Runnable

Listen to a specified group port and class D IP address for messages addressed to this group.

Version:

1.0

Author:

Alysson Neves Bessani, Nick Cross

See Also:

MIOPListener, Serialized Form

Field Summary

Fields inherited from class org.jacorb.orb.etf.StreamConnectionBase

in_stream, out_stream

Fields inherited from class org.jacorb.orb.etf.ConnectionBase

b_out, configuration, connected, connection_info, finalTimeout, logger, orb, profile

Constructor Summary

Constructors

Constructor and Description
ServerMIOPConnection() Creates a new server MIOP connection that listen to the specified group.

Method Summary

Methods

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.

Methods inherited from class org.jacorb.orb.miop.MIOPConnection

handleCommFailure, isSSL, supports_callback

Methods inherited from class org.jacorb.orb.etf.StreamConnectionBase

flush, silentClose, write

Methods inherited from class org.jacorb.orb.etf.ConnectionBase

get_server_profile, getLocalhost, is_connected, to_COMM_FAILURE, turnOnFinalTimeout, use_handle_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.CORBA.Object

_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

Constructor Detail

ServerMIOPConnection

public ServerMIOPConnection()

Creates a new server MIOP connection that listen to the specified group.

Method Detail

connect

public void connect(org.omg.ETF.Profile profile,
           long time_out)

Connect the socket. Called by MIOPListener.

Specified by:

connect in interface org.omg.ETF.ConnectionOperations

Parameters:

profile -

time_out - unused, we use SO_TIMEOUT

is_data_available

public boolean is_data_available()

Tests if there is data available on this connection.

Specified by:

is_data_available in interface org.omg.ETF.ConnectionOperations

Overrides:

is_data_available in class MIOPConnection

Returns:

true if there are data available.

wait_next_data

public boolean wait_next_data(long timeout)

Wait until there is some complete message ready data to be read from connection.

Specified by:

wait_next_data in interface org.omg.ETF.ConnectionOperations

Overrides:

wait_next_data in class ConnectionBase

Parameters:

timeout - unused.

Returns:

always true.

read

public int read(org.omg.ETF.BufferHolder buffer,
       int offset,
       int minLength,
       int maxLength,
       long timeout)

Read data from the connection.

Specified by:

read in interface org.omg.ETF.ConnectionOperations

Overrides:

read in class StreamConnectionBase

Parameters:

buffer - the buffer holder.

offset - the buffer offset.

minLength - the minimum length to be read.

maxLength - the maximum length to be read.

timeout - unused

Returns:

the number of bytes actually read. The last byte written to data.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.

close

public void close()

Close this connection.

Specified by:

close in interface org.omg.ETF.ConnectionOperations

run

public void run()

Run method. Inherited from runnable, this method is used to stay listening to the socket for new messages.

Specified by:

run in interface Runnable

getTimeout

protected int getTimeout()

Specified by:

getTimeout in class ConnectionBase

setTimeout

protected void setTimeout(int timeout)

Specified by:

setTimeout in class ConnectionBase

configure

public void configure(Configuration config)
               throws ConfigurationException

Specified by:

configure in interface Configurable

Overrides:

configure in class ConnectionBase

Throws:

ConfigurationException