self.cookiename = cookiename
self.path = path
self.lock = threading.Lock()
- self.lastuse = 0
self.cthread = None
self.freezetime = 3600
def cleanloop(self):
try:
- lastuse = self.lastuse
- while self.lastuse >= lastuse:
- lastuse = self.lastuse
+ while True:
time.sleep(300)
self.clean()
+ if len(self.live) == 0:
+ break
finally:
with self.lock:
self.cthread = None
def fetch(self, req):
now = int(time.time())
- self.lastuse = now
sessid = cookie.get(req, self.cookiename)
with self.lock:
if self.cthread is None:
except KeyError:
sess = session()
self.live[sess.id] = sess
- req.oncommit(self.addcookie)
+ sess.new = True
req.oncommit(self.ckfreeze)
return sess
- def addcookie(self, req):
- sess = req.item(self.fetch)
- cookie.add(req, self.cookiename, sess.id, self.path)
-
def ckfreeze(self, req):
- sess = req.item(self.fetch)
+ sess = self.get(req)
if sess.dirty():
try:
+ if getattr(sess, "new", False):
+ cookie.add(req, self.cookiename, sess.id, self.path)
+ del sess.new
self.freeze(sess)
except:
pass
def freeze(self, sess):
raise TypeError()
+ def get(self, req):
+ return req.item(self.fetch)
+
class backeddb(db):
def __init__(self, backdb, *args, **kw):
super(backeddb, self).__init__(*args, **kw)
default = backeddb(dirback(os.path.join("/tmp", "wrwsess-" + str(os.getuid()))))
def get(req):
- return req.item(default.fetch)
+ return default.get(req)