(self, txn, version, origin)
| 249 | self._end_write_unlocked(txn) |
| 250 | |
| 251 | def _commit_version_unlocked(self, txn, version, origin): |
| 252 | self._versions.append(version) |
| 253 | self._prune_versions_unlocked() |
| 254 | self.nodes = version.nodes |
| 255 | if self.origin is None: |
| 256 | self.origin = origin |
| 257 | # txn can be None in __init__ when we make the empty version. |
| 258 | if txn is not None: |
| 259 | self._end_write_unlocked(txn) |
| 260 | |
| 261 | def _commit_version(self, txn, version, origin): |
| 262 | with self._version_lock: |
no test coverage detected