Changeset 1699 for trunk/packages/invirt-console-server/files/usr/bin

Timestamp:

Nov 17, 2008, 1:20:02 PM (16 years ago)

Author:

broder

Message:

Add real caching to consolefs, too

File:

• trunk/packages/invirt-console-server/files/usr/bin/invirt-consolefs (modified) (4 diffs)

trunk/packages/invirt-console-server/files/usr/bin/invirt-consolefs

@@ -27 +27 @@
                 """
                 super(ConsoleFS, self).__init__(*args, **kw)
-                self.lasttime = time()
+                self.lasttime = 0
+                self.machines = []
                 self.fuse_args.add("allow_other", True)
                 
@@ -33 +34 @@
                 
                 syslog(LOG_DEBUG, 'Init complete.')
-
+        
         def make_map(self):
                 m = Mapper()
@@ -42 +43 @@
                 return m
         
-        def getMachines(self, **kw):
-                """Get the list of VMs in the database, clearing the cache if it's 
-                older than 15 seconds"""
+        def recache(self):
+                """Refresh the local cache of VMs if the cache is more than 15 minutes old
+                """
                 if time() - self.lasttime > 15:
                         self.lasttime = time()
                         database.clear_cache()
-                return [machine.name for machine in database.Machine.query()]
+                        self.machines = dict((machine.name, machine) for machine in database.session.query(database.Machine).all())
+
+        def getMachines(self, **kw):
+                """Get the list of VMs in the database"""
+                self.recache()
+                return self.machines.keys()
         
         def getMirror(self, machine, path='', **kw):
@@ -68 +74 @@
                 """Build the ACL for a machine and turn it into a .k5login file
                 """
-                machine = database.Machine.query().filter_by(name=machine).one()
+                self.recache()
+                machine = self.machines[machine]
                 users = [acl.user for acl in machine.acl]
                 return "\n".join(map(self.userToPrinc, users) + [''])