public void reconfigZKToWritable(List<String> observerNodes,List<String> readOnlyNodes){
  log.info("Standby is running in read-only mode due to connection loss with active site. " + "Reconfig coordinatorsvc of all nodes to writable");
  try {
    boolean reconfigLocal=false;
    for (    String node : observerNodes) {
      if (node.equals(coordinatorExt.getMyNodeId())) {
        reconfigLocal=true;
        continue;
      }
      LocalRepository localRepository=LocalRepository.getInstance();
      localRepository.remoteReconfigCoordinator(node,"participant");
      localRepository.remoteRestartCoordinator(node,"participant");
    }
    for (    String node : readOnlyNodes) {
      if (node.equals(coordinatorExt.getMyNodeId())) {
        reconfigLocal=true;
        continue;
      }
      LocalRepository localRepository=LocalRepository.getInstance();
      localRepository.remoteReconfigCoordinator(node,"participant");
      localRepository.remoteRestartCoordinator(node,"participant");
    }
    if (reconfigLocal) {
      coordinatorExt.reconfigZKToWritable();
    }
  }
 catch (  Exception ex) {
    log.warn("Unexpected errors during switching back to zk observer. Try again later. {}",ex.toString());
  }
}

public void reconfigZKToWritable ( List < String > observerNodes , List < String > readOnlyNodes ) { log . info ( "Standby is running in read-only mode due to connection loss with active site. " + "Reconfig coordinatorsvc of all nodes to writable" ) ; try { boolean reconfigLocal = false ; for ( String node : observerNodes ) { if ( node . equals ( coordinatorExt . getMyNodeId ( ) ) ) { reconfigLocal = true ; continue ; } LocalRepository localRepository = LocalRepository . getInstance ( ) ; localRepository . remoteReconfigCoordinator ( node , "participant" ) ; localRepository . remoteRestartCoordinator ( node , "participant" ) ; } for ( String node : readOnlyNodes ) { if ( node . equals ( coordinatorExt . getMyNodeId ( ) ) ) { reconfigLocal = true ; continue ; } LocalRepository localRepository = LocalRepository . getInstance ( ) ; localRepository . remoteReconfigCoordinator ( node , "participant" ) ; localRepository . remoteRestartCoordinator ( node , "participant" ) ; } if ( reconfigLocal ) { coordinatorExt . reconfigZKToWritable ( ) ; } } catch ( Exception ex ) { log . warn ( "Unexpected errors during switching back to zk observer. Try again later. {}" , ex . toString ( ) ) ; } }
reconfigure zookeeper to participant mode within the local site
