Last active
March 21, 2018 16:18
-
-
Save pldmgg/92b7a6975a7765293579a9bec296aec1 to your computer and use it in GitHub Desktop.
A few functions to help manage Docker For Windows
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| function Start-DockerAfterReboot { | |
| [CmdletBinding()] | |
| Param( | |
| [Parameter(Mandatory=$False)] | |
| [switch]$SkipPrompt | |
| ) | |
| if (!$(Check-Elevation)) { | |
| Write-Error "The $($MyInvocation.MyCommand.Name) function must be run with elevated privileges (i.e. start PowerShell with 'Run As Administrator'). Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| if (!$SkipPrompt) { | |
| Write-Warning "In the Docker For Windows GUI, please be sure to uncheck the 'Start Docker when you log in' checkbox under the 'General' tab!" | |
| $UncheckedCheckBox = Read-Host -Prompt "Did you uncheck the 'Start Docker when you log in' checkbox? [Yes\No]" | |
| while ($UncheckedCheckBox -notmatch "Yes|yes|Y|y|No|no|N|n") { | |
| Write-Host "$UncheckedCheckBox is NOT a valid choice. Please enter 'Yes' or 'No'" | |
| $UncheckedCheckBox = Read-Host -Prompt "Are all Docker Machine Hyper-V VMs 'Off'? [Yes\No]" | |
| } | |
| } | |
| else { | |
| $UncheckedCheckBox = "Yes" | |
| } | |
| if ($UncheckedCheckBox -notmatch "Yes|yes|Y|y") { | |
| Write-Error "User chose not to proceed. Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| try { | |
| $MobyLinuxVMInfo = Get-VM -Name MobyLinuxVM | |
| } | |
| catch { | |
| Write-Error $_ | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| try { | |
| if ($MobyLinuxVMInfo.State -ne "Off") { | |
| Stop-VM -Name MobyLinuxVM | |
| } | |
| } | |
| catch { | |
| Write-Error $_ | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| try { | |
| $DockerServiceInfo = Get-Service com.docker.service | |
| } | |
| catch { | |
| Write-Error $_ | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| if ($DockerServiceInfo.StartupType -ne "Manual") { | |
| $DockerServiceInfo | Set-Service -StartupType Manual | |
| } | |
| $DockerForWindowsProcess = Get-Process "Docker For Windows" -ErrorAction SilentlyContinue | |
| if ($DockerForWindowsProcess) {$DockerForWindowsProcess | Stop-Process -Force} | |
| if ($(Get-Service com.docker.service).Status -eq "Running") { | |
| Stop-Service com.docker.service -Force | |
| } | |
| # IMPORTANT MANUAL STEP: If you have any docker-machine VMs deployed in Hyper-V, make sure they are all OFF. | |
| # Since 'docker' is not running at this point, you can't use `docker-machine ls` to determine which Hyper-V | |
| # VMs are docker machines | |
| if (!$SkipPrompt) { | |
| Write-Warning "At this point, you must make sure that all Docker Machine Hyper-V VMs are 'Off'!" | |
| $AllDockerMachineVMsOff = Read-Host -Prompt "Are all Docker Machine Hyper-V VMs 'Off'? [Yes\No]" | |
| while ($AllDockerMachineVMsOff -notmatch "Yes|yes|Y|y|No|no|N|n") { | |
| Write-Host "$AllDockerMachineVMsOff is NOT a valid choice. Please enter 'Yes' or 'No'" | |
| $AllDockerMachineVMsOff = Read-Host -Prompt "Are all Docker Machine Hyper-V VMs 'Off'? [Yes\No]" | |
| } | |
| } | |
| else { | |
| $AllDockerMachineVMsOff = "Yes" | |
| } | |
| if ($AllDockerMachineVMsOff -notmatch "Yes|yes|Y|y") { | |
| Write-Error "User chose not to proceed. Please note the the com.docker.service is Stopped and 'Docker For Windows.exe' is not running. Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| Start-Service com.docker.service | |
| Write-Host "Sleeping for 30 seconds to give the com.docker.service service time to become ready..." | |
| Start-Sleep -Seconds 30 | |
| & "C:\Program Files\Docker\Docker\Docker For Windows.exe" | |
| Write-Host "Sleeping for 2 minutes to give Docker time to become ready ..." | |
| Start-Sleep -Seconds 120 | |
| # TODO: Find a way to determine from the shell the equivalent of Docker For Windows GUI pop-up saying Docker Started | |
| # and is ready | |
| $DockerStartSuccess = Read-Host -Prompt "Did the Docker GUI report that Docker successfully started? [Yes\No]" | |
| while ($DockerStartSuccess -notmatch "Yes|yes|Y|y|No|no|N|n") { | |
| Write-Host "$DockerStartSuccess is NOT a valid choice. Please enter 'Yes' or 'No'" | |
| $DockerStartSuccess = Read-Host -Prompt "Did the Docker GUI report that Docker successfully started? [Yes\No]" | |
| } | |
| if ($DockerStartSuccess -notmatch "Yes|yes|Y|y") { | |
| Write-Error "User indicated that Docker did not successfully start! Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| # Wait for "Docker For Windows.exe" to tell you that everything is working. | |
| # Once it's up and running, start the docker-machine VMs. You can do this manually, or use | |
| # functions in my gist (shout out to Warren Frame aka RamblingCookieMonster for `Invoke-Parallel` | |
| # https://github.com/RamblingCookieMonster/Invoke-Parallel) | |
| if (![bool]$(Get-Command Get-DockerMachinesPSObjects -ErrorAction SilentlyContinue) -or | |
| ![bool]$(Get-Command Manage-DockerMachines -ErrorAction SilentlyContinue) -or | |
| ![bool]$(Get-Command Restart-DockerMachinesUntilTheyGetIPs -ErrorAction SilentlyContinue) | |
| ) { | |
| $GistUrl = "https://gist.githubusercontent.com/pldmgg/92b7a6975a7765293579a9bec296aec1/raw/8d558de8a55caa36e2071aab11cca22375255c92/DockerForWindowsManagement.ps1" | |
| Invoke-WebRequest -Uri $GistUrl -OutFile "$HOME\Downloads\DockerForWindowsManagement.ps1" | |
| . "$HOME\Downloads\DockerForWindowsManagement.ps1" | |
| } | |
| Restart-DockerMachinesUntilTheyGetIPs | |
| } | |
| function Get-DockerInfo { | |
| $DockerVersionInfo = docker version | |
| [System.Collections.ArrayList]$DockerClientInfo = @() | |
| [System.Collections.ArrayList]$DockerServerInfo = @() | |
| foreach ($line in $DockerVersionInfo) { | |
| if ($line -match "^Client") { | |
| $ClientOrServer = "Client" | |
| } | |
| if ($line -match "^Server") { | |
| $ClientOrServer = "Server" | |
| } | |
| if (![string]::IsNullOrEmpty($line)) { | |
| if ($ClientOrServer -eq "Client" -and $line -notmatch "^Client") { | |
| $null = $DockerClientInfo.Add($line.Trim()) | |
| } | |
| if ($ClientOrServer -eq "Server" -and $line -notmatch "^Server") { | |
| $null = $DockerServerInfo.Add($line.Trim()) | |
| } | |
| } | |
| } | |
| [pscustomobject]$DockerClientPSObject = @{} | |
| [pscustomobject]$DockerServerPSObject = @{} | |
| foreach ($Property in $DockerClientInfo) { | |
| $KeyValuePrep = $Property -split ":[\s]+" | |
| $key = $KeyValuePrep[0].Trim() | |
| $value = $KeyValuePrep[1].Trim() | |
| $null = $DockerClientPSObject.Add($key,$value) | |
| } | |
| foreach ($Property in $DockerServerInfo) { | |
| if ([bool]$($Property -match ":[\s]+")) { | |
| $KeyValuePrep = $Property -split ":[\s]+" | |
| } | |
| elseif ([bool]$($Property -match ":")) { | |
| $KeyValuePrep = $Property -split ":" | |
| } | |
| $key = $KeyValuePrep[0].Trim() | |
| if ($KeyValuePrep[1] -ne $null) { | |
| $value = $KeyValuePrep[1].Trim() | |
| } | |
| $null = $DockerServerPSObject.Add($key,$value) | |
| } | |
| [pscustomobject]@{ | |
| DockerServerInfo = $DockerServerPSObject | |
| DockerClientInfo = $DockerClientPSObject | |
| } | |
| } | |
| function Get-DockerMachinesPSObjects { | |
| [CmdletBinding()] | |
| Param() | |
| if (![bool]$(Get-Command docker -ErrorAction SilentlyContinue)) { | |
| Write-Error "Unable to find the 'docker' command! Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| if (![bool]$(Get-Command docker-machine -ErrorAction SilentlyContinue)) { | |
| Write-Error "Unable to find the 'docker-machine' command! Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| $DockerMachinesPrep = docker-machine ls | |
| if ($($DockerMachinesPrep -split "`n").Count -gt 1) { | |
| $DockerMachinesPrep2 = $($DockerMachinesPrep -split "`n")[1..$($DockerMachinesPrep.Count-1)] | |
| [System.Collections.ArrayList]$DockerMachinesPSObjects = @() | |
| if ($DockerMachinesPrep2) { | |
| foreach ($Line in $DockerMachinesPrep2) { | |
| $ParsedLine = $Line -split " " | Where-Object {![System.String]::IsNullOrWhiteSpace($_)} | |
| if ($ParsedLine[5] -match "v[0-9]|Unknown") { | |
| $Swarm = $null | |
| } | |
| else { | |
| $Swarm = $ParsedLine[5] | |
| } | |
| if ($ParsedLine[5] -match "v[0-9]|Unknown") { | |
| $DockerVersion = $ParsedLine[5] | |
| $DVIndex = 5 | |
| } | |
| elseif ($ParsedLine[6] -match "v[0-9]|Unknown") { | |
| $DockerVersion = $ParsedLine[6] | |
| $DVIndex = 6 | |
| } | |
| $Errors = $ParsedLine[$($DVIndex+1)..$($ParsedLine.Count-1)] | |
| $PSObject = [pscustomobject]@{ | |
| Name = $ParsedLine[0] | |
| Active = $ParsedLine[1] | |
| Driver = $ParsedLine[2] | |
| State = $ParsedLine[3] | |
| Url = $ParsedLine[4] | |
| Swarm = $Swarm | |
| Docker = $DockerVersion | |
| Errors = $Errors -join " " | |
| } | |
| $null = $DockerMachinesPSObjects.Add($PSObject) | |
| } | |
| } | |
| $DockerMachinesPSObjects | |
| } | |
| else { | |
| Write-Verbose "No Docker Machines present" | |
| } | |
| } | |
| function Manage-DockerMachines { | |
| [CmdletBinding()] | |
| Param( | |
| [Parameter(Mandatory=$False)] | |
| [string]$DockerMachineVMName, | |
| [Parameter(Mandatory=$False)] | |
| [switch]$Start, | |
| [Parameter(Mandatory=$False)] | |
| [switch]$Stop, | |
| [Parameter(Mandatory=$False)] | |
| [switch]$Restart | |
| ) | |
| if (![bool]$(Get-Command docker -ErrorAction SilentlyContinue)) { | |
| Write-Error "Unable to find the 'docker' command! Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| if (![bool]$(Get-Command docker-machine -ErrorAction SilentlyContinue)) { | |
| Write-Error "Unable to find the 'docker-machine' command! Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| if ($DockerMachineVMName) { | |
| try { | |
| $VMInfo = Get-VM -Name $DockerMachineVMName | |
| } | |
| catch { | |
| Write-Error $_ | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| } | |
| [array]$DockerMachinesPSObjects = Get-DockerMachinesPSObjects | |
| if ($DockerMachinesPSObjects.Count -gt 0) { | |
| if ($DockerMachineVMName) { | |
| if ($Start) { | |
| docker-machine start $DockerMachineVMName | |
| } | |
| if ($Stop) { | |
| docker-machine stop $DockerMachineVMName | |
| } | |
| if ($Restart) { | |
| docker-machine restart $DockerMachineVMName | |
| } | |
| } | |
| else { | |
| foreach ($DockerMachine in $DockerMachinesPSObjects) { | |
| if ($Start) { | |
| docker-machine start $DockerMachine.Name | |
| } | |
| if ($Stop) { | |
| docker-machine stop $DockerMachine.Name | |
| } | |
| if ($Restart) { | |
| docker-machine restart $DockerMachine.Name | |
| } | |
| } | |
| } | |
| } | |
| else { | |
| Write-Output "No Docker Machine VMs Found" | |
| } | |
| } | |
| function Restart-DockerMachinesUntilTheyGetIPs { | |
| [CmdletBinding()] | |
| Param() | |
| if (![bool]$(Get-Command docker -ErrorAction SilentlyContinue)) { | |
| Write-Error "Unable to find the 'docker' command! Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| if (![bool]$(Get-Command docker-machine -ErrorAction SilentlyContinue)) { | |
| Write-Error "Unable to find the 'docker-machine' command! Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| [array]$DockerMachinesPSObjects = Get-DockerMachinesPSObjects | |
| if ($DockerMachinesPSObjects.Count -gt 1) { | |
| $FunctionsForSBUse = @( | |
| ${Function:Test-IsValidIPAddress}.Ast.Extent.Text | |
| ${Function:Manage-DockerMachines}.Ast.Extent.Text | |
| ) | |
| $DockerMachinesPSObjects | Invoke-Parallel { | |
| foreach ($function in $using:FunctionsForSBUse) {Invoke-Expression $function} | |
| $VMInfo = Get-VM -Name $_.Name | |
| if ($VMInfo.State -eq "Off") { | |
| Start-VM -Name $_.Name | |
| Start-Sleep -Seconds 45 | |
| } | |
| $VMIPAddresses = $(Get-VM -Name $_.Name).NetworkAdapters.IPAddresses | |
| [System.Collections.ArrayList]$FoundIPv4Addresses = @() | |
| foreach ($IPAddr in $VMIPAddresses) { | |
| if (Test-IsValidIPAddress -IPAddress $IPAddr) { | |
| $null = $FoundIPv4Addresses.Add($IPAddr) | |
| } | |
| } | |
| while ($FoundIPv4Addresses.Count -eq 0) { | |
| $ProcessInfo = New-Object System.Diagnostics.ProcessStartInfo | |
| #$ProcessInfo.WorkingDirectory = $(Get-Command docker-machine).Source | Split-Path -Parent | |
| $ProcessInfo.FileName = $(Get-Command docker-machine).Source | |
| $ProcessInfo.RedirectStandardError = $true | |
| $ProcessInfo.RedirectStandardOutput = $true | |
| $ProcessInfo.UseShellExecute = $false | |
| $ProcessInfo.Arguments = "restart $($_.Name)" | |
| $Process = New-Object System.Diagnostics.Process | |
| $Process.StartInfo = $ProcessInfo | |
| $Process.Start() | Out-Null | |
| # Below $FinishedInAlottedTime returns boolean true/false | |
| $FinishedInAlottedTime = $Process.WaitForExit(80000) | |
| if (!$FinishedInAlottedTime) { | |
| $Process.Kill() | |
| } | |
| $stdout = $Process.StandardOutput.ReadToEnd() | |
| $stderr = $Process.StandardError.ReadToEnd() | |
| $DockerMachineRestartResult = $stdout + $stderr | |
| Start-Sleep -Seconds 5 | |
| $VMIPAddresses = $(Get-VM -Name $_.Name).NetworkAdapters.IPAddresses | |
| [System.Collections.ArrayList]$FoundIPv4Addresses = @() | |
| foreach ($IPAddr in $VMIPAddresses) { | |
| if (Test-IsValidIPAddress -IPAddress $IPAddr) { | |
| $null = $FoundIPv4Addresses.Add($IPAddr) | |
| } | |
| } | |
| if ($([bool]$($DockerMachineRestartResult -match "exit status 1") -or !$FinishedInAlottedTime) -and | |
| $FoundIPv4Addresses.Count -eq 0 | |
| ) { | |
| Restart-VM -Name $_.Name -Confirm:$False -Force | |
| } | |
| } | |
| } | |
| } | |
| elseif ($DockerMachinesPSObjects.Count -eq 1) { | |
| $VMInfo = Get-VM -Name $DockerMachinesPSObjects.Name | |
| if ($VMInfo.State -eq "Off") { | |
| Start-VM -Name $DockerMachinesPSObjects.Name | |
| Write-Host "Sleeping for 45 seconds to give Hyper-V VM $($DockerMachinesPSObjects.Name) time to start..." | |
| Start-Sleep -Seconds 45 | |
| } | |
| $VMIPAddresses = $(Get-VM -Name $DockerMachinesPSObjects.Name).NetworkAdapters.IPAddresses | Where-Object {Test-IsValidIPAddress -IPAddress $_} | |
| while (!$VMIPAddresses) { | |
| $ProcessInfo = New-Object System.Diagnostics.ProcessStartInfo | |
| #$ProcessInfo.WorkingDirectory = $(Get-Command docker-machine).Source | Split-Path -Parent | |
| $ProcessInfo.FileName = $(Get-Command docker-machine).Source | |
| $ProcessInfo.RedirectStandardError = $true | |
| $ProcessInfo.RedirectStandardOutput = $true | |
| $ProcessInfo.UseShellExecute = $false | |
| $ProcessInfo.Arguments = "restart $($DockerMachinesPSObjects.Name)" | |
| $Process = New-Object System.Diagnostics.Process | |
| $Process.StartInfo = $ProcessInfo | |
| $Process.Start() | Out-Null | |
| Write-Host "Started 'docker-machine restart $($DockerMachinesPSObjects.Name)' ..." | |
| # Below $FinishedInAlottedTime returns boolean true/false | |
| $FinishedInAlottedTime = $Process.WaitForExit(80000) | |
| if (!$FinishedInAlottedTime) { | |
| $Process.Kill() | |
| } | |
| $stdout = $Process.StandardOutput.ReadToEnd() | |
| $stderr = $Process.StandardError.ReadToEnd() | |
| $DockerMachineRestartResult = $stdout + $stderr | |
| Start-Sleep -Seconds 60 | |
| $VMIPAddresses = $(Get-VM -Name $DockerMachinesPSObjects.Name).NetworkAdapters.IPAddresses | Where-Object {Test-IsValidIPAddress -IPAddress $_} | |
| if ($([bool]$($DockerMachineRestartResult -match "exit status 1") -or !$FinishedInAlottedTime) -and !$VMIPAddresses) { | |
| Restart-VM -Name $DockerMachinesPSObjects.Name -Confirm:$False -Force | |
| } | |
| } | |
| } | |
| else { | |
| Write-Output "No Docker Machine VMs Found" | |
| } | |
| } | |
| function Create-DockerMachineUntilItWorks { | |
| [CmdletBinding()] | |
| Param( | |
| [Parameter(Mandatory=$True)] | |
| [string]$NewDockerMachineName, | |
| [Parameter(Mandatory=$False)] | |
| [string]$vSwitchName, | |
| [Parameter(Mandatory=$False)] | |
| [string]$vSwitchIP | |
| ) | |
| if (![bool]$(Get-Command docker -ErrorAction SilentlyContinue)) { | |
| Write-Error "Unable to find the 'docker' command! Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| if (![bool]$(Get-Command docker-machine -ErrorAction SilentlyContinue)) { | |
| Write-Error "Unable to find the 'docker-machine' command! Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| if ($(!$vSwitchName -and !$vSwitchIP) -or $($vSwitchName -and $vSwitchIP)) { | |
| Write-Error "The $($MyInvocation.MyCommand.Name) function requires either the -vSwitchName parameter or the -vSwitchIP parameter! Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| if ($vSwitchIP) { | |
| if (!$(Test-IsValidIPAddress -IPAddress $vSwitchIP)) { | |
| Write-Error "$vSwitchIP is not a valid IPv4 IP Address! Halting!" | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| try { | |
| $vSwitchAllRelatedInfo = $vSwitchAllRelatedInfo = Get-vSwitchAllRelatedInfo -IPAddress $vSwitchIP -ErrorAction SilentlyContinue -ErrorVariable GVSIErr -WarningAction SilentlyContinue | |
| if (!$vSwitchAllRelatedInfo) {throw "The Get-vSwitchAllRelatedInfo function failed to find the existing Internal vSwitch! Halting!"} | |
| } | |
| catch { | |
| Write-Error $_ | |
| Write-Host "Errors for the Get-vSwitchAllRelatedInfo function are as follows:" | |
| Write-Error $($GVSIErr | Out-String) | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| } | |
| if ($vSwitchName) { | |
| try { | |
| $vSwitchAllRelatedInfo = $vSwitchAllRelatedInfo = Get-vSwitchAllRelatedInfo -vSwitchName $vSwitchName -ErrorAction SilentlyContinue -ErrorVariable GVSIErr -WarningAction SilentlyContinue | |
| if (!$vSwitchAllRelatedInfo) {throw "The Get-vSwitchAllRelatedInfo function failed to find the existing Internal vSwitch! Halting!"} | |
| } | |
| catch { | |
| Write-Error $_ | |
| Write-Host "Errors for the Get-vSwitchAllRelatedInfo function are as follows:" | |
| Write-Error $($GVSIErr | Out-String) | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| } | |
| $FinalvSwitchName = $vSwitchAllRelatedInfo.BasicvSwitchInfo.Name | |
| [array]$DockerMachinesPSObjects = Get-DockerMachinesPSObjects | |
| if ($DockerMachinesPSObjects.Count -gt 0) { | |
| $FinalDockerMachineName = New-UniqueString -ArrayOfStrings $DockerMachinesPSObjects.Name -PossibleNewUniqueString $NewDockerMachineName | |
| } | |
| else { | |
| $FinalDockerMachineName = $NewDockerMachineName | |
| } | |
| # Make sure Docker CE is set to Linux Containers | |
| $DockerInfo = Get-DockerInfo | |
| while ($DockerInfo.DockerServerInfo.'OS/Arch' -ne "linux/amd64") { | |
| Write-Host "Switching Docker CE Container Type from Windows to Linux ..." | |
| Switch-DockerContainerType -ContainerType Linux | |
| Write-Host "Sleeping for 60 seconds to wait for MobyLinuxVM ..." | |
| Start-Sleep -Seconds 60 | |
| $DockerInfo = Get-DockerInfo | |
| } | |
| while (!$VMIPAddresses -or $DockerMachineSSHResult -ne "success") { | |
| # Make sure the VM no longer exists | |
| while ([bool]$(Get-VM -Name $FinalDockerMachineName -ErrorAction SilentlyContinue)) { | |
| Write-Host "Waiting for VM removal from previous loop..." | |
| Start-Sleep -Seconds 10 | |
| } | |
| $ProcessInfo = New-Object System.Diagnostics.ProcessStartInfo | |
| #$ProcessInfo.WorkingDirectory = $(Get-Command docker-machine).Source | Split-Path -Parent | |
| $ProcessInfo.FileName = $(Get-Command docker-machine).Source | |
| $ProcessInfo.RedirectStandardError = $true | |
| $ProcessInfo.RedirectStandardOutput = $true | |
| $ProcessInfo.UseShellExecute = $false | |
| $ProcessInfo.Arguments = "create -d hyperv --hyperv-virtual-switch `"$FinalvSwitchName`" $FinalDockerMachineName" | |
| $Process = New-Object System.Diagnostics.Process | |
| $Process.StartInfo = $ProcessInfo | |
| $Process.Start() | Out-Null | |
| Write-Host "Sleeping for 30 seconds to wait for 'docker-machine create' to actually create and start the VM..." | |
| Start-Sleep -Seconds 30 | |
| # Below $FinishedInAlottedTime returns boolean true/false | |
| Write-Host "Waiting for 'docker-machine create' exit for 90 seconds..." | |
| $FinishedInAlottedTime = $Process.WaitForExit(90000) | |
| if (!$FinishedInAlottedTime) { | |
| Write-Host "'docker-machine create' did not exit in the alotted time. Killing process..." | |
| $Process.Kill() | |
| } | |
| if ($(Get-VM -Name $FinalDockerMachineName).NetworkAdapters.Status -eq "NoContact") { | |
| $NoContact = $True | |
| if ([bool]$(Get-Process docker-machine -ErrorAction SilentlyContinue)) { | |
| Get-Process docker-machine | Stop-Process | |
| } | |
| } | |
| $stdout = $Process.StandardOutput.ReadToEnd() | |
| $stderr = $Process.StandardError.ReadToEnd() | |
| $DockerMachineCreateResult = $stdout + $stderr | |
| [array]$VMIPAddresses = $(Get-VM -Name $FinalDockerMachineName).NetworkAdapters.IPAddresses | Where-Object {Test-IsValidIPAddress -IPAddress $_} | |
| if ($VMIPAddresses.Count -gt 0) { | |
| # Make sure that ssh works | |
| $DockerMachineSSHResult = ssh -o "StrictHostKeyChecking=no" -o "BatchMode=yes" -i "$HOME\.docker\machine\machines\$FinalDockerMachineName\id_rsa" -T -T docker@$($VMIPAddresses[0]) "echo success" | |
| } | |
| if ($VMIPAddresses.Count -eq 0 -or $DockerMachineSSHResult -ne "success" -or $NoContact) { | |
| if ($NoContact) { | |
| Write-Warning "Hyper-V reports that it does not have contact with the VM $FinalDockerMachineName!" | |
| } | |
| elseif ($VMIPAddresses.Count -eq 0) { | |
| Write-Warning "$FinalDockerMachineName did not get an IP Address!" | |
| } | |
| elseif ($DockerMachineSSHResult -ne "success") { | |
| Write-Warning "Unable to succesfully ssh into $FinalDockerMachineName!" | |
| } | |
| $ProcessInfo = New-Object System.Diagnostics.ProcessStartInfo | |
| #$ProcessInfo.WorkingDirectory = $(Get-Command docker-machine).Source | Split-Path -Parent | |
| $ProcessInfo.FileName = $(Get-Command docker-machine).Source | |
| $ProcessInfo.RedirectStandardError = $true | |
| $ProcessInfo.RedirectStandardOutput = $true | |
| $ProcessInfo.UseShellExecute = $false | |
| $ProcessInfo.Arguments = "rm $FinalDockerMachineName -y" | |
| $Process = New-Object System.Diagnostics.Process | |
| $Process.StartInfo = $ProcessInfo | |
| $Process.Start() | Out-Null | |
| # Below $FinishedInAlottedTime returns boolean true/false | |
| Write-Host "Waiting for 'docker-machine rm' exit for 30 seconds..." | |
| $FinishedInAlottedTime = $Process.WaitForExit(30000) | |
| if (!$FinishedInAlottedTime) { | |
| Write-Host "'docker-machine rm' did not finish in the alotted time. Killing docker-machine process and removing VM manually..." | |
| $Process.Kill() | |
| Get-VM -Name $FinalDockerMachineName | Stop-VM -Turnoff -Force -Passthru | Remove-VM -Force | |
| if (Test-Path "$HOME\.docker\machine\machines\$FinalDockerMachineName") { | |
| Remove-Item "$HOME\.docker\machine\machines\$FinalDockerMachineName" -Recurse -Force | |
| } | |
| } | |
| $stdout = $Process.StandardOutput.ReadToEnd() | |
| $stderr = $Process.StandardError.ReadToEnd() | |
| $DockerMachineDestroyResult = $stdout + $stderr | |
| } | |
| } | |
| # At this point, the VM might have an IP, but the certs might still be screwed up, so... | |
| $ProcessInfo = New-Object System.Diagnostics.ProcessStartInfo | |
| #$ProcessInfo.WorkingDirectory = $(Get-Command docker-machine).Source | Split-Path -Parent | |
| $ProcessInfo.FileName = $(Get-Command docker-machine).Source | |
| $ProcessInfo.RedirectStandardError = $true | |
| $ProcessInfo.RedirectStandardOutput = $true | |
| $ProcessInfo.UseShellExecute = $false | |
| $ProcessInfo.Arguments = "env $FinalDockerMachineName" | |
| $Process = New-Object System.Diagnostics.Process | |
| $Process.StartInfo = $ProcessInfo | |
| $Process.Start() | Out-Null | |
| # Below $FinishedInAlottedTime returns boolean true/false | |
| Write-Host "Waiting for exit for 20 seconds..." | |
| $FinishedInAlottedTime = $Process.WaitForExit(20000) | |
| if (!$FinishedInAlottedTime) { | |
| $Process.Kill() | |
| } | |
| $stdout = $Process.StandardOutput.ReadToEnd() | |
| $stderr = $Process.StandardError.ReadToEnd() | |
| $DockerMachineEnvResult = $stdout + $stderr | |
| if ([bool]$($DockerMachineEnvResult -match "Error checking TLS connection")) { | |
| docker-machine regenerate-certs $FinalDockerMachineName --force | |
| } | |
| } | |
| function Switch-DockerContainerType { | |
| [CmdletBinding()] | |
| Param ( | |
| [Parameter(Mandatory=$True)] | |
| [ValidateSet("Windows","Linux")] | |
| [string]$ContainerType | |
| ) | |
| try { | |
| # Find DockerCli | |
| $DockerCliExePath = $(Get-ChildItem -Path "$env:ProgramFiles\Docker" -Recurse -File -Filter "*DockerCli.exe").FullName | |
| if (!$DockerCliExePath) { | |
| throw "Unable to find DockerCli.exe! Halting!" | |
| } | |
| } | |
| catch { | |
| Write-Error $_ | |
| $global:FunctionResult = "1" | |
| return | |
| } | |
| $DockerInfo = Get-DockerInfo | |
| if ($($DockerInfo.DockerServerInfo.'OS/Arch' -match "windows" -and $ContainerType -eq "Linux") -or | |
| $($DockerInfo.DockerServerInfo.'OS/Arch' -match "linux" -and $ContainerType -eq "Windows")) { | |
| & $DockerCliExePath -SwitchDaemon | |
| [pscustomobject]@{ | |
| OriginalDockerServerArch = $DockerInfo.DockerServerInfo.'OS/Arch' | |
| NewDockerServerArch = $($($(docker version) -match "OS/Arch")[1] -split ":[\s]+")[1].Trim() | |
| } | |
| } | |
| else { | |
| Write-Warning "The Docker Daemon is already set to manage $ContainerType containers! No action taken." | |
| } | |
| } | |
| function Check-Elevation { | |
| if ($PSVersionTable.PSEdition -eq "Desktop" -or $PSVersionTable.Platform -eq "Win32NT" -or $PSVersionTable.PSVersion.Major -le 5) { | |
| [System.Security.Principal.WindowsPrincipal]$currentPrincipal = New-Object System.Security.Principal.WindowsPrincipal( | |
| [System.Security.Principal.WindowsIdentity]::GetCurrent() | |
| ) | |
| [System.Security.Principal.WindowsBuiltInRole]$administratorsRole = [System.Security.Principal.WindowsBuiltInRole]::Administrator | |
| if($currentPrincipal.IsInRole($administratorsRole)) { | |
| return $true | |
| } | |
| else { | |
| return $false | |
| } | |
| } | |
| if ($PSVersionTable.Platform -eq "Unix") { | |
| if ($(whoami) -eq "root") { | |
| return $true | |
| } | |
| else { | |
| return $false | |
| } | |
| } | |
| } | |
| <# | |
| .SYNOPSIS | |
| Function to control parallel processing using runspaces | |
| .DESCRIPTION | |
| Function to control parallel processing using runspaces | |
| Note that each runspace will not have access to variables and commands loaded in your session or in other runspaces by default. | |
| This behaviour can be changed with parameters. | |
| .PARAMETER ScriptFile | |
| File to run against all input objects. Must include parameter to take in the input object, or use $args. Optionally, include parameter to take in parameter. Example: C:\script.ps1 | |
| .PARAMETER ScriptBlock | |
| Scriptblock to run against all computers. | |
| You may use $Using:<Variable> language in PowerShell 3 and later. | |
| The parameter block is added for you, allowing behaviour similar to foreach-object: | |
| Refer to the input object as $_. | |
| Refer to the parameter parameter as $parameter | |
| .PARAMETER InputObject | |
| Run script against these specified objects. | |
| .PARAMETER Parameter | |
| This object is passed to every script block. You can use it to pass information to the script block; for example, the path to a logging folder | |
| Reference this object as $parameter if using the scriptblock parameterset. | |
| .PARAMETER ImportVariables | |
| If specified, get user session variables and add them to the initial session state | |
| .PARAMETER ImportModules | |
| If specified, get loaded modules and pssnapins, add them to the initial session state | |
| .PARAMETER Throttle | |
| Maximum number of threads to run at a single time. | |
| .PARAMETER SleepTimer | |
| Milliseconds to sleep after checking for completed runspaces and in a few other spots. I would not recommend dropping below 200 or increasing above 500 | |
| .PARAMETER RunspaceTimeout | |
| Maximum time in seconds a single thread can run. If execution of your code takes longer than this, it is disposed. Default: 0 (seconds) | |
| WARNING: Using this parameter requires that maxQueue be set to throttle (it will be by default) for accurate timing. Details here: | |
| http://gallery.technet.microsoft.com/Run-Parallel-Parallel-377fd430 | |
| .PARAMETER NoCloseOnTimeout | |
| Do not dispose of timed out tasks or attempt to close the runspace if threads have timed out. This will prevent the script from hanging in certain situations where threads become non-responsive, at the expense of leaking memory within the PowerShell host. | |
| .PARAMETER MaxQueue | |
| Maximum number of powershell instances to add to runspace pool. If this is higher than $throttle, $timeout will be inaccurate | |
| If this is equal or less than throttle, there will be a performance impact | |
| The default value is $throttle times 3, if $runspaceTimeout is not specified | |
| The default value is $throttle, if $runspaceTimeout is specified | |
| .PARAMETER LogFile | |
| Path to a file where we can log results, including run time for each thread, whether it completes, completes with errors, or times out. | |
| .PARAMETER AppendLog | |
| Append to existing log | |
| .PARAMETER Quiet | |
| Disable progress bar | |
| .EXAMPLE | |
| Each example uses Test-ForPacs.ps1 which includes the following code: | |
| param($computer) | |
| if(test-connection $computer -count 1 -quiet -BufferSize 16){ | |
| $object = [pscustomobject] @{ | |
| Computer=$computer; | |
| Available=1; | |
| Kodak=$( | |
| if((test-path "\\$computer\c$\users\public\desktop\Kodak Direct View Pacs.url") -or (test-path "\\$computer\c$\documents and settings\all users\desktop\Kodak Direct View Pacs.url") ){"1"}else{"0"} | |
| ) | |
| } | |
| } | |
| else{ | |
| $object = [pscustomobject] @{ | |
| Computer=$computer; | |
| Available=0; | |
| Kodak="NA" | |
| } | |
| } | |
| $object | |
| .EXAMPLE | |
| Invoke-Parallel -scriptfile C:\public\Test-ForPacs.ps1 -inputobject $(get-content C:\pcs.txt) -runspaceTimeout 10 -throttle 10 | |
| Pulls list of PCs from C:\pcs.txt, | |
| Runs Test-ForPacs against each | |
| If any query takes longer than 10 seconds, it is disposed | |
| Only run 10 threads at a time | |
| .EXAMPLE | |
| Invoke-Parallel -scriptfile C:\public\Test-ForPacs.ps1 -inputobject c-is-ts-91, c-is-ts-95 | |
| Runs against c-is-ts-91, c-is-ts-95 (-computername) | |
| Runs Test-ForPacs against each | |
| .EXAMPLE | |
| $stuff = [pscustomobject] @{ | |
| ContentFile = "windows\system32\drivers\etc\hosts" | |
| Logfile = "C:\temp\log.txt" | |
| } | |
| $computers | Invoke-Parallel -parameter $stuff { | |
| $contentFile = join-path "\\$_\c$" $parameter.contentfile | |
| Get-Content $contentFile | | |
| set-content $parameter.logfile | |
| } | |
| This example uses the parameter argument. This parameter is a single object. To pass multiple items into the script block, we create a custom object (using a PowerShell v3 language) with properties we want to pass in. | |
| Inside the script block, $parameter is used to reference this parameter object. This example sets a content file, gets content from that file, and sets it to a predefined log file. | |
| .EXAMPLE | |
| $test = 5 | |
| 1..2 | Invoke-Parallel -ImportVariables {$_ * $test} | |
| Add variables from the current session to the session state. Without -ImportVariables $Test would not be accessible | |
| .EXAMPLE | |
| $test = 5 | |
| 1..2 | Invoke-Parallel {$_ * $Using:test} | |
| Reference a variable from the current session with the $Using:<Variable> syntax. Requires PowerShell 3 or later. Note that -ImportVariables parameter is no longer necessary. | |
| .FUNCTIONALITY | |
| PowerShell Language | |
| .NOTES | |
| Credit to Boe Prox for the base runspace code and $Using implementation | |
| http://learn-powershell.net/2012/05/10/speedy-network-information-query-using-powershell/ | |
| http://gallery.technet.microsoft.com/scriptcenter/Speedy-Network-Information-5b1406fb#content | |
| https://github.com/proxb/PoshRSJob/ | |
| Credit to T Bryce Yehl for the Quiet and NoCloseOnTimeout implementations | |
| Credit to Sergei Vorobev for the many ideas and contributions that have improved functionality, reliability, and ease of use | |
| .LINK | |
| https://github.com/RamblingCookieMonster/Invoke-Parallel | |
| #> | |
| function Invoke-Parallel { | |
| [cmdletbinding(DefaultParameterSetName='ScriptBlock')] | |
| Param ( | |
| [Parameter(Mandatory=$false,position=0,ParameterSetName='ScriptBlock')] | |
| [System.Management.Automation.ScriptBlock]$ScriptBlock, | |
| [Parameter(Mandatory=$false,ParameterSetName='ScriptFile')] | |
| [ValidateScript({Test-Path $_ -pathtype leaf})] | |
| $ScriptFile, | |
| [Parameter(Mandatory=$true,ValueFromPipeline=$true)] | |
| [Alias('CN','__Server','IPAddress','Server','ComputerName')] | |
| [PSObject]$InputObject, | |
| [PSObject]$Parameter, | |
| [switch]$ImportVariables, | |
| [switch]$ImportModules, | |
| [switch]$ImportFunctions, | |
| [int]$Throttle = 20, | |
| [int]$SleepTimer = 200, | |
| [int]$RunspaceTimeout = 0, | |
| [switch]$NoCloseOnTimeout = $false, | |
| [int]$MaxQueue, | |
| [validatescript({Test-Path (Split-Path $_ -parent)})] | |
| [switch] $AppendLog = $false, | |
| [string]$LogFile, | |
| [switch] $Quiet = $false | |
| ) | |
| begin { | |
| #No max queue specified? Estimate one. | |
| #We use the script scope to resolve an odd PowerShell 2 issue where MaxQueue isn't seen later in the function | |
| if( -not $PSBoundParameters.ContainsKey('MaxQueue') ) { | |
| if($RunspaceTimeout -ne 0){ $script:MaxQueue = $Throttle } | |
| else{ $script:MaxQueue = $Throttle * 3 } | |
| } | |
| else { | |
| $script:MaxQueue = $MaxQueue | |
| } | |
| Write-Verbose "Throttle: '$throttle' SleepTimer '$sleepTimer' runSpaceTimeout '$runspaceTimeout' maxQueue '$maxQueue' logFile '$logFile'" | |
| #If they want to import variables or modules, create a clean runspace, get loaded items, use those to exclude items | |
| if ($ImportVariables -or $ImportModules -or $ImportFunctions) { | |
| $StandardUserEnv = [powershell]::Create().addscript({ | |
| #Get modules, snapins, functions in this clean runspace | |
| $Modules = Get-Module | Select-Object -ExpandProperty Name | |
| $Snapins = Get-PSSnapin | Select-Object -ExpandProperty Name | |
| $Functions = Get-ChildItem function:\ | Select-Object -ExpandProperty Name | |
| #Get variables in this clean runspace | |
| #Called last to get vars like $? into session | |
| $Variables = Get-Variable | Select-Object -ExpandProperty Name | |
| #Return a hashtable where we can access each. | |
| @{ | |
| Variables = $Variables | |
| Modules = $Modules | |
| Snapins = $Snapins | |
| Functions = $Functions | |
| } | |
| }).invoke()[0] | |
| if ($ImportVariables) { | |
| #Exclude common parameters, bound parameters, and automatic variables | |
| Function _temp {[cmdletbinding(SupportsShouldProcess=$True)] param() } | |
| $VariablesToExclude = @( (Get-Command _temp | Select-Object -ExpandProperty parameters).Keys + $PSBoundParameters.Keys + $StandardUserEnv.Variables ) | |
| Write-Verbose "Excluding variables $( ($VariablesToExclude | Sort-Object ) -join ", ")" | |
| # we don't use 'Get-Variable -Exclude', because it uses regexps. | |
| # One of the veriables that we pass is '$?'. | |
| # There could be other variables with such problems. | |
| # Scope 2 required if we move to a real module | |
| $UserVariables = @( Get-Variable | Where-Object { -not ($VariablesToExclude -contains $_.Name) } ) | |
| Write-Verbose "Found variables to import: $( ($UserVariables | Select-Object -expandproperty Name | Sort-Object ) -join ", " | Out-String).`n" | |
| } | |
| if ($ImportModules) { | |
| $UserModules = @( Get-Module | Where-Object {$StandardUserEnv.Modules -notcontains $_.Name -and (Test-Path $_.Path -ErrorAction SilentlyContinue)} | Select-Object -ExpandProperty Path ) | |
| $UserSnapins = @( Get-PSSnapin | Select-Object -ExpandProperty Name | Where-Object {$StandardUserEnv.Snapins -notcontains $_ } ) | |
| } | |
| if($ImportFunctions) { | |
| $UserFunctions = @( Get-ChildItem function:\ | Where-Object { $StandardUserEnv.Functions -notcontains $_.Name } ) | |
| } | |
| } | |
| #region functions | |
| Function Get-RunspaceData { | |
| [cmdletbinding()] | |
| param( [switch]$Wait ) | |
| #loop through runspaces | |
| #if $wait is specified, keep looping until all complete | |
| Do { | |
| #set more to false for tracking completion | |
| $more = $false | |
| #Progress bar if we have inputobject count (bound parameter) | |
| if (-not $Quiet) { | |
| Write-Progress -Activity "Running Query" -Status "Starting threads"` | |
| -CurrentOperation "$startedCount threads defined - $totalCount input objects - $script:completedCount input objects processed"` | |
| -PercentComplete $( Try { $script:completedCount / $totalCount * 100 } Catch {0} ) | |
| } | |
| #run through each runspace. | |
| Foreach($runspace in $runspaces) { | |
| #get the duration - inaccurate | |
| $currentdate = Get-Date | |
| $runtime = $currentdate - $runspace.startTime | |
| $runMin = [math]::Round( $runtime.totalminutes ,2 ) | |
| #set up log object | |
| $log = "" | Select-Object Date, Action, Runtime, Status, Details | |
| $log.Action = "Removing:'$($runspace.object)'" | |
| $log.Date = $currentdate | |
| $log.Runtime = "$runMin minutes" | |
| #If runspace completed, end invoke, dispose, recycle, counter++ | |
| If ($runspace.Runspace.isCompleted) { | |
| $script:completedCount++ | |
| #check if there were errors | |
| if($runspace.powershell.Streams.Error.Count -gt 0) { | |
| #set the logging info and move the file to completed | |
| $log.status = "CompletedWithErrors" | |
| Write-Verbose ($log | ConvertTo-Csv -Delimiter ";" -NoTypeInformation)[1] | |
| foreach($ErrorRecord in $runspace.powershell.Streams.Error) { | |
| Write-Error -ErrorRecord $ErrorRecord | |
| } | |
| } | |
| else { | |
| #add logging details and cleanup | |
| $log.status = "Completed" | |
| Write-Verbose ($log | ConvertTo-Csv -Delimiter ";" -NoTypeInformation)[1] | |
| } | |
| #everything is logged, clean up the runspace | |
| $runspace.powershell.EndInvoke($runspace.Runspace) | |
| $runspace.powershell.dispose() | |
| $runspace.Runspace = $null | |
| $runspace.powershell = $null | |
| } | |
| #If runtime exceeds max, dispose the runspace | |
| ElseIf ( $runspaceTimeout -ne 0 -and $runtime.totalseconds -gt $runspaceTimeout) { | |
| $script:completedCount++ | |
| $timedOutTasks = $true | |
| #add logging details and cleanup | |
| $log.status = "TimedOut" | |
| Write-Verbose ($log | ConvertTo-Csv -Delimiter ";" -NoTypeInformation)[1] | |
| Write-Error "Runspace timed out at $($runtime.totalseconds) seconds for the object:`n$($runspace.object | out-string)" | |
| #Depending on how it hangs, we could still get stuck here as dispose calls a synchronous method on the powershell instance | |
| if (!$noCloseOnTimeout) { $runspace.powershell.dispose() } | |
| $runspace.Runspace = $null | |
| $runspace.powershell = $null | |
| $completedCount++ | |
| } | |
| #If runspace isn't null set more to true | |
| ElseIf ($runspace.Runspace -ne $null ) { | |
| $log = $null | |
| $more = $true | |
| } | |
| #log the results if a log file was indicated | |
| if($logFile -and $log) { | |
| ($log | ConvertTo-Csv -Delimiter ";" -NoTypeInformation)[1] | out-file $LogFile -append | |
| } | |
| } | |
| #Clean out unused runspace jobs | |
| $temphash = $runspaces.clone() | |
| $temphash | Where-Object { $_.runspace -eq $Null } | ForEach-Object { | |
| $Runspaces.remove($_) | |
| } | |
| #sleep for a bit if we will loop again | |
| if($PSBoundParameters['Wait']){ Start-Sleep -milliseconds $SleepTimer } | |
| #Loop again only if -wait parameter and there are more runspaces to process | |
| } while ($more -and $PSBoundParameters['Wait']) | |
| #End of runspace function | |
| } | |
| #endregion functions | |
| #region Init | |
| if($PSCmdlet.ParameterSetName -eq 'ScriptFile') { | |
| $ScriptBlock = [scriptblock]::Create( $(Get-Content $ScriptFile | out-string) ) | |
| } | |
| elseif($PSCmdlet.ParameterSetName -eq 'ScriptBlock') { | |
| #Start building parameter names for the param block | |
| [string[]]$ParamsToAdd = '$_' | |
| if( $PSBoundParameters.ContainsKey('Parameter') ) { | |
| $ParamsToAdd += '$Parameter' | |
| } | |
| $UsingVariableData = $Null | |
| # This code enables $Using support through the AST. | |
| # This is entirely from Boe Prox, and his https://github.com/proxb/PoshRSJob module; all credit to Boe! | |
| if($PSVersionTable.PSVersion.Major -gt 2) { | |
| #Extract using references | |
| $UsingVariables = $ScriptBlock.ast.FindAll({$args[0] -is [System.Management.Automation.Language.UsingExpressionAst]},$True) | |
| If ($UsingVariables) { | |
| $List = New-Object 'System.Collections.Generic.List`1[System.Management.Automation.Language.VariableExpressionAst]' | |
| ForEach ($Ast in $UsingVariables) { | |
| [void]$list.Add($Ast.SubExpression) | |
| } | |
| $UsingVar = $UsingVariables | Group-Object -Property SubExpression | ForEach-Object {$_.Group | Select-Object -First 1} | |
| #Extract the name, value, and create replacements for each | |
| $UsingVariableData = ForEach ($Var in $UsingVar) { | |
| try { | |
| $Value = Get-Variable -Name $Var.SubExpression.VariablePath.UserPath -ErrorAction Stop | |
| [pscustomobject]@{ | |
| Name = $Var.SubExpression.Extent.Text | |
| Value = $Value.Value | |
| NewName = ('$__using_{0}' -f $Var.SubExpression.VariablePath.UserPath) | |
| NewVarName = ('__using_{0}' -f $Var.SubExpression.VariablePath.UserPath) | |
| } | |
| } | |
| catch { | |
| Write-Error "$($Var.SubExpression.Extent.Text) is not a valid Using: variable!" | |
| } | |
| } | |
| $ParamsToAdd += $UsingVariableData | Select-Object -ExpandProperty NewName -Unique | |
| $NewParams = $UsingVariableData.NewName -join ', ' | |
| $Tuple = [Tuple]::Create($list, $NewParams) | |
| $bindingFlags = [Reflection.BindingFlags]"Default,NonPublic,Instance" | |
| $GetWithInputHandlingForInvokeCommandImpl = ($ScriptBlock.ast.gettype().GetMethod('GetWithInputHandlingForInvokeCommandImpl',$bindingFlags)) | |
| $StringScriptBlock = $GetWithInputHandlingForInvokeCommandImpl.Invoke($ScriptBlock.ast,@($Tuple)) | |
| $ScriptBlock = [scriptblock]::Create($StringScriptBlock) | |
| Write-Verbose $StringScriptBlock | |
| } | |
| } | |
| $ScriptBlock = $ExecutionContext.InvokeCommand.NewScriptBlock("param($($ParamsToAdd -Join ", "))`r`n" + $Scriptblock.ToString()) | |
| } | |
| else { | |
| Throw "Must provide ScriptBlock or ScriptFile"; Break | |
| } | |
| Write-Debug "`$ScriptBlock: $($ScriptBlock | Out-String)" | |
| Write-Verbose "Creating runspace pool and session states" | |
| #If specified, add variables and modules/snapins to session state | |
| $sessionstate = [System.Management.Automation.Runspaces.InitialSessionState]::CreateDefault() | |
| if($ImportVariables -and $UserVariables.count -gt 0) { | |
| foreach($Variable in $UserVariables) { | |
| $sessionstate.Variables.Add((New-Object -TypeName System.Management.Automation.Runspaces.SessionStateVariableEntry -ArgumentList $Variable.Name, $Variable.Value, $null) ) | |
| } | |
| } | |
| if ($ImportModules) { | |
| if($UserModules.count -gt 0) { | |
| foreach($ModulePath in $UserModules) { | |
| $sessionstate.ImportPSModule($ModulePath) | |
| } | |
| } | |
| if($UserSnapins.count -gt 0) { | |
| foreach($PSSnapin in $UserSnapins) { | |
| [void]$sessionstate.ImportPSSnapIn($PSSnapin, [ref]$null) | |
| } | |
| } | |
| } | |
| if($ImportFunctions -and $UserFunctions.count -gt 0) { | |
| foreach ($FunctionDef in $UserFunctions) { | |
| $sessionstate.Commands.Add((New-Object System.Management.Automation.Runspaces.SessionStateFunctionEntry -ArgumentList $FunctionDef.Name,$FunctionDef.ScriptBlock)) | |
| } | |
| } | |
| #Create runspace pool | |
| $runspacepool = [runspacefactory]::CreateRunspacePool(1, $Throttle, $sessionstate, $Host) | |
| $runspacepool.Open() | |
| Write-Verbose "Creating empty collection to hold runspace jobs" | |
| $Script:runspaces = New-Object System.Collections.ArrayList | |
| #If inputObject is bound get a total count and set bound to true | |
| $bound = $PSBoundParameters.keys -contains "InputObject" | |
| if(-not $bound) { | |
| [System.Collections.ArrayList]$allObjects = @() | |
| } | |
| #Set up log file if specified | |
| if( $LogFile -and (-not (Test-Path $LogFile) -or $AppendLog -eq $false)){ | |
| New-Item -ItemType file -Path $logFile -Force | Out-Null | |
| ("" | Select-Object -Property Date, Action, Runtime, Status, Details | ConvertTo-Csv -NoTypeInformation -Delimiter ";")[0] | Out-File $LogFile | |
| } | |
| #write initial log entry | |
| $log = "" | Select-Object -Property Date, Action, Runtime, Status, Details | |
| $log.Date = Get-Date | |
| $log.Action = "Batch processing started" | |
| $log.Runtime = $null | |
| $log.Status = "Started" | |
| $log.Details = $null | |
| if($logFile) { | |
| ($log | convertto-csv -Delimiter ";" -NoTypeInformation)[1] | Out-File $LogFile -Append | |
| } | |
| $timedOutTasks = $false | |
| #endregion INIT | |
| } | |
| process { | |
| #add piped objects to all objects or set all objects to bound input object parameter | |
| if($bound) { | |
| $allObjects = $InputObject | |
| } | |
| else { | |
| [void]$allObjects.add( $InputObject ) | |
| } | |
| } | |
| end { | |
| #Use Try/Finally to catch Ctrl+C and clean up. | |
| try { | |
| #counts for progress | |
| $totalCount = $allObjects.count | |
| $script:completedCount = 0 | |
| $startedCount = 0 | |
| foreach($object in $allObjects) { | |
| #region add scripts to runspace pool | |
| #Create the powershell instance, set verbose if needed, supply the scriptblock and parameters | |
| $powershell = [powershell]::Create() | |
| if ($VerbosePreference -eq 'Continue') { | |
| [void]$PowerShell.AddScript({$VerbosePreference = 'Continue'}) | |
| } | |
| [void]$PowerShell.AddScript($ScriptBlock).AddArgument($object) | |
| if ($parameter) { | |
| [void]$PowerShell.AddArgument($parameter) | |
| } | |
| # $Using support from Boe Prox | |
| if ($UsingVariableData) { | |
| Foreach($UsingVariable in $UsingVariableData) { | |
| Write-Verbose "Adding $($UsingVariable.Name) with value: $($UsingVariable.Value)" | |
| [void]$PowerShell.AddArgument($UsingVariable.Value) | |
| } | |
| } | |
| #Add the runspace into the powershell instance | |
| $powershell.RunspacePool = $runspacepool | |
| #Create a temporary collection for each runspace | |
| $temp = "" | Select-Object PowerShell, StartTime, object, Runspace | |
| $temp.PowerShell = $powershell | |
| $temp.StartTime = Get-Date | |
| $temp.object = $object | |
| #Save the handle output when calling BeginInvoke() that will be used later to end the runspace | |
| $temp.Runspace = $powershell.BeginInvoke() | |
| $startedCount++ | |
| #Add the temp tracking info to $runspaces collection | |
| Write-Verbose ( "Adding {0} to collection at {1}" -f $temp.object, $temp.starttime.tostring() ) | |
| $runspaces.Add($temp) | Out-Null | |
| #loop through existing runspaces one time | |
| Get-RunspaceData | |
| #If we have more running than max queue (used to control timeout accuracy) | |
| #Script scope resolves odd PowerShell 2 issue | |
| $firstRun = $true | |
| while ($runspaces.count -ge $Script:MaxQueue) { | |
| #give verbose output | |
| if($firstRun) { | |
| Write-Verbose "$($runspaces.count) items running - exceeded $Script:MaxQueue limit." | |
| } | |
| $firstRun = $false | |
| #run get-runspace data and sleep for a short while | |
| Get-RunspaceData | |
| Start-Sleep -Milliseconds $sleepTimer | |
| } | |
| #endregion add scripts to runspace pool | |
| } | |
| Write-Verbose ( "Finish processing the remaining runspace jobs: {0}" -f ( @($runspaces | Where-Object {$_.Runspace -ne $Null}).Count) ) | |
| Get-RunspaceData -wait | |
| if (-not $quiet) { | |
| Write-Progress -Activity "Running Query" -Status "Starting threads" -Completed | |
| } | |
| } | |
| finally { | |
| #Close the runspace pool, unless we specified no close on timeout and something timed out | |
| if ( ($timedOutTasks -eq $false) -or ( ($timedOutTasks -eq $true) -and ($noCloseOnTimeout -eq $false) ) ) { | |
| Write-Verbose "Closing the runspace pool" | |
| $runspacepool.close() | |
| } | |
| #collect garbage | |
| [gc]::Collect() | |
| } | |
| } | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment