| | |
| | | final ConnectedRS rs = connectedRS.get(); |
| | | if (rs.isConnected()) |
| | | { |
| | | connectPhaseLock.notify(); |
| | | connectPhaseLock.notifyAll(); |
| | | |
| | | final long rsGenId = rs.rsInfo.getGenerationId(); |
| | | final int rsServerId = rs.rsInfo.getServerId(); |
| | |
| | | if (!connectionError) |
| | | { |
| | | connectionError = true; |
| | | connectPhaseLock.notify(); |
| | | connectPhaseLock.notifyAll(); |
| | | |
| | | if (!rsInfos.isEmpty()) |
| | | { |
| | |
| | | synchronized (monitorResponse) |
| | | { |
| | | monitorResponse.set(true); |
| | | monitorResponse.notify(); |
| | | monitorResponse.notifyAll(); |
| | | } |
| | | |
| | | // Update the replication servers ServerStates with new received info |