47 lines
1.4 KiB
Python
47 lines
1.4 KiB
Python
|
import subprocess
|
||
|
|
|
||
|
|
def wait_net_service(server, port, timeout=None):
|
||
|
|
""" Wait for network service to appear
|
||
|
|
@param timeout: in seconds, if None or 0 wait forever
|
||
|
|
@return: True of False, if timeout is None may return only True or
|
||
|
|
throw unhandled network exception
|
||
|
|
"""
|
||
|
|
import socket
|
||
|
|
import errno
|
||
|
|
|
||
|
|
s = socket.socket()
|
||
|
|
if timeout:
|
||
|
|
from time import time as now
|
||
|
|
# time module is needed to calc timeout shared between two exceptions
|
||
|
|
end = now() + timeout
|
||
|
|
|
||
|
|
while True:
|
||
|
|
try:
|
||
|
|
if timeout:
|
||
|
|
next_timeout = end - now()
|
||
|
|
if next_timeout < 0:
|
||
|
|
return False
|
||
|
|
else:
|
||
|
|
s.settimeout(next_timeout)
|
||
|
|
s.connect((server, port))
|
||
|
|
except socket.timeout as err:
|
||
|
|
# this exception occurs only if timeout is set
|
||
|
|
if timeout:
|
||
|
|
return False
|
||
|
|
except socket.error as err:
|
||
|
|
# catch timeout exception from underlying network library
|
||
|
|
# this one is different from socket.timeout
|
||
|
|
if type(err.args) != tuple or err[0] != errno.ETIMEDOUT:
|
||
|
|
raise
|
||
|
|
else:
|
||
|
|
s.close()
|
||
|
|
return True
|
||
|
|
|
||
|
|
|
||
|
|
def up2date_anyimages():
|
||
|
|
cmd = "docker images -q feedati/*".split()
|
||
|
|
output = subprocess.check_output(cmd).strip()
|
||
|
|
if output:
|
||
|
|
return True
|
||
|
|
return False
|