public function manage()
    {
        if (!($this->processManagerDto instanceof ProcessManagerDto)) {
            throw new ProcessManagerException("ProcessManagerDto wasn't set.");
        }

        $this->executionDto = new ExecutionDto();
        $this->reactControlDto = $this->processManagerDto;
        $this->initStartMethods();
        $this->context = new Context($this->loop);

        $this->dtoContainer = new DtoContainer();
        $this->tasks = $this->processManagerDto->getTasksNumber();
        $this->commandsManager = new CommandsManager();
        $this->logger->info("PM start work." . $this->loggerPostfix);

        $this->initWorkersPublisher();
        $this->declareLmRequester();

        $this->initLoadManager();
        $this->initLoadManagingControl();

        $this->loop->run();

        return null;
    }
public function manage()
    {
        if (!($this->processManagerDto instanceof ProcessManagerDto)) {
            throw new ProcessManagerException("ProcessManagerDto wasn't set.");
        }

        $this->executionDto = new ExecutionDto();
        $this->reactControlDto = $this->processManagerDto;
        $this->initStartMethods();
        $this->context = new Context($this->loop);

        $this->dtoContainer = new DtoContainer();
        $this->tasks = $this->processManagerDto->getTasksNumber();
        $this->commandsManager = new CommandsManager();
        $this->logger->info("PM start work." . $this->loggerPostfix);

        $this->initWorkersPublisher();
        $this->declareLmRequester();

        $this->initLoadManager();
        $this->initLoadManagingControl();

        $this->loop->run();

        return null;
    }
public function manage ( ) { if ( ! ( $ this -> processManagerDto instanceof ProcessManagerDto ) ) { throw new ProcessManagerException ( "ProcessManagerDto wasn't set." ) ; } $ this -> executionDto = new ExecutionDto ( ) ; $ this -> reactControlDto = $ this -> processManagerDto ; $ this -> initStartMethods ( ) ; $ this -> context = new Context ( $ this -> loop ) ; $ this -> dtoContainer = new DtoContainer ( ) ; $ this -> tasks = $ this -> processManagerDto -> getTasksNumber ( ) ; $ this -> commandsManager = new CommandsManager ( ) ; $ this -> logger -> info ( "PM start work." . $ this -> loggerPostfix ) ; $ this -> initWorkersPublisher ( ) ; $ this -> declareLmRequester ( ) ; $ this -> initLoadManager ( ) ; $ this -> initLoadManagingControl ( ) ; $ this -> loop -> run ( ) ; return null ; }
Manage processes creation and termination during to load manager info and tasks number
@param ProcessManagerDto $processManagerDto
Manage processes creation and termination during to load manager info and tasks number