Added WebMoira sources

[moira.git] / webmoira / mit / moira / Kticket.java

diff --git a/webmoira/mit/moira/Kticket.java b/webmoira/mit/moira/Kticket.java
new file mode 100644 (file)
index 0000000..28c6f44
--- /dev/null
+++ b/webmoira/mit/moira/Kticket.java
@@ -0,0 +1,64 @@
+package mit.moira;
+
+import java.util.Date;
+import java.io.IOException;
+
+public class Kticket implements Runnable {
+    Object LOCK;
+    String name;
+    String instance;
+    String realm;
+    boolean dostop = false;
+    Runtime r;
+    Date renewTime;
+
+    Kticket(String name, String instance, String realm, Object lock) {
+       this.name = name;
+       this.instance = instance;
+       this.realm = realm;
+       this.LOCK = lock;
+       r = Runtime.getRuntime();
+       renewTime = new Date();
+    }
+
+    public void run() {
+       for(;;) {
+           if (dostop) return;
+           Date now = new Date();
+           if (now.after(renewTime)) {
+               renew();
+               renewTime = new Date(System.currentTimeMillis() + 6*3600*1000L); // 6 hours
+           }
+           try {
+               Thread.sleep(30*1000L); // Sleep for 30 seconds
+           } catch (InterruptedException i) {
+               // Nothing to be done about it
+           }
+       }
+    }
+
+    public void renew() {
+       synchronized(LOCK) {
+           try {
+               Process p = r.exec("/usr/athena/bin/kinit -k -t /mit/jis/javahacking/moira/KEY " + name + "/" + instance + "@" + realm);
+               p.waitFor();
+           } catch (IOException e) {
+               e.printStackTrace();
+           } catch (InterruptedException i) {
+           }
+       }
+    }
+
+    public void destroy() {
+       dostop = true;
+       synchronized(LOCK) {
+           try {
+               Process p = r.exec("/usr/athena/bin/kdestroy");
+               p.waitFor();
+           } catch (IOException e) {
+               e.printStackTrace();
+           } catch (InterruptedException i) {
+           }
+       }
+    }
+}