mirror_php/deployer
1
0
Fork 0
mirror of https://github.com/deployphp/deployer.git synced 2025-02-24 09:12:51 +01:00
Code Issues Projects Releases Wiki Activity

Merge pull request #918 from t33k/native_ssh_multiplexing

Browse Source 
Add support for multiplexing for NativeSsh
This commit is contained in:
Anton Medvedev 2017-01-19 10:34:46 +07:00 committed by GitHub
commit 48abf05679
1 changed files with 106 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

107
src/Server/Remote/NativeSsh.php
View File

@ -13,6 +13,8 @@ use Symfony\Component\Process\Process;
class NativeSsh implements ServerInterface
{
const UNIX_SOCKET_MAX_LENGTH = 104;
/**
* @var array
*/
@ -48,9 +50,15 @@ class NativeSsh implements ServerInterface
$sshOptions = [
'-A',
'-q',
'-o UserKnownHostsFile=/dev/null -o StrictHostKeyChecking=no'
'-o UserKnownHostsFile=/dev/null',
'-o StrictHostKeyChecking=no'
];
if (\Deployer\get('ssh_type_native_mux')) {
$this->initMultiplexing();
$sshOptions = array_merge($sshOptions, $this->getMultiplexingSshOptions());
}
$username = $serverConfig->getUser() ? $serverConfig->getUser() : null;
if (!empty($username)) {
$username = $username . '@';
@ -134,6 +142,11 @@ class NativeSsh implements ServerInterface
$scpOptions[] = '-i ' . escapeshellarg($serverConfig->getPrivateKey());
}
if (\Deployer\get('ssh_type_native_mux')) {
$this->initMultiplexing();
$scpOptions = array_merge($scpOptions, $this->getMultiplexingSshOptions());
}
$scpCommand = 'scp ' . implode(' ', $scpOptions) . ' ' . escapeshellarg($target) . ' ' . escapeshellarg($target2);
$process = new Process($scpCommand);
@ -152,4 +165,96 @@ class NativeSsh implements ServerInterface
{
return $this->configuration;
}
/**
* Return ssh multiplexing socket name
*
* When $connectionHash is longer than 104 chars we can get "SSH Error: unix_listener: too long for Unix domain socket".
* https://github.com/ansible/ansible/issues/11536
* So try to get as descriptive hash as possible.
* %C is creating hash out of connection attributes.
*
* @return string Ssh multiplexing socket name
*/
protected function getConnectionHash()
{
$serverConfig = $this->getConfiguration();
$connectionData = "{$serverConfig->getUser()}@{$serverConfig->getHost()}:{$serverConfig->getPort()}";
$tryLongestPossibleSocketName = 0;
$connectionHash = '';
do {
switch ($tryLongestPossibleSocketName) {
case 1:
$connectionHash = "~/.ssh/deployer_mux_" . $connectionData;
break;
case 2:
$connectionHash = "~/.ssh/deployer_mux_%C";
break;
case 3:
$connectionHash = "~/deployer_mux_$connectionData";
break;
case 4:
$connectionHash = "~/deployer_mux_%C";
break;
case 5:
$connectionHash = "~/mux_%C";
break;
case 6:
throw new \RuntimeException("The multiplexing socket name is too long. Socket name is:" . $connectionHash);
default:
$connectionHash = "~/.ssh/deployer_mux_$connectionData";
}
$tryLongestPossibleSocketName++;
} while (strlen($connectionHash) > self::UNIX_SOCKET_MAX_LENGTH);
return $connectionHash;
}
/**
* Return ssh options for multiplexing
*
* @return string[]
*/
protected function getMultiplexingSshOptions()
{
return [
'-o ControlMaster=auto',
'-o ControlPersist=5',
'-o ControlPath=\'' . $this->getConnectionHash() . '\'',
];
}
/**
* Init multiplexing with exec() command
*
* Background: Symfony Process hangs on creating multiplex connection
* but after mux is created with exec() then Symfony Process
* can work with it.
*/
public function initMultiplexing()
{
$serverConfig = $this->getConfiguration();
$username = $serverConfig->getUser() ? $serverConfig->getUser() . '@' : null;
$hostname = $serverConfig->getHost();
$sshOptions = [];
if ($serverConfig->getPort()) {
$sshOptions[] = '-p ' . escapeshellarg($serverConfig->getPort());
}
if ($serverConfig->getPrivateKey()) {
$sshOptions[] = '-i ' . escapeshellarg($serverConfig->getPrivateKey());
}
$sshOptions = array_merge($sshOptions, $this->getMultiplexingSshOptions());
exec('ssh ' . implode(' ', $sshOptions) . ' -O check -S ' . $this->getConnectionHash() . ' ' . escapeshellarg($username . $hostname) . ' 2>&1', $checkifMuxActive);
if (!preg_match('/Master running/', $checkifMuxActive[0])) {
if (\Deployer\isVerbose()) {
\Deployer\writeln(' SSH multiplexing initialization');
}
exec('ssh ' . implode(' ', $sshOptions) . ' ' . escapeshellarg($username . $hostname) . " 'echo \"SSH multiplexing initialization\"' ");
}
}
}