[Mulgara-svn] r417 - branches/nw-interface/src/jar/itql/java/org/mulgara/itql

[pag at mulgara.org]

Author: pag
Date: 2007-09-10 23:15:43 -0500 (Mon, 10 Sep 2007)
New Revision: 417

Modified:
   branches/nw-interface/src/jar/itql/java/org/mulgara/itql/TqlInterpreter.java
Log:
Update for use with the locality parameter on DataTx methods.

Modified: branches/nw-interface/src/jar/itql/java/org/mulgara/itql/TqlInterpreter.java
===================================================================
--- branches/nw-interface/src/jar/itql/java/org/mulgara/itql/TqlInterpreter.java	2007-09-11 04:14:54 UTC (rev 416)
+++ branches/nw-interface/src/jar/itql/java/org/mulgara/itql/TqlInterpreter.java	2007-09-11 04:15:43 UTC (rev 417)
@@ -531,8 +531,9 @@
     // get constituents of the load command
     URI sourceURI = toURI(node.getSource());
     URI destinationURI = toURI(node.getDestination());
+    boolean locality = node.getLocality() != null && (node.getLocality() instanceof ALocalLocality);
 
-    lastCommand = new Load(sourceURI, destinationURI);
+    lastCommand = new Load(sourceURI, destinationURI, locality);
   }
 
   /**
@@ -652,12 +653,11 @@
     // log the command
     if (logger.isDebugEnabled()) logger.debug("Processing restore command " + node);
 
-    // get the server we'll be restoring to
     URI destinationURI = toURI(node.getDestination());
-    // get the resource we're reading from
     URI sourceURI = toURI(node.getSource());
+    boolean locality = node.getLocality() != null && (node.getLocality() instanceof ALocalLocality);
 
-    lastCommand = new Restore(sourceURI, destinationURI);
+    lastCommand = new Restore(sourceURI, destinationURI, locality);
   }
 
   /**