Dominique.Fournier/DomFramework
1
0
Fork 0
Code Issues Pull Requests Projects Releases Activity

fork: Add name of the child process for "ps -edf"

Browse Source 
git-svn-id: https://svn.fournier38.fr/svn/ProgSVN/trunk@4008 bf3deb0d-5f1a-0410-827f-c0cc1f45334c
This commit is contained in:
Dominique Fournier
2017-12-22 14:03:10 +00:00
parent 8822ec580e
commit 63dd033864
1 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
fork.php
View File

@@ -14,6 +14,7 @@ class fork
if (! function_exists ("pcntl_fork")) if (! function_exists ("pcntl_fork"))
throw new \Exception ("Can't fork as PHP doesn't have the pcntl_fork", throw new \Exception ("Can't fork as PHP doesn't have the pcntl_fork",
500); 500);
declare (ticks=1);
} }
/** Return the number of active PID /** Return the number of active PID
@@ -59,11 +60,12 @@ class fork
* messages from the child are silently dropped. * messages from the child are silently dropped.
* If some parameters are provided, the called child method will receive them * If some parameters are provided, the called child method will receive them
* This function fork and return the child PID * This function fork and return the child PID
* @param string $name The name displayed in the processus list
* @param callable $callable The callback method to use in child * @param callable $callable The callback method to use in child
* @param mixed|null $params The params to provide to child method * @param mixed|null $params The params to provide to child method
* @return The child PID * @return The child PID
*/ */
public function startDetachedChild ($callable, $params = array ()) public function startDetachedChild ($name, $callable, $params = array ())
{ {
$pid = pcntl_fork (); $pid = pcntl_fork ();
if ($pid === -1) if ($pid === -1)
@@ -85,6 +87,9 @@ class fork
fclose (STDIN); fclose (STDIN);
fclose (STDOUT); fclose (STDOUT);
fclose (STDERR); fclose (STDERR);
if (function_exists ("cli_set_process_title"))
cli_set_process_title ($name);
$args = func_get_args (); $args = func_get_args ();
unset ($args[0]); unset ($args[0]);
call_user_func_array ($callable, $args); call_user_func_array ($callable, $args);
@@ -119,6 +124,9 @@ class fork
*/ */
public function stopChild ($pid, $maxWait = null) public function stopChild ($pid, $maxWait = null)
{ {
if (! key_exists ($pid, $this->pidList))
throw new \Exception ("Can't stop pid '$pid' : not in the fork list",
500);
return $this->sendSignalToChild (SIGTERM, $pid, $maxWait); return $this->sendSignalToChild (SIGTERM, $pid, $maxWait);
} }
@@ -133,6 +141,9 @@ class fork
*/ */
public function killChild ($pid, $maxWait = null) public function killChild ($pid, $maxWait = null)
{ {
if (! key_exists ($pid, $this->pidList))
throw new \Exception ("Can't kill pid '$pid' : not in the fork list",
500);
return $this->sendSignalToChild (SIGKILL, $pid, $maxWait); return $this->sendSignalToChild (SIGKILL, $pid, $maxWait);
} }
@@ -148,10 +159,7 @@ class fork
*/ */
private function sendSignalToChild ($signal, $pid, $maxWait = null) private function sendSignalToChild ($signal, $pid, $maxWait = null)
{ {
if (! key_exists ($pid, $this->pidList)) posix_kill ($pid, $signal);
throw new \Exception ("Can't stop/kill pid '$pid' : not in the fork list",
500);
posix_kill ($pid, SIGKILL);
if ($maxWait !== null) if ($maxWait !== null)
{ {
$startWait = time (); $startWait = time ();