+RLIMITS = {"CPU": RLIMIT_CPU,
+ "RSS": RLIMIT_RSS,
+ "NPROC": RLIMIT_NPROC,
+ "NOFILE": RLIMIT_NOFILE,
+ "MEMLOCK": RLIMIT_MEMLOCK,
+ "AS": RLIMIT_AS,
+ "LOCKS": RLIMIT_LOCKS,
+ "SIGPENDING": RLIMIT_SIGPENDING,
+ "MSGQUEUE": RLIMIT_MSGQUEUE,
+ "NSOCK": VLIMIT_NSOCK,
+ "OPENFD": VLIMIT_OPENFD,
+ "ANON": VLIMIT_ANON,
+ "SHMEM": VLIMIT_SHMEM}
+
+class NoSuchVServer(Exception): pass
+
+
+class VServerConfig:
+ mapping = {
+ 'S_CONTEXT': 'context',
+ 'VS_WHITELISTED': 'whitelisted',
+ 'CPULIMIT': 'sched/fill-rate2',
+ 'CPUGUARANTEED': 'sched/fill-rate',
+ 'VS_DISK_MAX': 'dlimits/0/space_total',
+ }
+
+ def __init__(self, name, directory):
+ global RLIMITS
+ for i in RLIMITS.keys():
+ for j in ('HARD', 'SOFT', 'MINIMUM'):
+ self.mapping['VS_%s_%s' % (i, j)] = 'rlimits/%s.%s' % (i.lower(), j.replace('MINIMUM', 'min').lower())
+ self.name = name
+ self.dir = directory
+
+ def get(self, option, default = None):
+ try:
+ filename = self.mapping[option]
+ f = open(os.path.join(self.dir, filename), "r")
+ buf = f.readline().rstrip()
+ f.close()
+ return buf
+ except KeyError, e:
+ # No mapping exists for this option
+ raise e
+ except IOError, e:
+ if default is not None:
+ return default
+ else:
+ raise KeyError, "Key %s is not set for %s" % (option, self.name)
+
+ def update(self, vars):
+ for (option, value) in vars.iteritems():
+ try:
+ old_umask = os.umask(0022)
+ filename = os.path.join(self.dir, self.mapping[option])
+ try:
+ os.makedirs(os.path.dirname(filename), 0755)
+ except:
+ pass
+ f = open(filename, 'w')
+ f.write("%s\n" % value)
+ f.close()
+ os.umask(old_umask)
+ except KeyError, e:
+ raise KeyError, "Don't know how to handle %s, sorry" % option
+