Attachments management

[gpl/argeo-slc.git] / runtime / org.argeo.slc.server / src / main / java / org / argeo / slc / services / impl / runtime / AgentServiceImpl.java

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 1f2397a09be8f55f94281a19b6e214c5091f78f4..021f573645f78f98540ccee7b11d4048cd2df7f3 100644 (file)
--- 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.");
                }
 
        }