X-Git-Url: https://git.phdru.name/?a=blobdiff_plain;f=Robots%2Fbkmk_rforking.py;h=f0e9354a0df4628fad5ef0093c08c652c43697ed;hb=92f5d0b12ed82b7ac51acfa074de7bfad14c1084;hp=da257f6cecba0d741dc6589c87d6a5fa4299d200;hpb=37885488f6f7a735fcacbeb524d9743ac62d5dbb;p=bookmarks_db.git diff --git a/Robots/bkmk_rforking.py b/Robots/bkmk_rforking.py index da257f6..f0e9354 100644 --- a/Robots/bkmk_rforking.py +++ b/Robots/bkmk_rforking.py @@ -1,7 +1,7 @@ """ Forking robot - Written by BroytMann. Copyright (C) 2000-2007 PhiloSoft Design. + Written by Broytman. Copyright (C) 2000-2010 PhiloSoft Design. """ @@ -14,9 +14,9 @@ except ImportError: import sys, os from subproc import Subprocess, RecordFile -# This is to catch 'close failed: [Errno 9] Bad file descriptor' -# message from os.close() in Subprocess.die(). -sys.stderr = open("err.log", 'w') +# This is to catch 'close failed: [Errno 9] Bad file descriptor' message +# from os.close() in Subprocess.die() and errors from from the subprocess. +sys.stderr = open("err.log", 'a') check_subp = None subp_pipe = None @@ -32,7 +32,8 @@ def restart_subp(log): global check_subp, subp_pipe stop_subp(log) - check_subp = Subprocess("%s/Robots/bkmk_rforking_sub.py" % os.path.dirname(sys.argv[0])) + check_subp = Subprocess("%s/Robots/bkmk_rforking_sub.py" % os.path.dirname(sys.argv[0]), + control_stderr=True) subp_pipe = RecordFile(check_subp) @@ -50,11 +51,12 @@ class robot_forking(Robot): bookmark.tempfname = self.tempfname subp_pipe.write_record(pickle.dumps(bookmark)) - if check_subp.waitForPendingChar(900): # wait 15 minutes + if check_subp.waitForPendingChar(60): # wait a minute new_b = pickle.loads(subp_pipe.read_record()) for attr in ("error", "no_error", "moved", "size", "md5", "real_title", - "last_tested", "last_modified", "test_time", "icon"): + "last_tested", "last_modified", "test_time", + "icon", "icon_href"): if hasattr(new_b, attr): setattr(bookmark, attr, getattr(new_b, attr)) else: @@ -63,6 +65,13 @@ class robot_forking(Robot): bookmark.parent = save_parent + while True: + error = check_subp.readPendingErrLine() + if not error: + break + sys.stderr.write("(subp) " + error) + sys.stderr.flush() + except KeyboardInterrupt: return 0