X-Git-Url: https://code.wpia.club/?a=blobdiff_plain;ds=sidebyside;f=src%2Forg%2Fcacert%2Fgigi%2Fping%2FPingerDaemon.java;h=4936bfc1c1a66e213cb56826ecede219d99c448e;hb=a0232b6e40e7e09767f0444d24e18bf12dafc362;hp=bc86d80c7b09de993e945870a90786326e5887c7;hpb=bba77181c4ffa665c11f6db1a23d5913be799e0e;p=gigi.git diff --git a/src/org/cacert/gigi/ping/PingerDaemon.java b/src/org/cacert/gigi/ping/PingerDaemon.java index bc86d80c..4936bfc1 100644 --- a/src/org/cacert/gigi/ping/PingerDaemon.java +++ b/src/org/cacert/gigi/ping/PingerDaemon.java @@ -5,17 +5,16 @@ import java.util.HashMap; import java.util.LinkedList; import java.util.Queue; -import org.cacert.gigi.database.DatabaseConnection; import org.cacert.gigi.database.GigiPreparedStatement; import org.cacert.gigi.database.GigiResultSet; import org.cacert.gigi.dbObjects.Domain; import org.cacert.gigi.dbObjects.DomainPingConfiguration; -import org.cacert.gigi.dbObjects.DomainPingConfiguration.PingType; +import org.cacert.gigi.dbObjects.DomainPingType; import org.cacert.gigi.util.RandomToken; public class PingerDaemon extends Thread { - HashMap pingers = new HashMap<>(); + HashMap pingers = new HashMap<>(); private GigiPreparedStatement searchNeededPings; @@ -29,11 +28,11 @@ public class PingerDaemon extends Thread { @Override public void run() { - searchNeededPings = DatabaseConnection.getInstance().prepare("SELECT `pingconfig`.`id` FROM `pingconfig` LEFT JOIN `domainPinglog` ON `domainPinglog`.`configId` = `pingconfig`.`id` INNER JOIN `domains` ON `domains`.`id` = `pingconfig`.`domainid` WHERE ( `domainPinglog`.`configId` IS NULL) AND `domains`.`deleted` IS NULL GROUP BY `pingconfig`.`id`"); - pingers.put(PingType.EMAIL, new EmailPinger()); - pingers.put(PingType.SSL, new SSLPinger(truststore)); - pingers.put(PingType.HTTP, new HTTPFetch()); - pingers.put(PingType.DNS, new DNSPinger()); + searchNeededPings = new GigiPreparedStatement("SELECT `pingconfig`.`id` FROM `pingconfig` LEFT JOIN `domainPinglog` ON `domainPinglog`.`configId` = `pingconfig`.`id` INNER JOIN `domains` ON `domains`.`id` = `pingconfig`.`domainid` WHERE ( `domainPinglog`.`configId` IS NULL) AND `domains`.`deleted` IS NULL GROUP BY `pingconfig`.`id`"); + pingers.put(DomainPingType.EMAIL, new EmailPinger()); + pingers.put(DomainPingType.SSL, new SSLPinger(truststore)); + pingers.put(DomainPingType.HTTP, new HTTPFetch()); + pingers.put(DomainPingType.DNS, new DNSPinger()); while (true) { try { @@ -66,7 +65,7 @@ public class PingerDaemon extends Thread { } private void handle(DomainPingConfiguration conf) { - PingType type = conf.getType(); + DomainPingType type = conf.getType(); String config = conf.getInfo(); DomainPinger dp = pingers.get(type); if (dp != null) { @@ -80,6 +79,7 @@ public class PingerDaemon extends Thread { try { dp.ping(target, config, target.getOwner(), conf.getId()); } catch (Throwable t) { + t.printStackTrace(); DomainPinger.enterPingResult(conf.getId(), "error", "exception", null); } System.err.println("done (" + System.currentTimeMillis() + ")");