Arm keepalive timeout timer after response completion.
(self)
| 650 | pass |
| 651 | |
| 652 | def _arm_keepalive_timer(self): |
| 653 | """Arm keepalive timeout timer after response completion.""" |
| 654 | if self._keepalive_handle: |
| 655 | self._keepalive_handle.cancel() |
| 656 | keepalive_timeout = self.cfg.keepalive |
| 657 | if keepalive_timeout > 0: |
| 658 | self._keepalive_handle = self.worker.loop.call_later( |
| 659 | keepalive_timeout, self._keepalive_timeout |
| 660 | ) |
| 661 | |
| 662 | def _cancel_keepalive_timer(self): |
| 663 | """Cancel keepalive timer when new request arrives.""" |