Package org.eclipse.ecf.provider.generic
Class ServerSOContainer
java.lang.Object
org.eclipse.ecf.core.AbstractContainer
org.eclipse.ecf.provider.generic.SOContainer
org.eclipse.ecf.provider.generic.ServerSOContainer
- All Implemented Interfaces:
org.eclipse.core.runtime.IAdaptable,IContainer,IIdentifiable,IReliableContainer,ISharedObjectContainer,ISharedObjectContainerGroupManager
- Direct Known Subclasses:
ServletServerContainer,SSLServerSOContainer,TCPServerSOContainer
-
Field Summary
FieldsFields inherited from class org.eclipse.ecf.provider.generic.SOContainer
config, DEFAULT_OBJECT_ARG_KEY, DEFAULT_OBJECT_ARGTYPES_KEY, groupManager, isClosing, loadingThreadGroup, policy, receiver, sharedObjectManager, sharedObjectMessageSerializer, sharedObjectThreadGroup -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected ContainerMessageacceptNewClient(Socket socket, String target, Serializable data, ISynchAsynchConnection conn) protected ObjectcheckJoin(SocketAddress saddr, ID fromID, String target, Serializable data) voidconnect(ID groupID, IConnectContext joinContext) Connect to a target remote process or process group.voidDisconnect.voiddispose()Dispose this IContainer instance.voidejectAllGroupMembers(Serializable reason) Eject all, for the given reason.voidejectGroupMember(ID memberID, Serializable reason) Eject the given groupMemberID from the current group of containers, for the given reason.protected voidforwardExcluding(ID from, ID excluding, ContainerMessage data) protected voidforwardToRemote(ID from, ID to, ContainerMessage data) Get the target ID that this container instance has connected to.protected IAsynchConnectiongetConnectionForID(ID memberID) protected IDprotected ISynchConnectiongetSynchConnectionForID(ID memberID) protected voidprotected voidbooleanprotected voidprotected voidqueueContainerMessage(ContainerMessage message) voidSet the join policy for this group manager.Methods inherited from class org.eclipse.ecf.provider.generic.SOContainer
addNewRemoteMember, addSharedObject0, addSharedObjectAndWait, addSharedObjectWrapper, addToLoading, checkRemoteCreate, createContainerPropertiesForSharedObject, createRemoteSharedObjectConfig, createRemoteSharedObjectContext, createRemoteSharedObjectWrapper, createSharedObjectConfig, createSharedObjectContext, createSharedObjectWrapper, debug, defaultDeserializeSharedObjectMessage, defaultSerializeSharedObjectMessage, deserializeContainerMessage, deserializeSharedObjectMessage, destroySharedObject, disconnect, fireDelegateContainerEvent, forward, getAdapter, getArgsFromProperties, getArgTypesFromProperties, getClassLoaderForContainer, getClassLoaderForSharedObject, getConfig, getConnectNamespace, getGroupMemberIDs, getGroupMembershipLock, getID, getMaxGroupMembers, getMessageReceiver, getNewSharedObjectThread, getNextSequenceNumber, getOtherMemberIDs, getReceiver, getSharedObject, getSharedObjectIDs, getSharedObjectManager, getSharedObjectMessageSerializer, getSharedObjectWrapper, handleAsynchIOException, handleCreateMessage, handleCreateResponseMessage, handleLeave, handleSharedObjectDisposeMessage, handleSharedObjectMessage, handleUndeliveredSharedObjectMessage, handleUnidentifiedMessage, isClosing, load, moveFromLoadingToActive, notifySharedObjectActivated, notifySharedObjectDeactivated, printToSystemError, processAsynch, processSynch, removeFromLoading, removeRemoteMember, removeSharedObject, sendCreate, sendCreateResponse, sendCreateResponseSharedObjectMessage, sendCreateSharedObjectMessage, sendDispose, sendDisposeSharedObjectMessage, sendMessage, sendMessage, sendSharedObjectMessage, serialize, serializeSharedObjectMessage, setMaxGroupMembers, setRemoteAddPolicy, setSharedObjectMessageSerializer, traceStack, validateContainerMessage, verifySharedObjectMessageTarget, verifyToIDForSharedObjectMessageMethods inherited from class org.eclipse.ecf.core.AbstractContainer
addListener, fireContainerEvent, getPasswordFromConnectContext, removeListenerMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.eclipse.ecf.core.IContainer
addListener, removeListener
-
Field Details
-
connectHandlerPolicy
-
-
Constructor Details
-
Method Details
-
isGroupManager
public boolean isGroupManager()- Specified by:
isGroupManagerin interfaceIReliableContainer- Specified by:
isGroupManagerin classSOContainer- Returns:
- true if this IReliableContainer instance is in the 'manager' role for the group, false otherwise.
-
getConnectedID
Description copied from interface:IContainerGet the target ID that this container instance has connected to. Returns null if not connected.- Specified by:
getConnectedIDin interfaceIContainer- Specified by:
getConnectedIDin classSOContainer- Returns:
- ID of the target we are connected to. Returns
nullif container not connected.
-
disconnect
public void disconnect()Description copied from interface:IContainerDisconnect. This operation will disconnect the local container instance from any previously joined target or group. Subsequent calls to getConnectedID() will returnnull.- Specified by:
disconnectin interfaceIContainer- Specified by:
disconnectin classSOContainer
-
ejectGroupMember
Description copied from interface:ISharedObjectContainerGroupManagerEject the given groupMemberID from the current group of containers, for the given reason.- Specified by:
ejectGroupMemberin interfaceISharedObjectContainerGroupManager- Parameters:
memberID- the ID of the group member to eject. If null, or if group member is not in group managed by this object, the method has no effectreason- a reason for the ejection
-
ejectAllGroupMembers
Description copied from interface:ISharedObjectContainerGroupManagerEject all, for the given reason.- Specified by:
ejectAllGroupMembersin interfaceISharedObjectContainerGroupManager- Parameters:
reason- a reason for the ejection
-
dispose
public void dispose()Description copied from interface:IContainerDispose this IContainer instance. The container instance will be made inactive after the completion of this method and will be unavailable for subsequent usage.- Specified by:
disposein interfaceIContainer- Overrides:
disposein classSOContainer
-
connect
Description copied from interface:IContainerConnect to a target remote process or process group. The target identified by the first parameter (targetID) is connected the implementation class. If authentication information is required, the required information is given via via the second parameter (connectContext). Callers note that depending upon the provider implementation this method may block. It is suggested that callers use a separate thread to call this method. This method provides an implementation independent way for container implementations to connect, authenticate, and communicate with a remote service or group of services. Providers are responsible for implementing this operation in a way appropriate to the given remote service (or group) via expected protocol.- Specified by:
connectin interfaceIContainer- Specified by:
connectin classSOContainer- Parameters:
groupID- the ID of the remote server or group to connect to. SeeIContainer.getConnectNamespace()for a explanation of the constraints upon this parameter.joinContext- any required context to allow this container to authenticate. May benullif underlying provider does not have any authentication requirements for connection.- Throws:
ContainerConnectException- thrown if communication cannot be established with remote service. Causes can include network connection failure, authentication failure, server error, or if container is already connected.
-
setConnectPolicy
Description copied from interface:ISharedObjectContainerGroupManagerSet the join policy for this group manager. If the policy is set to null, the implementing container is not obligated to consult the policy. If non-null, the given policy's checkJoin method is called before the manager agrees to the join of a given group participant.- Specified by:
setConnectPolicyin interfaceISharedObjectContainerGroupManager
-
queueContainerMessage
- Specified by:
queueContainerMessagein classSOContainer- Throws:
IOException
-
forwardToRemote
- Specified by:
forwardToRemotein classSOContainer- Throws:
IOException
-
forwardExcluding
- Specified by:
forwardExcludingin classSOContainer- Throws:
IOException
-
handleViewChangeMessage
- Specified by:
handleViewChangeMessagein classSOContainer- Parameters:
mess- message- Throws:
IOException- not thrown by this implementation.
-
acceptNewClient
protected ContainerMessage acceptNewClient(Socket socket, String target, Serializable data, ISynchAsynchConnection conn) -
checkJoin
protected Object checkJoin(SocketAddress saddr, ID fromID, String target, Serializable data) throws Exception - Throws:
Exception
-
handleLeaveGroupMessage
- Specified by:
handleLeaveGroupMessagein classSOContainer- Parameters:
mess- leave group message
-
getIDForConnection
- Specified by:
getIDForConnectionin classSOContainer
-
getConnectionForID
-
getSynchConnectionForID
-
processDisconnect
- Specified by:
processDisconnectin classSOContainer
-