Hopiu/linkchecker
1
0
Fork 0
mirror of https://github.com/Hopiu/linkchecker.git synced 2026-03-26 02:40:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

thread name and maximum wait for finish

Browse source 
git-svn-id: https://linkchecker.svn.sourceforge.net/svnroot/linkchecker/trunk/linkchecker@2611 e7d03fd6-7b0d-0410-9947-9c21f3af8025
This commit is contained in:
calvin 2005-05-18 22:15:18 +00:00
parent 3db056f161
commit fd652881fb
1 changed files with 15 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
linkcheck/checker/consumer.py
View file

@ -89,7 +89,13 @@ class Consumer (linkcheck.lock.AssertLock):
else:
# go check this url
# this calls either self.checked() or self.interrupted()
self.threader.start_thread(url_data.check, ())
if url_data.parent_url and \
not linkcheck.url.url_is_absolute(url_data.base_url):
name = url_data.parent_url
else:
name = u""
name += url_data.base_url
self.threader.start_thread(url_data.check, (), name=name)
def checked (self, url_data):
"""
@ -136,7 +142,14 @@ class Consumer (linkcheck.lock.AssertLock):
Abort checking and send end-of-output message to logger.
"""
# wait for threads to finish
num_waited = 0
wait_max = 30
while not self.no_more_threads():
if num_waited > wait_max:
linkcheck.log.error(linkcheck.LOG_CHECK,
"Thread wait timeout")
self.logger_end_output()
sys.exit(1)
num = self.active_threads()
msg = \
_n("keyboard interrupt; waiting for %d active thread to finish",
@ -148,6 +161,7 @@ class Consumer (linkcheck.lock.AssertLock):
self.threader.finish()
finally:
self.release()
num_waited += 1
time.sleep(2)
self.logger_end_output()