STDIN, 1 => STDOUT, 2 => STDERR, ); $cmd = "{$php_executable} {$php_args} {$code} {$host}:{$port} "; if (substr(PHP_OS, 0, 3) == 'WIN') { $cmd = "{$php_executable} {$php_args} {$code} {$host}:{$port} "; $handle = proc_open(addslashes($cmd), $descriptorspec, $pipes, __DIR__, NULL, array("bypass_shell" => true, "suppress_errors" => true)); } else { $cmd = "exec {$cmd} 2>/dev/null"; $handle = proc_open($cmd, $descriptorspec, $pipes, __DIR__); } // note: even when server prints 'Listening on localhost:8964...Press Ctrl-C to quit.' // it might not be listening yet...need to wait until fsockopen() call returns $error = "Unable to connect to server\n"; for ($i=0; $i < getenv("VALGRIND") ? 1000 : 60; $i++) { usleep(50000); // 50ms per try $status = proc_get_status($handle); $fp = @fsockopen($host, $port); // Failure, the server is no longer running if (!($status && $status['running'])) { $error = "Server is not running {$status['command']}\n"; break; } // Success, Connected to servers if ($fp) { $error = ''; break; } } if ($fp) { fclose($fp); } if ($error) { echo $error; proc_terminate($handle); proc_close($handle); exit(1); } register_shutdown_function( function($handle) { if (is_resource($handle)) { proc_terminate($handle); proc_close($handle); } }, $handle ); return $handle; } function memcached_server_stop($handle) { $success = FALSE; if ($handle) { proc_terminate($handle); /* Wait for server to shutdown */ for ($i = 0; $i < 60; $i++) { $status = proc_get_status($handle); if (!($status && $status['running'])) { $success = TRUE; break; } usleep(50000); } proc_close($handle); } return $success; }