mirror_php/deployer
1
0
Fork 0
mirror of https://github.com/deployphp/deployer.git synced 2025-03-14 18:29:41 +01:00
Code Issues Projects Releases Wiki Activity

Upgrade to PurePHP 1.1.0.

Browse Source
This commit is contained in:
Anton Medvedev 2015-01-02 19:35:54 +03:00
parent 1145544169
commit 434e8a4cea
3 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
composer.json
View File

@ -23,7 +23,7 @@
"symfony/console": "~2.6",
"symfony/process": "~2.6",
"elfet/php-ssh": "~1.0",
"elfet/pure": "~1.0",
"elfet/pure": "~1.1",
"phpseclib/phpseclib": "0.3.*@dev",
"kherge/amend": "~3.0"
},

2
src/Console/WorkerCommand.php
View File

@ -62,7 +62,7 @@ class WorkerCommand extends Command
$environment = isset($this->deployer->environments[$serverName]) ? $this->deployer->environments[$serverName] : new Environment();
$output = new RemoteOutput($output, $pure, $serverName);
while (!$pure->map('shutdown')->has($serverName)) {
while ($pure->ping()) {
// Get task to do
$taskName = $pure->map('tasks_to_do')->get($serverName);

7
src/Executor/ParallelExecutor.php
View File

@ -34,11 +34,8 @@ class ParallelExecutor implements ExecutorInterface
$pure = new Server($port);
$loop = $pure->getLoop();
$outputStorage = new QueueStorage();
$pure->setStorage('output', $outputStorage);
$exceptionStorage = new QueueStorage();
$pure->setStorage('exception', $exceptionStorage);
$outputStorage = $pure['output'] = new QueueStorage();
$exceptionStorage = $pure['exception'] = new QueueStorage();
// Wait until all workers finish they tasks. When set this variable to true and send new tasks to workers.
$wait = false;