diff src/org/dancres/blitz/tools/HotBackup.java @ 0:3dc0c5604566

Initial checkin of blitz 2.0 fcs - no installer yet.
author Dan Creswell <dan.creswell@gmail.com>
date Sat, 21 Mar 2009 11:00:06 +0000
parents
children
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/org/dancres/blitz/tools/HotBackup.java	Sat Mar 21 11:00:06 2009 +0000
@@ -0,0 +1,112 @@
+package org.dancres.blitz.tools;
+
+import java.io.IOException;
+
+import java.rmi.RemoteException;
+import java.rmi.RMISecurityManager;
+
+import net.jini.discovery.*;
+
+import net.jini.lookup.*;
+import net.jini.lookup.entry.Name;
+
+import net.jini.core.lookup.ServiceItem;
+import net.jini.core.lookup.ServiceTemplate;
+
+import net.jini.core.entry.Entry;
+
+import net.jini.admin.Administrable;
+
+import net.jini.space.JavaSpace;
+
+import net.jini.core.transaction.TransactionException;
+
+import org.dancres.blitz.remote.BlitzAdmin;
+
+import org.dancres.jini.util.DiscoveryUtil;
+import org.dancres.jini.util.ServiceLocator;
+
+/**
+   <p>Triggers a backup to the specified directory which must be available to
+   the machine on which the Blitz instance is running.</p>
+
+   <p>Arguments are directory and spacename or directory, LUS host and 
+   spacename</p>
+
+   @see org.dancres.blitz.remote.BlitzAdmin
+ */
+public class HotBackup {
+    private static final long MAX_DISCOVER_TIME = 15 * 1000;
+
+    public static void main(String args[]) {
+        if (System.getSecurityManager() == null)
+            System.setSecurityManager(new RMISecurityManager());
+
+        try {
+            try {
+                Object myProxy = null;
+
+                if (args.length == 2)
+                    myProxy = ServiceLocator.getService(JavaSpace.class,
+                                                        args[1],
+                                                        MAX_DISCOVER_TIME);
+                else if (args.length == 3) {
+                    myProxy = ServiceLocator.getService(args[1],
+                                                        JavaSpace.class,
+                                                        args[2]);
+                } else {
+                    System.err.println("Wrong number of arguments - should be <dir> <spacename> or <dir> <LUS host> <spacename>");
+                    System.exit(-1);
+                }
+
+                String myDir = args[0];
+
+                if (myProxy != null) {
+                    System.err.println("Found space: " + myProxy);
+
+                    DiscoveryUtil.dumpInterfaces(myProxy.getClass());
+
+                    if (DiscoveryUtil.hasInterface(myProxy,
+                                                   Administrable.class)) {
+                        Administrable myAdmin = (Administrable) myProxy;
+
+                        Object myAdminProxy = myAdmin.getAdmin();
+
+                        DiscoveryUtil.dumpInterfaces(myAdminProxy.getClass());
+
+                        if (DiscoveryUtil.hasInterface(myAdminProxy,
+                                                       BlitzAdmin.class)) {
+                            BlitzAdmin myBlitzAdmin = 
+                                (BlitzAdmin) myAdminProxy;
+
+                            try {
+                                System.err.println("Invoking backup to: " +
+                                                   myDir);
+                                myBlitzAdmin.backup(myDir);
+                            } catch (Exception aE) {
+                                System.err.println("Failed to backup");
+                                aE.printStackTrace(System.err);
+                                System.exit(-1);
+                            }
+                        } else {
+                            System.err.println("No BlitzAdmin interface found - can't be Blitz");
+                        }
+                    } else {
+                        System.err.println("No admin interface present - can't be Blitz");
+                    }
+                }
+            } catch (InterruptedException anIE) {
+                System.err.println("!!! Whoops service not found :( !!!");
+            }
+        } catch (ClassNotFoundException aCNFE) {
+            System.err.println("ClassNotFound exception");
+            aCNFE.printStackTrace(System.err);
+        } catch (RemoteException anRE) {
+            System.err.println("Remote exception");
+            anRE.printStackTrace(System.err);
+        } catch (IOException anIOE) {
+            System.err.println("Failed to configure discovery");
+            anIOE.printStackTrace(System.err);
+        }
+    }
+}