Changeset 1728 for trunk

Timestamp:

Nov 21, 2008, 4:16:38 AM (16 years ago)

Author:

quentin

Message:

Switched from caching ORM to direct database queries; now uncached queries are almost as fast as the cached queries used to be, and we don't have any cache coherency problems

Location:

trunk/packages/invirt-remote-server

Files:

• debian/changelog (modified) (1 diff)
• files/usr/sbin/invirt-remconffs (modified) (5 diffs)

trunk/packages/invirt-remote-server/debian/changelog

@@ +1 @@
+invirt-remote-server (0.1.3) unstable; urgency=low
+
+  * Switched to using "raw" select expressions instead of using the ORM;
+    allows the same speed as the old object-based system but without any
+    caching necessary.
+
+ -- Quentin Smith <quentin@mit.edu>  Fri, 21 Nov 2008 04:15:50 -0500
+
 invirt-remote-server (0.1.2) unstable; urgency=low
 

trunk/packages/invirt-remote-server/files/usr/sbin/invirt-remconffs

@@ -6 +6 @@
 from syslog import *
 from time import time
+import sqlalchemy as sa
 
 from invirt import database
@@ -28 +29 @@
         """
         super(RemConfFS, self).__init__(*args, **kw)
-        self.lasttime = 0
         self.fuse_args.add("allow_other", True)
         
@@ -43 +43 @@
         return m
     
-    def recache(self):
-        if time() - self.lasttime > 5:
-            self.lasttime = time()
-            database.clear_cache()
-            self.machines = dict((machine.name, machine) for machine in database.session.query(database.Machine).all())
-    
     def getroot(self, **kw):
         return ['acl', 'conf']
@@ -55 +49 @@
         """Build the ACL file for a machine
         """
-        self.recache()
-        machine = self.machines[machine]
-        users = [acl.user for acl in machine.acl]
-        return "\n".join(map(self.userToPrinc, users)
+        s = sa.sql.select([database.machine_access_table.c.user], # Field to select from
+                          sa.sql.and_( # where clause
+                database.machine_table.c.machine_id==database.machine_access_table.c.machine_id, # join field
+                database.machine_table.c.name == machine), # filter field
+                          from_obj=[database.machine_access_table, database.machine_table]) # from tables
+        users = [self.userToPrinc(acl[0]) for acl in
+                 database.session.execute(s)]
+        return "\n".join(users
                  + ['include /etc/remctl/acl/web',
                     ''])
@@ -71 +69 @@
     
     def getmachines(self, **kw):
-        """Get the list of VMs in the database, clearing the cache if it's 
-        older than 15 seconds"""
-        self.recache()
-        return self.machines.keys()
+        """Get the list of VMs in the database. Does not cache to prevent race conditions."""
+        return list(row[0] for row in database.session.execute(sa.sql.select([database.Machine.c.name])))
     
     def userToPrinc(self, user):