Added worker TTL and set the default to 3 seconds

WyriHaximus · Apr 6, 2016 · ba5abe0 · ba5abe0
1 parent 44ea6a3
commit ba5abe0
Show file tree

Hide file tree

Showing 4 changed files with 37 additions and 31 deletions.
diff --git a/composer.json b/composer.json
@@ -11,7 +11,7 @@
   "require": {
     "php": "^5.5||^7.0",
     "cakephp/cakephp": "^3.0.0",
-    "wyrihaximus/react-child-process-pool": "^1.0.0",
+    "wyrihaximus/react-child-process-pool": "^1.3",
     "doctrine/annotations": "^1.2",
     "phpdocumentor/reflection-docblock": "^2.0|^3.0"
   },

diff --git a/composer.lock b/composer.lock
diff --git a/config/bootstrap.php b/config/bootstrap.php
@@ -16,6 +16,10 @@
     Configure::write('WyriHaximus.React.Cake.Orm.Process', 'exec php ' . ROOT . '/bin/cake.php WyriHaximus/React/Cake/Orm.worker run -q');
 }
 
+if (!Configure::check('WyriHaximus.React.Cake.Orm.TTL')) {
+    Configure::write('WyriHaximus.React.Cake.Orm.TTL', 3);
+}
+
 AnnotationRegistry::registerLoader(function ($class) {
     return class_exists($class);
 });
diff --git a/src/Pool.php b/src/Pool.php
@@ -10,6 +10,7 @@
 use React\Promise\PromiseInterface;
 use WyriHaximus\React\ChildProcess\Messenger\Messages\Factory;
 use WyriHaximus\React\ChildProcess\Pool\Factory\Flexible;
+use WyriHaximus\React\ChildProcess\Pool\Options;
 use WyriHaximus\React\ChildProcess\Pool\PoolInfoInterface;
 use WyriHaximus\React\ChildProcess\Pool\PoolInterface;
 use WyriHaximus\React\ChildProcess\Pool\PoolUtilizerInterface;
@@ -53,6 +54,7 @@ protected function __construct(LoopInterface $loop)
             $this->loop,
             [
                 'processOptions' => Configure::read('WyriHaximus.React.Cake.Orm.Line'),
+                Options::TTL => Configure::read('WyriHaximus.React.Cake.Orm.TTL'),
             ]
         )->then(function (PoolInterface $pool) {
             $this->pool = $pool;