@@ -76,12 +76,12 @@ class Process
76
76
77
77
private static $ sigchild ;
78
78
private static $ posixSignals = array (
79
- 1 => 1 , // SIGHUP
80
- 2 => 2 , // SIGINT
81
- 3 => 3 , // SIGQUIT
82
- 6 => 6 , // SIGABRT
83
- 14 => 14 , // SIGALRM
84
- 15 => 15 , // SIGTERM
79
+ 1 , // SIGHUP
80
+ 2 , // SIGINT
81
+ 3 , // SIGQUIT
82
+ 6 , // SIGABRT
83
+ 14 , // SIGALRM
84
+ 15 , // SIGTERM
85
85
);
86
86
87
87
/**
@@ -285,27 +285,35 @@ public function start($callback = null)
285
285
if (!isset ($ this ->options ['bypass_shell ' ])) {
286
286
$ this ->options ['bypass_shell ' ] = true ;
287
287
}
288
- }
288
+ } elseif (!$ this ->useFileHandles && $ this ->enhanceSigchildCompatibility && $ this ->isSigchildEnabled ()) {
289
+ // last exit code is output on the fourth pipe and caught to work around --enable-sigchild
290
+ $ descriptors [3 ] = array ('pipe ' , 'w ' );
291
+
292
+ $ commandline = '' ;
293
+ foreach (self ::$ posixSignals as $ s ) {
294
+ $ commandline .= "trap 'echo s $ s >&3' $ s; " ;
295
+ }
289
296
290
- $ ptsWorkaround = null ;
297
+ // See https://unix.stackexchange.com/questions/71205/background-process-pipe-input
298
+ $ commandline .= '{ ( ' .$ this ->commandline .') <&3 3<&- 3>/dev/null & } 3<&0; ' ;
299
+ $ commandline .= 'pid=$!; echo $pid >&3; wait $pid; code=$?; echo x$code >&3; exit $code ' ;
291
300
292
- if (!$ this ->useFileHandles && $ this ->enhanceSigchildCompatibility && $ this ->isSigchildEnabled ()) {
293
301
// Workaround for the bug, when PTS functionality is enabled.
294
302
// @see : https://bugs.php.net/69442
295
303
$ ptsWorkaround = fopen (__FILE__ , 'r ' );
296
304
}
297
305
298
306
$ this ->process = proc_open ($ commandline , $ descriptors , $ this ->processPipes ->pipes , $ this ->cwd , $ this ->env , $ this ->options );
299
307
300
- if ($ ptsWorkaround ) {
301
- fclose ($ ptsWorkaround );
302
- }
303
-
304
308
if (!is_resource ($ this ->process )) {
305
309
throw new RuntimeException ('Unable to launch a new process. ' );
306
310
}
307
311
$ this ->status = self ::STATUS_STARTED ;
308
312
313
+ if (isset ($ descriptors [3 ])) {
314
+ $ this ->fallbackStatus ['pid ' ] = (int ) fgets ($ this ->processPipes ->pipes [3 ]);
315
+ }
316
+
309
317
if ($ this ->tty ) {
310
318
return ;
311
319
}
@@ -596,8 +604,6 @@ public function clearErrorOutput()
596
604
public function getExitCode ()
597
605
{
598
606
if (!$ this ->enhanceSigchildCompatibility && $ this ->isSigchildEnabled ()) {
599
- $ this ->stop (0 );
600
-
601
607
throw new RuntimeException ('This PHP has been compiled with --enable-sigchild. You must use setEnhanceSigchildCompatibility() to use this method. ' );
602
608
}
603
609
@@ -651,8 +657,6 @@ public function hasBeenSignaled()
651
657
$ this ->requireProcessIsTerminated (__FUNCTION__ );
652
658
653
659
if (!$ this ->enhanceSigchildCompatibility && $ this ->isSigchildEnabled ()) {
654
- $ this ->stop (0 );
655
-
656
660
throw new RuntimeException ('This PHP has been compiled with --enable-sigchild. Term signal can not be retrieved. ' );
657
661
}
658
662
@@ -674,8 +678,6 @@ public function getTermSignal()
674
678
$ this ->requireProcessIsTerminated (__FUNCTION__ );
675
679
676
680
if ($ this ->isSigchildEnabled () && (!$ this ->enhanceSigchildCompatibility || -1 === $ this ->processInformation ['termsig ' ])) {
677
- $ this ->stop (0 );
678
-
679
681
throw new RuntimeException ('This PHP has been compiled with --enable-sigchild. Term signal can not be retrieved. ' );
680
682
}
681
683
@@ -1223,14 +1225,7 @@ public static function isPtySupported()
1223
1225
return $result = false ;
1224
1226
}
1225
1227
1226
- $ proc = @proc_open ('echo 1 ' , array (array ('pty ' ), array ('pty ' ), array ('pty ' )), $ pipes );
1227
- if (is_resource ($ proc )) {
1228
- proc_close ($ proc );
1229
-
1230
- return $ result = true ;
1231
- }
1232
-
1233
- return $ result = false ;
1228
+ return $ result = (bool ) @proc_open ('echo 1 ' , array (array ('pty ' ), array ('pty ' ), array ('pty ' )), $ pipes );
1234
1229
}
1235
1230
1236
1231
/**
@@ -1245,22 +1240,8 @@ private function getDescriptors()
1245
1240
} else {
1246
1241
$ this ->processPipes = UnixPipes::create ($ this , $ this ->input );
1247
1242
}
1248
- $ descriptors = $ this ->processPipes ->getDescriptors ($ this ->outputDisabled );
1249
-
1250
- if (!$ this ->useFileHandles && $ this ->enhanceSigchildCompatibility && $ this ->isSigchildEnabled ()) {
1251
- // last exit code is output on the fourth pipe and caught to work around --enable-sigchild
1252
- $ descriptors [3 ] = array ('pipe ' , 'w ' );
1253
-
1254
- $ trap = '' ;
1255
- foreach (self ::$ posixSignals as $ s ) {
1256
- $ trap .= "trap 'echo s $ s >&3' $ s; " ;
1257
- }
1258
-
1259
- $ this ->commandline = $ trap .'{ ( ' .$ this ->commandline .') <&3 3<&- 3>/dev/null & } 3<&0; ' ;
1260
- $ this ->commandline .= 'pid=$!; echo p$pid >&3; wait $pid; code=$?; echo x$code >&3; exit $code ' ;
1261
- }
1262
1243
1263
- return $ descriptors ;
1244
+ return $ this -> processPipes -> getDescriptors ( $ this -> outputDisabled ) ;
1264
1245
}
1265
1246
1266
1247
/**
@@ -1379,8 +1360,11 @@ private function readPipes($blocking, $close)
1379
1360
$ this ->fallbackStatus ['signaled ' ] = true ;
1380
1361
$ this ->fallbackStatus ['exitcode ' ] = -1 ;
1381
1362
$ this ->fallbackStatus ['termsig ' ] = (int ) substr ($ data , 1 );
1382
- } elseif ('x ' === $ data [0 ] && !isset ($ this ->fallbackStatus ['signaled ' ])) {
1383
- $ this ->fallbackStatus ['exitcode ' ] = (int ) substr ($ data , 1 );
1363
+ } elseif ('x ' === $ data [0 ]) {
1364
+ $ this ->fallbackStatus ['running ' ] = false ;
1365
+ if (!isset ($ this ->fallbackStatus ['signaled ' ])) {
1366
+ $ this ->fallbackStatus ['exitcode ' ] = (int ) substr ($ data , 1 );
1367
+ }
1384
1368
}
1385
1369
}
1386
1370
} else {
@@ -1462,14 +1446,6 @@ private function doSignal($signal, $throwException)
1462
1446
return false ;
1463
1447
}
1464
1448
1465
- if ($ this ->enhanceSigchildCompatibility && $ this ->isSigchildEnabled () && !isset (self ::$ posixSignals [$ signal ]) && !(function_exists ('posix_kill ' ) && @posix_kill ($ this ->getPid (), $ signal ))) {
1466
- if ($ throwException ) {
1467
- throw new RuntimeException ('This PHP has been compiled with --enable-sigchild and posix_kill() is not available. ' );
1468
- }
1469
-
1470
- return false ;
1471
- }
1472
-
1473
1449
if ('\\' === DIRECTORY_SEPARATOR ) {
1474
1450
exec (sprintf ('taskkill /F /T /PID %d 2>&1 ' , $ this ->getPid ()), $ output , $ exitCode );
1475
1451
if ($ exitCode && $ this ->isRunning ()) {
@@ -1479,14 +1455,21 @@ private function doSignal($signal, $throwException)
1479
1455
1480
1456
return false ;
1481
1457
}
1482
- }
1483
-
1484
- if (true !== @proc_terminate ($ this ->process , $ signal ) && '\\' !== DIRECTORY_SEPARATOR ) {
1485
- if ($ throwException ) {
1486
- throw new RuntimeException (sprintf ('Error while sending signal `%s`. ' , $ signal ));
1458
+ } else {
1459
+ if (!$ this ->enhanceSigchildCompatibility || !$ this ->isSigchildEnabled ()) {
1460
+ $ ok = @proc_terminate ($ this ->process , $ signal );
1461
+ } elseif (function_exists ('posix_kill ' )) {
1462
+ $ ok = @posix_kill ($ this ->getPid (), $ signal );
1463
+ } elseif ($ ok = proc_open (sprintf ('kill -%d %d ' , $ signal , $ this ->getPid ()), array (2 => array ('pipe ' , 'w ' )), $ pipes )) {
1464
+ $ ok = false === fgets ($ pipes [2 ]);
1487
1465
}
1466
+ if (!$ ok ) {
1467
+ if ($ throwException ) {
1468
+ throw new RuntimeException (sprintf ('Error while sending signal `%s`. ' , $ signal ));
1469
+ }
1488
1470
1489
- return false ;
1471
+ return false ;
1472
+ }
1490
1473
}
1491
1474
1492
1475
$ this ->latestSignal = (int ) $ signal ;
0 commit comments