|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sleepycat.je.rep.utilint.ServiceDispatcher.ExecutingService
com.sleepycat.je.rep.impl.GroupService
public class GroupService
Nested Class Summary | |
---|---|
(package private) class |
GroupService.GroupServiceRunnable
|
Field Summary | |
---|---|
(package private) RepGroupProtocol |
protocol
|
(package private) RepNode |
repNode
|
static String |
SERVICE_NAME
|
Constructor Summary | |
---|---|
GroupService(ServiceDispatcher dispatcher,
RepNode repNode)
|
Method Summary | |
---|---|
protected void |
cancel()
Cancel the service as part of the registration being canceled. |
Runnable |
getRunnable(SocketChannel socketChannel)
|
TextProtocol.ResponseMessage |
process(RepGroupProtocol.EnsureNode ensureNode)
Ensures that the Monitor node, as described in the request, is a member of the group. |
TextProtocol.ResponseMessage |
process(RepGroupProtocol.GroupRequest groupRequest)
Wraps the replication group as currently cached on this node in a Response message and returns it. |
TextProtocol.ResponseMessage |
process(RepGroupProtocol.RemoveMember removeMember)
Removes a current member from the group. |
TextProtocol.ResponseMessage |
process(RepGroupProtocol.TransferMaster transferMaster)
Transfer the master role from the current master to one of the specified replicas. |
TextProtocol.ResponseMessage |
process(RepGroupProtocol.UpdateAddress updateAddress)
Update the network address for a dead replica. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
final RepNode repNode
final RepGroupProtocol protocol
public static final String SERVICE_NAME
Constructor Detail |
---|
public GroupService(ServiceDispatcher dispatcher, RepNode repNode)
Method Detail |
---|
protected void cancel()
cancel
in class ServiceDispatcher.ExecutingService
public TextProtocol.ResponseMessage process(RepGroupProtocol.GroupRequest groupRequest)
public TextProtocol.ResponseMessage process(RepGroupProtocol.EnsureNode ensureNode)
ensureNode
- the request message describing the monitor node
public TextProtocol.ResponseMessage process(RepGroupProtocol.RemoveMember removeMember)
removeMember
- the request identifying the member to be removed.
public TextProtocol.ResponseMessage process(RepGroupProtocol.UpdateAddress updateAddress)
updateAddress
- the request identifying the new network address for
the node.
public TextProtocol.ResponseMessage process(RepGroupProtocol.TransferMaster transferMaster)
transferMaster
- the request identifying nodes to be considered for
the role of new master
public Runnable getRunnable(SocketChannel socketChannel)
getRunnable
in class ServiceDispatcher.ExecutingService
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |