ziver/hal
1
1
Fork 0
Code Pull requests Releases Activity

adding ant build script

Browse source 
Former-commit-id: 47153bf95c1f09c1119a11c95f1188d8beca0113
This commit is contained in:
Daniel Collin 2015-12-04 12:18:45 +01:00
parent a0dce97932
commit 4c05900dfc
6 changed files with 111 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

29
src/se/koc/hal/plugin/localsensor/ImpulseTracker.java
View file

@ -1,8 +1,12 @@
package se.koc.hal.plugin.localsensor;
import java.io.IOException;
import java.sql.SQLException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.logging.Logger;
import zutil.db.DBConnection;
import zutil.log.LogUtil;
import com.pi4j.io.gpio.GpioController;
import com.pi4j.io.gpio.GpioFactory;
@ -14,17 +18,19 @@ import com.pi4j.io.gpio.event.GpioPinDigitalStateChangeEvent;
import com.pi4j.io.gpio.event.GpioPinListenerDigital;
public class ImpulseTracker implements Runnable {
private static final Logger logger = LogUtil.getLogger();
private static final int IMPULSE_REPORT_TIMEOUT = 60000; //one minute
private long nanoSecondsSleep = IMPULSE_REPORT_TIMEOUT * 1000000L;
private Integer impulseCount = 0;
private ExecutorService executorPool;
private final DBConnection db;
public static void main(String args[]) throws InterruptedException, IOException {
public static void main(String args[]) throws Exception {
new ImpulseTracker();
}
public ImpulseTracker() throws InterruptedException, IOException{
public ImpulseTracker() throws Exception{
// create gpio controller
final GpioController gpio = GpioFactory.getInstance();
@ -48,6 +54,9 @@ public class ImpulseTracker implements Runnable {
this.executorPool = Executors.newCachedThreadPool();
logger.info("Connecting to db...");
db = new DBConnection(DBConnection.DBMS.SQLite, "hal.db");
//start a daemon thread to save the impulse count every minute
Thread thread = new Thread(this);
thread.setDaemon(true);
@ -92,15 +101,13 @@ public class ImpulseTracker implements Runnable {
executorPool.execute(new Runnable(){
@Override
public void run() {
//this.listener.
try {
db.exec("INSERT INTO sensor_data_raw (timestamp, sensor_id, data) VALUE("+timestamp_end+", "+2+", "+data+")");
} catch (SQLException e) {
e.printStackTrace();
}
}
});
}
/*
public void setListener(Object listener){
this.listener = listener;
}
*/
}