()
| 940 | from twisted.internet import reactor |
| 941 | |
| 942 | def performReconnect(): |
| 943 | # Apply the shared state reset logic |
| 944 | self._performRetryStateReset() |
| 945 | |
| 946 | # Stop current service and restart it to trigger reconnection |
| 947 | if self._reconnectingService and self._reconnectingService.running: |
| 948 | self._reconnectingService.stopService() |
| 949 | |
| 950 | # Restart the service to trigger a reconnection attempt |
| 951 | self._reconnectingService.startService() |
| 952 | |
| 953 | # Use callLater for threading purposes as suggested |
| 954 | reactor.callLater(0.1, performReconnect) |
nothing calls this directly
no test coverage detected