(self, entry)
| 2583 | self._on_remove(entry._statement) |
| 2584 | |
| 2585 | def _set_entry_timeout(self, entry): |
| 2586 | # Clear the existing timeout. |
| 2587 | self._clear_entry_callback(entry) |
| 2588 | |
| 2589 | # Set the new timeout if it's not 0. |
| 2590 | if self._max_lifetime: |
| 2591 | entry._cleanup_cb = self._loop.call_later( |
| 2592 | self._max_lifetime, self._on_entry_expired, entry) |
| 2593 | |
| 2594 | def _new_entry(self, query, statement): |
| 2595 | entry = _StatementCacheEntry(self, query, statement) |
no test coverage detected