org.openorb.iiop
Class IIOPServerProtocol

java.lang.Object
  org.openorb.iiop.IIOPServerProtocol

All Implemented Interfaces:

ServerProtocol

public class IIOPServerProtocol

extends java.lang.Object

implements ServerProtocol

Version:

$Revision: 1.9 $ $Date: 2001/08/13 03:47:33 $

Author:

Chris Wood <wood@intalio.com>

Field Summary

Fields inherited from interface org.openorb.net.ServerProtocol

STATE_CLOSED, STATE_LISTENING, STATE_PAUSED

Constructor Summary

IIOPServerProtocol(ServerManager serverManager, org.openorb.iiop.CDRCodecFactory codecFactory, IIOPTransportServerInitializer trans)
Create new IIOPServerProtocol

Method Summary

void	close() Stop listening, refuse all incoming connections.
TaggedProfile	create_profile(int profile_tag, ComponentSet component_set, byte[] object_key) Construct a tagged profile from parts.
ServerManager	getServerManager()
void	listen(int timeout) Listen for a single connection.
boolean	open() Move to the listening state.
ORB	orb() An orb reference.
boolean	pause() Move to the paused state.
void	run_listen() Donate a thread for listening.
boolean	servesAddress(java.lang.String addr, int port)
int	state() The channel state.
java.lang.String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

IIOPServerProtocol

public IIOPServerProtocol(ServerManager serverManager,
                          org.openorb.iiop.CDRCodecFactory codecFactory,
                          IIOPTransportServerInitializer trans)

Create new IIOPServerProtocol

Parameters:

serverManager - the server manager instance.

codecFactory - codec factory for iiop codecs.

trans - transport initializer.

Throws:

INITIALIZE - if problem occoured during startup.

Method Detail

toString

public java.lang.String toString()

orb

public ORB orb()

Description copied from interface: ServerProtocol

An orb reference.

Specified by:

orb in interface ServerProtocol

getServerManager

public ServerManager getServerManager()

servesAddress

public boolean servesAddress(java.lang.String addr,
                             int port)

state

public int state()

Description copied from interface: ServerProtocol

The channel state.

Specified by:

state in interface ServerProtocol

open

public boolean open()

Move to the listening state. If in the closed state this wil result in the protocol re-registering itself with the ServerManager. Returns true if state changed.

Specified by:

open in interface ServerProtocol

pause

public boolean pause()

Move to the paused state. This is only valid in the LISTENING state. returns true if state is now PAUSED.

Specified by:

pause in interface ServerProtocol

close

public void close()

Stop listening, refuse all incoming connections.

Specified by:

close in interface ServerProtocol

listen

public void listen(int timeout)

Listen for a single connection. If a connection is available this will create and register a new server socket, otherwise it will return once the timeout has expired.

Specified by:

listen in interface ServerProtocol

run_listen

public void run_listen()

Donate a thread for listening. This function returns when interrupt is called on the thread or the protocol is closed.

Specified by:

run_listen in interface ServerProtocol

create_profile

public TaggedProfile create_profile(int profile_tag,
                                    ComponentSet component_set,
                                    byte[] object_key)

Construct a tagged profile from parts. This is used by the ServerManager. If the profile should not be included in an IOR this may return null.

Specified by:

create_profile in interface ServerProtocol