Starts statestored and waits until the service is started and ready to accept connections.
(self, wait_until_ready=True, additional_args=None)
| 725 | return int(self._get_port('state_store_port', DEFAULT_STATESTORE_SERVICE_PORT)) |
| 726 | |
| 727 | def start(self, wait_until_ready=True, additional_args=None): |
| 728 | """Starts statestored and waits until the service is started and ready to accept |
| 729 | connections.""" |
| 730 | restart_args = self.cmd[1:] |
| 731 | if additional_args: |
| 732 | restart_args = restart_args + [additional_args] |
| 733 | LOG.info("Starting Statestored process: {0}".format(restart_args)) |
| 734 | run_daemon("statestored", restart_args) |
| 735 | if wait_until_ready: |
| 736 | self.service.wait_for_metric_value('statestore.service-started', |
| 737 | expected_value=1, timeout=30) |
| 738 | |
| 739 | |
| 740 | # Represents a catalogd process |
nothing calls this directly
no test coverage detected