equal
deleted
inserted
replaced
225 self._active = True |
225 self._active = True |
226 self._condition = threading.Condition() |
226 self._condition = threading.Condition() |
227 self._record = {} |
227 self._record = {} |
228 |
228 |
229 def __enter__(self): |
229 def __enter__(self): |
230 self._condition.__enter__() |
230 return self._condition.__enter__() |
231 |
231 |
232 def __exit__(self, *args): |
232 def __exit__(self, *args): |
233 self._condition.__exit__(*args) |
233 return self._condition.__exit__(*args) |
234 |
234 |
235 def record(self, txid, cnxset): |
235 def record(self, txid, cnxset): |
236 """Inform the tracker that a txid have acquired a cnxset |
236 """Inform the tracker that a txid have acquired a cnxset |
237 |
237 |
238 This methode is to be used by Transaction object. |
238 This methode is to be used by Transaction object. |