check_subp = None
subp_pipe = None
+
def stop_subp(log):
global check_subp, subp_pipe
if check_subp:
del check_subp
del subp_pipe
+
def restart_subp(log):
global check_subp, subp_pipe
stop_subp(log)
_set_subproc = True
+
class robot_forking(Robot):
- subproc = 'urllib2' # Default subprocess
+ subproc = 'urllib2' # Default subprocess
def check_url(self, bookmark):
global _set_subproc
if attr.startswith('subproc_'):
subproc_attrs.append((attr[len('subproc_'):], getattr(self, attr)))
if subproc_attrs:
- subproc += ':' + ':'.join(['='.join((k,v)) for k,v in subproc_attrs])
+ subproc += ':' + ':'.join(
+ ['='.join((k, v)) for k, v in subproc_attrs]
+ )
os.environ['BKMK_ROBOT'] = subproc
if not check_subp:
- restart_subp(self.log) # Not restart, just start afresh
+ restart_subp(self.log) # Not restart, just start afresh
try:
save_parent = bookmark.parent
bookmark.parent = None
subp_pipe.write_record(pickle.dumps(bookmark))
- if check_subp.waitForPendingChar(60): # wait a minute
+ if check_subp.waitForPendingChar(60): # wait a minute
new_b = pickle.loads(subp_pipe.read_record())
for attr in (
"error", "no_error",
return 1
def stop(self):
- stop_subp(None) # Stop subprocess; do not log restarting
+ stop_subp(None) # Stop subprocess; do not log restarting