X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.server%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fservices%2Fimpl%2Fruntime%2FAgentServiceImpl.java;h=021f573645f78f98540ccee7b11d4048cd2df7f3;hb=44dd5750650b46d9979b4e06e4cc76c0b0003f4f;hp=1f2397a09be8f55f94281a19b6e214c5091f78f4;hpb=a9bd656db864f3f648d375deef6833c2f53f29ba;p=gpl%2Fargeo-slc.git

diff --git a/runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/services/impl/runtime/AgentServiceImpl.java b/runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/services/impl/runtime/AgentServiceImpl.java
index 1f2397a09..021f57364 100644
--- a/runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/services/impl/runtime/AgentServiceImpl.java
+++ b/runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/services/impl/runtime/AgentServiceImpl.java
@@ -56,6 +56,7 @@ public class AgentServiceImpl implements AgentService, InitializingBean,
 
 	protected class PingThread extends Thread {
 		public void run() {
+			log.info("Start pinging agents.");
 			while (pingThreadActive) {
 				List<SlcAgentDescriptor> lst = slcAgentDescriptorDao
 						.listSlcAgentDescriptors();
@@ -63,7 +64,7 @@ public class AgentServiceImpl implements AgentService, InitializingBean,
 				for (SlcAgentDescriptor ad : lst)
 					agentIds.add(ad.getUuid());
 
-				if (log.isDebugEnabled())
+				if (log.isTraceEnabled())
 					log.debug("Ping " + agentIds.size() + " agent.");
 				for (String agentId : agentIds) {
 					SlcAgent agent = agentFactory.getAgent(agentId);
@@ -74,6 +75,12 @@ public class AgentServiceImpl implements AgentService, InitializingBean,
 					}
 				}
 
+				lst = slcAgentDescriptorDao.listSlcAgentDescriptors();
+				agentIds = new ArrayList<String>();
+				for (SlcAgentDescriptor ad : lst)
+					agentIds.add(ad.getUuid());
+				agentFactory.pingAll(agentIds);
+
 				synchronized (AgentServiceImpl.this) {
 					try {
 						AgentServiceImpl.this.wait(pingCycle);
@@ -82,6 +89,7 @@ public class AgentServiceImpl implements AgentService, InitializingBean,
 					}
 				}
 			}
+			log.info("Stopped pinging agents.");
 		}
 
 	}