def start(self, fork=True):
if not fork:<EOL><INDENT>distributed_logger.info('<STR_LIT>')<EOL>_registry_aggregator(self.reporter, self.socket_addr)<EOL><DEDENT>else:<EOL><INDENT>distributed_logger.info('<STR_LIT>')<EOL>p = Process(target=_registry_aggregator, args=(self.reporter, self.socket_addr, ))<EOL>p.start()<EOL>distributed_logger.info('<STR_LIT>', p.pid)<EOL>self.process = p<EOL><DEDENT>
Starts the registry aggregator.

        :param fork: whether to fork a process; if ``False``, blocks and stays in the existing process