Skip to content

4.2.0 release #2506

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 9 commits into from
Feb 6, 2020
Merged

4.2.0 release #2506

Changes from 1 commit
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
1e56722
set logging level of paramiko to warn
riedel Apr 14, 2019
bc6777e
set host key policy for ssh transport to WarningPolicy()
riedel Apr 14, 2019
ed9b208
obey Hostname Username Port and ProxyCommand settings from .ssh/config
riedel Apr 14, 2019
a67d180
Fix CI labels so we run on amd64 nodes
ndeloof Oct 14, 2019
61e2d5f
Fix win32pipe.WaitNamedPipe throw exception in windows container.
SLdragon Aug 30, 2019
9b0d07f
Version bump
chris-crone Oct 3, 2019
6c29375
Fix ImageCollectionTest.test_pull_multiple flakiness
thaJeztah Jan 3, 2020
6e44d84
Implement context management, lifecycle and unittests.
Jan 17, 2020
ab56784
Bump 4.2.0
ulyssessouza Feb 6, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Fix win32pipe.WaitNamedPipe throw exception in windows container. 
Signed-off-by: Renlong Tu <[email protected]>
  • Loading branch information
@SLdragon @ulyssessouza
SLdragon authored and ulyssessouza committed Feb 6, 2020
commit 61e2d5f69bd189679306e8e3b52d9c109b339f6f
12 changes: 7 additions & 5 deletions docker/transport/npipesocket.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
import functools
import time
import io

import six
Expand All @@ -9,7 +10,7 @@
cSECURITY_SQOS_PRESENT = 0x100000
cSECURITY_ANONYMOUS = 0

RETRY_WAIT_TIMEOUT = 10000
MAXIMUM_RETRY_COUNT = 10


def check_closed(f):
Expand Down Expand Up @@ -46,8 +47,7 @@ def close(self):
self._closed = True

@check_closed
def connect(self, address):
win32pipe.WaitNamedPipe(address, self._timeout)
def connect(self, address, retry_count=0):
try:
handle = win32file.CreateFile(
address,
Expand All @@ -65,8 +65,10 @@ def connect(self, address):
# Another program or thread has grabbed our pipe instance
# before we got to it. Wait for availability and attempt to
# connect again.
win32pipe.WaitNamedPipe(address, RETRY_WAIT_TIMEOUT)
return self.connect(address)
retry_count = retry_count + 1
if (retry_count < MAXIMUM_RETRY_COUNT):
time.sleep(1)
return self.connect(address, retry_count)
raise e

self.flags = win32pipe.GetNamedPipeInfo(handle)[0]
Expand Down