Synchronized monitored list of processes

diff --git a/server/process/sonar-process/src/main/java/org/sonar/process/Monitor.java b/server/process/sonar-process/src/main/java/org/sonar/process/Monitor.java
index 18b4f11d927b5d27f8292d1622d3e07558509d84..f1891535b3759eaf7c5e180073877fbe004804bd 100644 (file)
--- a/server/process/sonar-process/src/main/java/org/sonar/process/Monitor.java
+++ b/server/process/sonar-process/src/main/java/org/sonar/process/Monitor.java
@@ -67,7 +67,7 @@ public class Monitor extends Thread implements Terminable {
     @Override
     public void run() {
       for (ProcessWrapper process : processes) {
-        LOGGER.debug("Pinging process[{}]",process.getName());
+        LOGGER.debug("Pinging process[{}]", process.getName());
         try {
           ProcessMXBean mBean = process.getProcessMXBean();
           if (mBean != null) {
@@ -85,25 +85,31 @@ public class Monitor extends Thread implements Terminable {
    * Registers and monitors process. Note that process is probably not ready yet.
    */
   public void registerProcess(ProcessWrapper process) throws InterruptedException {
-    processes.add(process);
+    LOGGER.info("Registering process[{}] for monitoring.", process.getName());
+    synchronized (processes) {
+      processes.add(process);
+    }
     // starts a monitoring thread
     process.start();
   }
 
   /**
    * Check continuously that registered processes are still up. If any process is down or does not answer to pings
-   * during the max allowed period, then thread exits. 
+   * during the max allowed period, then thread exits.
    */
   @Override
   public void run() {
     try {
       boolean ok = true;
       while (isRunning && ok) {
-        for (ProcessWrapper process : processes) {
-          if (!ProcessUtils.isAlive(process.process())) {
-            LOGGER.info("{} is down, stopping all other processes", process.getName());
-            ok = false;
-            interrupt();
+        synchronized (processes) {
+          LOGGER.debug("Monitoring {} processes.", processes.size());
+          for (ProcessWrapper process : processes) {
+            if (!ProcessUtils.isAlive(process.process())) {
+              LOGGER.info("{} is down, stopping all other processes", process.getName());
+              ok = false;
+              interrupt();
+            }
           }
         }
         if (ok) {