ClearML/wexpect-venv
1
0
Fork 0
mirror of https://github.com/clearml/wexpect-venv synced 2025-06-26 10:05:49 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

[FIX] align sleep times, now all commands arrives after the before one has been processed.[TST][FIX] destructor and constructor testcases

Browse Source
This commit is contained in:
Benedek Racz 2020-01-22 13:33:09 +01:00
parent 9709eb82e9
commit eda36aa1a1
5 changed files with 33 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tests/test_constructor.py
View File

@ -41,9 +41,12 @@ class TestCaseConstructor(PexpectTestCase.PexpectTestCase):
def test_named_parameters (self):
'''This tests that named parameters work.
'''
p = wexpect.spawn ('ls',timeout=10)
p = wexpect.spawn (timeout=10, command='ls')
p = wexpect.spawn (args=[], command='ls')
p = wexpect.spawn('ls',timeout=10)
p.wait()
p = wexpect.spawn(timeout=10, command='ls')
p.wait()
p = wexpect.spawn(args=[], command='ls')
p.wait()
if __name__ == '__main__':
unittest.main()

46
tests/test_destructor.py
View File

@ -32,35 +32,34 @@ class TestCaseDestructor(PexpectTestCase.PexpectTestCase):
return 'SKIP'
gc.collect()
time.sleep(2)
p1 = wexpect.spawn('"%s" hello_world.py' % self.PYTHONBIN)
p2 = wexpect.spawn('"%s" hello_world.py' % self.PYTHONBIN)
p3 = wexpect.spawn('"%s" hello_world.py' % self.PYTHONBIN)
p4 = wexpect.spawn('"%s" hello_world.py' % self.PYTHONBIN)
fd_t1 = (p1.child_fd,p2.child_fd,p3.child_fd,p4.child_fd)
p1 = wexpect.spawn('ls', port=4321)
p2 = wexpect.spawn('ls', port=4322)
p3 = wexpect.spawn('ls', port=4323)
p4 = wexpect.spawn('ls', port=4324)
p1.expect(wexpect.EOF)
p2.expect(wexpect.EOF)
p3.expect(wexpect.EOF)
p4.expect(wexpect.EOF)
p1.kill(9)
p2.kill(9)
p3.kill(9)
p4.kill(9)
p1.kill()
p2.kill()
p3.kill()
p4.kill()
p1 = None
p2 = None
p3 = None
p4 = None
gc.collect()
time.sleep(2) # Some platforms are slow at gc... Solaris!
p1 = wexpect.spawn('"%s" hello_world.py' % self.PYTHONBIN)
p2 = wexpect.spawn('"%s" hello_world.py' % self.PYTHONBIN)
p3 = wexpect.spawn('"%s" hello_world.py' % self.PYTHONBIN)
p4 = wexpect.spawn('"%s" hello_world.py' % self.PYTHONBIN)
fd_t2 = (p1.child_fd,p2.child_fd,p3.child_fd,p4.child_fd)
p1.kill(9)
p2.kill(9)
p3.kill(9)
p4.kill(9)
p1 = wexpect.spawn('ls', port=4321)
p2 = wexpect.spawn('ls', port=4322)
p3 = wexpect.spawn('ls', port=4323)
p4 = wexpect.spawn('ls', port=4324)
p1.kill()
p2.kill()
p3.kill()
p4.kill()
del (p1)
del (p2)
del (p3)
@ -68,13 +67,10 @@ class TestCaseDestructor(PexpectTestCase.PexpectTestCase):
gc.collect()
time.sleep(2)
p1 = wexpect.spawn('"%s" hello_world.py' % self.PYTHONBIN)
p2 = wexpect.spawn('"%s" hello_world.py' % self.PYTHONBIN)
p3 = wexpect.spawn('"%s" hello_world.py' % self.PYTHONBIN)
p4 = wexpect.spawn('"%s" hello_world.py' % self.PYTHONBIN)
fd_t3 = (p1.child_fd,p2.child_fd,p3.child_fd,p4.child_fd)
assert (fd_t1 == fd_t2 == fd_t3), "pty file descriptors not properly garbage collected (fd_t1,fd_t2,fd_t3)=(%s,%s,%s)" % (str(fd_t1),str(fd_t2),str(fd_t3))
p1 = wexpect.spawn('ls', port=4321)
p2 = wexpect.spawn('ls', port=4322)
p3 = wexpect.spawn('ls', port=4323)
p4 = wexpect.spawn('ls', port=4324)
if __name__ == '__main__':

4
wexpect/console_reader.py
View File

@ -175,7 +175,7 @@ class ConsoleReaderBase:
self.resumeThread()
paused = False
time.sleep(.1)
time.sleep(.02)
def terminate_child(self):
try:
@ -437,7 +437,7 @@ class ConsoleReaderSocket(ConsoleReaderBase):
self.sock.settimeout(5)
self.sock.listen(1)
self.connection, client_address = self.sock.accept()
self.connection.settimeout(.2)
self.connection.settimeout(.01)
logger.info(f'Client connected: {client_address}')
except:
logger.error(f"Port: {self.port}")

4
wexpect/spawn.py
View File

@ -990,6 +990,10 @@ class SpawnSocket(SpawnBase):
except EOF:
self.flag_eof = True
raise
except ConnectionResetError:
self.flag_eof = True
logger.info("EOF('ConnectionResetError')")
raise EOF('ConnectionResetError')
except socket.timeout:
return ''

1
wexpect/wexpect_util.py
View File

@ -44,7 +44,6 @@ import os
import logging
def init_logger(logger):
os.environ['WEXPECT_LOGGER_LEVEL'] = 'DEBUG'
try:
logger_level = os.environ['WEXPECT_LOGGER_LEVEL']
try: