| | |
| | | private static final Set<Integer> localPorts = |
| | | new CopyOnWriteArraySet<Integer>(); |
| | | |
| | | // Monitors for synchronizing domain creation with the connect thread. |
| | | /** Monitors for synchronizing domain creation with the connect thread. */ |
| | | private final Object domainTicketLock = new Object(); |
| | | private final Object connectThreadLock = new Object(); |
| | | private long domainTicket; |
| | |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * initialization function for the replicationServer. |
| | | */ |
| | | /** Initialization function for the replicationServer. */ |
| | | private void initialize() |
| | | { |
| | | shutdown.set(false); |