@@ -28,7 +28,7 @@ def __init__(self, mtda, lock_timeout, session_timeout):
28
28
self ._sessions = {}
29
29
30
30
def check (self , session = None ):
31
- self .mtda .debug (3 , f"session.check({ session } )" )
31
+ self .mtda .debug (4 , f"session.check({ session } )" )
32
32
33
33
events = []
34
34
now = time .monotonic ()
@@ -45,7 +45,7 @@ def check(self, session=None):
45
45
inactive = []
46
46
for s in self ._sessions :
47
47
left = self ._sessions [s ] - now
48
- self .mtda .debug (3 , "session %s: %d seconds" % (s , left ))
48
+ self .mtda .debug (4 , "session %s: %d seconds" % (s , left ))
49
49
if left <= 0 :
50
50
inactive .append (s )
51
51
for s in inactive :
@@ -73,11 +73,11 @@ def check(self, session=None):
73
73
for e in events :
74
74
self .notify (e )
75
75
76
- self .mtda .debug (3 , f"session.check: { result } " )
76
+ self .mtda .debug (4 , f"session.check: { result } " )
77
77
return result
78
78
79
79
def lock (self , session ):
80
- self .mtda .debug (3 , f"session.lock({ session } )" )
80
+ self .mtda .debug (4 , f"session.lock({ session } )" )
81
81
82
82
self .check (session )
83
83
with self ._lock :
@@ -88,7 +88,7 @@ def lock(self, session):
88
88
else :
89
89
result = False
90
90
91
- self .mtda .debug (3 , f"session.lock(): { result } " )
91
+ self .mtda .debug (4 , f"session.lock(): { result } " )
92
92
return result
93
93
94
94
def locked (self , session ):
@@ -100,7 +100,7 @@ def locked(self, session):
100
100
return result
101
101
102
102
def unlock (self , session ):
103
- self .mtda .debug (3 , f"session.unlock({ session } )" )
103
+ self .mtda .debug (4 , f"session.unlock({ session } )" )
104
104
105
105
result = False
106
106
self .check (session )
@@ -112,33 +112,33 @@ def unlock(self, session):
112
112
if result is True :
113
113
self .notify (f"UNLOCKED { session } " )
114
114
115
- self .mtda .debug (3 , f"session.unlock: { result } " )
115
+ self .mtda .debug (4 , f"session.unlock: { result } " )
116
116
return result
117
117
118
118
def notify (self , info ):
119
- self .mtda .debug (3 , f"session.notify({ info } )" )
119
+ self .mtda .debug (4 , f"session.notify({ info } )" )
120
120
121
121
result = None
122
122
if info is not None :
123
123
for m in self ._monitors :
124
124
m .session_event (info )
125
125
self .mtda .notify (CONSTS .EVENTS .SESSION , info )
126
126
127
- self .mtda .debug (3 , f"session.notify: { result } " )
127
+ self .mtda .debug (4 , f"session.notify: { result } " )
128
128
return result
129
129
130
130
def monitor (self , monitor ):
131
- self .mtda .debug (3 , "session.monitor()" )
131
+ self .mtda .debug (4 , "session.monitor()" )
132
132
133
133
result = None
134
134
with self ._lock :
135
135
self ._monitors .append (monitor )
136
136
137
- self .mtda .debug (3 , f"session.monitor: { result } " )
137
+ self .mtda .debug (4 , f"session.monitor: { result } " )
138
138
return result
139
139
140
140
def set_timeout (self , timeout , session = None ):
141
- self .mtda .debug (3 , f"session.set_timeout({ timeout } , { session } )" )
141
+ self .mtda .debug (4 , f"session.set_timeout({ timeout } , { session } )" )
142
142
143
143
with self ._lock :
144
144
result = self ._session_timeout
@@ -150,5 +150,5 @@ def set_timeout(self, timeout, session=None):
150
150
self ._sessions [s ] = now + timeout
151
151
self .check (session )
152
152
153
- self .mtda .debug (3 , f"session.set_timeout: { result } " )
153
+ self .mtda .debug (4 , f"session.set_timeout: { result } " )
154
154
return result
0 commit comments