Updated Monitor Interface
git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/data-miner-manager-cl@141825 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
parent
177f399ea2
commit
aace38a38b
|
@ -1,4 +1,7 @@
|
||||||
<ReleaseNotes>
|
<ReleaseNotes>
|
||||||
|
<Changeset component="org.gcube.data.analysis.data-miner-manager-cl.1-1-0">
|
||||||
|
<Change>Updated Monitor interface</Change>
|
||||||
|
</Changeset>
|
||||||
<Changeset component="org.gcube.data.analysis.data-miner-manager-cl.1-0-0">
|
<Changeset component="org.gcube.data.analysis.data-miner-manager-cl.1-0-0">
|
||||||
<Change>first release</Change>
|
<Change>first release</Change>
|
||||||
</Changeset>
|
</Changeset>
|
||||||
|
|
2
pom.xml
2
pom.xml
|
@ -11,7 +11,7 @@
|
||||||
|
|
||||||
<groupId>data-miner-manager-cl</groupId>
|
<groupId>data-miner-manager-cl</groupId>
|
||||||
<artifactId>data-miner-manager-cl</artifactId>
|
<artifactId>data-miner-manager-cl</artifactId>
|
||||||
<version>1.0.0-SNAPSHOT</version>
|
<version>1.1.0-SNAPSHOT</version>
|
||||||
|
|
||||||
<name>data-miner-manager-cl</name>
|
<name>data-miner-manager-cl</name>
|
||||||
<description>DataMiner Manager Client Library</description>
|
<description>DataMiner Manager Client Library</description>
|
||||||
|
|
|
@ -18,9 +18,9 @@ import org.slf4j.LoggerFactory;
|
||||||
*/
|
*/
|
||||||
public class DMMonitor {
|
public class DMMonitor {
|
||||||
private static Logger logger = LoggerFactory.getLogger(DMMonitor.class);
|
private static Logger logger = LoggerFactory.getLogger(DMMonitor.class);
|
||||||
private static final int SLEEP = 1000;
|
private int sleep = 2000; // Sleep duration
|
||||||
private static final int DELAY = 2000;
|
private int delay = 2000; // Delay on first check
|
||||||
private static final int PERIOD = 1000;
|
private int period = 2000;// Interval between monitoring requests
|
||||||
private ComputationId computationId;
|
private ComputationId computationId;
|
||||||
private SClient sClient;
|
private SClient sClient;
|
||||||
private ArrayList<DMMonitorListener> listeners = new ArrayList<DMMonitorListener>();
|
private ArrayList<DMMonitorListener> listeners = new ArrayList<DMMonitorListener>();
|
||||||
|
@ -45,18 +45,18 @@ public class DMMonitor {
|
||||||
public void start() {
|
public void start() {
|
||||||
try {
|
try {
|
||||||
logger.debug("Start Monitoring");
|
logger.debug("Start Monitoring");
|
||||||
notEnd=true;
|
notEnd = true;
|
||||||
timer = new Timer(false);
|
timer = new Timer(false);
|
||||||
DMMonitorTask dmMonitorTask = new DMMonitorTask(this, computationId,
|
DMMonitorTask dmMonitorTask = new DMMonitorTask(this,
|
||||||
sClient, listeners);
|
computationId, sClient, listeners);
|
||||||
logger.debug("Start: " + new Date());
|
logger.debug("Start: " + new Date());
|
||||||
timer.schedule(dmMonitorTask, DELAY, PERIOD);
|
timer.schedule(dmMonitorTask, delay, period);
|
||||||
|
|
||||||
while (notEnd){
|
while (notEnd) {
|
||||||
Thread.sleep(SLEEP);
|
Thread.sleep(sleep);
|
||||||
}
|
}
|
||||||
logger.debug("End run");
|
logger.debug("End run");
|
||||||
|
|
||||||
} catch (Throwable e) {
|
} catch (Throwable e) {
|
||||||
logger.error(e.getLocalizedMessage());
|
logger.error(e.getLocalizedMessage());
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
|
@ -67,10 +67,56 @@ public class DMMonitor {
|
||||||
public void cancel() {
|
public void cancel() {
|
||||||
if (timer != null)
|
if (timer != null)
|
||||||
timer.cancel();
|
timer.cancel();
|
||||||
notEnd=false;
|
notEnd = false;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* @return Sleep duration
|
||||||
|
*/
|
||||||
|
public int getSleep() {
|
||||||
|
return sleep;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* @param sleep Sleep duration
|
||||||
|
*/
|
||||||
|
public void setSleep(int sleep) {
|
||||||
|
this.sleep = sleep;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* @return Delay on first check
|
||||||
|
*/
|
||||||
|
public int getDelay() {
|
||||||
|
return delay;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* @param delay Delay on first check
|
||||||
|
*/
|
||||||
|
public void setDelay(int delay) {
|
||||||
|
this.delay = delay;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* @return Interval between monitoring requests
|
||||||
|
*/
|
||||||
|
public int getPeriod() {
|
||||||
|
return period;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* @param period Interval between monitoring requests
|
||||||
|
*/
|
||||||
|
public void setPeriod(int period) {
|
||||||
|
this.period = period;
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue