X-Git-Url: https://git.phdru.name/?a=blobdiff_plain;f=Robots%2Fbkmk_rforking.py;h=e1281219c66974d70c1b8d538744638e99bfc315;hb=e2c7ec4349db18acd4c8d0902b0a5ab2cffd5be7;hp=6250af91603cfb8e6125b049e900f33c3be0e9ef;hpb=c2ea4e82718b903aa123dd77490f36657383b0ca;p=bookmarks_db.git diff --git a/Robots/bkmk_rforking.py b/Robots/bkmk_rforking.py index 6250af9..e128121 100644 --- a/Robots/bkmk_rforking.py +++ b/Robots/bkmk_rforking.py @@ -10,7 +10,8 @@ __license__ = "GNU GPL" __all__ = ['robot_forking'] -import sys, os +import os +import sys try: import cPickle as pickle @@ -28,6 +29,7 @@ sys.stderr = open("err.log", 'a') check_subp = None subp_pipe = None + def stop_subp(log): global check_subp, subp_pipe if check_subp: @@ -35,17 +37,20 @@ def stop_subp(log): del check_subp del subp_pipe + 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) _set_subproc = True + class robot_forking(Robot): subproc = 'urllib2' # Default subprocess @@ -58,7 +63,9 @@ class robot_forking(Robot): subproc_attrs = [] for attr in dir(self): if attr.startswith('subproc_'): - subproc_attrs.append((attr[len('subproc_'):], getattr(self, attr))) + subproc_attrs.append( + (attr[len('subproc_'):], getattr(self, attr)) + ) if subproc_attrs: subproc += ':' + ':'.join( ['='.join((k, v)) for k, v in subproc_attrs]