projects
/
invirt/packages/invirt-web.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Add a commented out line to disable the autoinstaller
[invirt/packages/invirt-web.git]
/
code
/
cache_acls.py
diff --git
a/code/cache_acls.py
b/code/cache_acls.py
index
9f8d66a
..
1a23587
100644
(file)
--- a/
code/cache_acls.py
+++ b/
code/cache_acls.py
@@
-1,11
+1,17
@@
#!/usr/bin/python
#!/usr/bin/python
-from sipb_xen_database import *
+from invirt.database import *
+from invirt.config import structs as config
import sys
import getafsgroups
import subprocess
def expandLocker(name):
import sys
import getafsgroups
import subprocess
def expandLocker(name):
- groups = getafsgroups.getLockerAcl(name)
+ try:
+ groups = getafsgroups.getLockerAcl(name)
+ except getafsgroups.AfsProcessError, e:
+ if e.message.startswith("fs: You don't have the required access rights on"):
+ groups = []
+ raise
cell = getafsgroups.getCell(name)
ans = set()
for group in groups:
cell = getafsgroups.getCell(name)
ans = set()
for group in groups:
@@
-29,7
+35,7
@@
def expandName(name):
return [name]
return []
try:
return [name]
return []
try:
- return getafsgroups.getAfsGroupMembers(name, 'athena.mit.edu')
+ return getafsgroups.getAfsGroupMembers(name, config.authz[0].cell)
except getafsgroups.AfsProcessError:
return []
except getafsgroups.AfsProcessError:
return []
@@
-44,28
+50,28
@@
def refreshMachine(m):
old_people = set(a.user for a in m.acl)
for removed in old_people - people:
ma = [x for x in m.acl if x.user == removed][0]
old_people = set(a.user for a in m.acl)
for removed in old_people - people:
ma = [x for x in m.acl if x.user == removed][0]
- ctx.current.delete(ma)
+ session.delete(ma)
for p in people - old_people:
ma = MachineAccess(user=p)
m.acl.append(ma)
for p in people - old_people:
ma = MachineAccess(user=p)
m.acl.append(ma)
- ctx.current.save(ma)
+ session.save_or_update(ma)
def refreshCache():
def refreshCache():
- transaction = ctx.current.create_transaction()
+ session.begin()
try:
try:
- machines = Machine.select()
+ machines = Machine.query().all()
for m in machines:
refreshMachine(m)
for m in machines:
refreshMachine(m)
- ctx.current.flush()
+ session.flush()
# Atomically execute our changes
# Atomically execute our changes
- transaction.commit()
+ session.commit()
except:
# Failed! Rollback all the changes.
except:
# Failed! Rollback all the changes.
- transaction.rollback()
+ session.rollback()
raise
if __name__ == '__main__':
raise
if __name__ == '__main__':
- connect('postgres://sipb-xen@sipb-xen-dev/sipb_xen')
+ connect()
refreshCache()
refreshCache()