Starts catalogd and waits until the service is ready to accept connections.
(self, wait_until_ready=True, additional_args=None)
| 753 | return int(self._get_port('catalog_service_port', DEFAULT_CATALOG_SERVICE_PORT)) |
| 754 | |
| 755 | def start(self, wait_until_ready=True, additional_args=None): |
| 756 | """Starts catalogd and waits until the service is ready to accept connections.""" |
| 757 | restart_args = self.cmd[1:] |
| 758 | if additional_args: |
| 759 | restart_args = restart_args + [additional_args] |
| 760 | LOG.info("Starting Catalogd process: {0}".format(restart_args)) |
| 761 | run_daemon("catalogd", restart_args) |
| 762 | if wait_until_ready: |
| 763 | self.service.wait_for_metric_value('statestore-subscriber.connected', |
| 764 | expected_value=1, timeout=30) |
| 765 | # Also wait until web pages are initialized |
| 766 | self.service.wait_for_page_ready("healthz") |
| 767 | |
| 768 | def set_jvm_log_level(self, class_name, level): |
| 769 | """Helper method to set JVM log level for certain class name.""" |
nothing calls this directly
no test coverage detected