From e70341b29473cc8ceb48089991f165cbad7a6ece Mon Sep 17 00:00:00 2001 From: Fredrik Tolf Date: Thu, 1 Dec 2011 21:33:32 +0100 Subject: [PATCH] Tidied up sessions' freezechecking. --- wrw/session.py | 25 ++++++++++++------------- 1 file changed, 12 insertions(+), 13 deletions(-) diff --git a/wrw/session.py b/wrw/session.py index 284d092..2abe650 100644 --- a/wrw/session.py +++ b/wrw/session.py @@ -110,6 +110,7 @@ class db(object): def fetch(self, req): now = int(time.time()) sessid = cookie.get(req, self.cookiename) + new = False with self.lock: if self.cthread is None: self.cthread = threading.Thread(target = self.cleanloop) @@ -129,21 +130,19 @@ class db(object): except KeyError: sess = session() self.live[sess.id] = sess - sess.new = True - req.oncommit(self.ckfreeze) + new = True + + def ckfreeze(req): + if sess.dirty(): + try: + if new: + cookie.add(req, self.cookiename, sess.id, self.path) + self.freeze(sess) + except: + pass + req.oncommit(ckfreeze) return sess - def ckfreeze(self, req): - 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 thaw(self, sessid): raise KeyError() -- 2.11.0