| | |
| | | */ |
| | | private AtomicBoolean shuttingDown = new AtomicBoolean(false); |
| | | |
| | | /** |
| | | * Weight of this remote server. |
| | | */ |
| | | protected int weight = 1; |
| | | |
| | | /** |
| | | * Creates a new server handler instance with the provided socket. |
| | |
| | | */ |
| | | public RSInfo toRSInfo() |
| | | { |
| | | RSInfo rsInfo = new RSInfo(serverId, generationId, groupId); |
| | | RSInfo rsInfo = new RSInfo(serverId, generationId, groupId, weight); |
| | | |
| | | return rsInfo; |
| | | } |
| | | |
| | | /** |
| | | * Starts the monitoring publisher for the domain if not already started. |
| | | */ |
| | | protected void createMonitoringPublisher() |
| | | { |
| | | if (!replicationServerDomain.isRunningMonitoringPublisher()) |
| | | { |
| | | replicationServerDomain.startMonitoringPublisher(); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * Performs any processing periodic processing that may be desired to update |
| | | * the information associated with this monitor. Note that best-effort |
| | | * attempts will be made to ensure that calls to this method come |