58 except AttributeError: |
58 except AttributeError: |
59 last_usage_time = session.mtime |
59 last_usage_time = session.mtime |
60 except BadConnectionId: |
60 except BadConnectionId: |
61 self.close_session(session) |
61 self.close_session(session) |
62 closed += 1 |
62 closed += 1 |
63 else: |
63 continue |
64 no_use_time = (time() - last_usage_time) |
64 |
65 if session.anonymous_session: |
65 no_use_time = (time() - last_usage_time) |
66 if no_use_time >= self.cleanup_anon_session_time: |
66 if session.anonymous_session: |
67 self.close_session(session) |
67 if no_use_time >= self.cleanup_anon_session_time: |
68 closed += 1 |
|
69 elif session_time is not None and no_use_time >= session_time: |
|
70 self.close_session(session) |
68 self.close_session(session) |
71 closed += 1 |
69 closed += 1 |
|
70 elif session_time is not None and no_use_time >= session_time: |
|
71 self.close_session(session) |
|
72 closed += 1 |
72 return closed, total - closed |
73 return closed, total - closed |
73 |
74 |
74 def current_sessions(self): |
75 def current_sessions(self): |
75 """return currently open sessions""" |
76 """return currently open sessions""" |
76 raise NotImplementedError() |
77 raise NotImplementedError() |