package com.sleepycat.je.rep.impl;
import static com.sleepycat.je.rep.impl.RepParams.GROUP_NAME;
List of sockets for in-flight requests.
The socket is in this collection while the request is being processed,
and must be removed before sending any response.
"In-flight GroupService request(s) canceled: node shutdown");
Wraps the replication group as currently cached on this node in
a Response message and returns it.
Ensures that the Monitor node, as described in the request, is a member
of the group.
- Parameters:
ensureNode
the request message describing the monitor node- Returns:
- EnsureOK message if the monitor node is already part of the rep
group, or was just made a part of the replication group. It returns a
Fail message if it could not be made part of the group. The message
associated with the response provides further details.
Removes a current member from the group.
- Parameters:
removeMember
the request identifying the member to be removed.- Returns:
- OK message if the member was removed from the group.
Update the network address for a dead replica.
- Parameters:
updateAddress
the request identifying the new network address for
the node.- Returns:
- OK message if the address is successfully updated.
Transfer the master role from the current master to one of the specified
replicas.
- Parameters:
transferMaster
the request identifying nodes to be considered for
the role of new master- Returns:
- null
("GroupService operation can only be performed at master");
Removes the given
SocketChannel
from our list of active sockets.
Before sending any response on the socket, this method must be invoked
to claim ownership of it.
This avoids a potential race between the request processing thread in
the normal case, and a thread calling cancel()
at env shutdown
time.
- Returns:
- true, if the socket is still active (usual case); false
otherwise, presumably because the service was shut down.
super(socketChannel, protocol, true);