def _spawn_transform_service(self):
"""Launch transform service and get pid."""
status = 0
pid = os.fork()
if pid == 0:
try:
os.setsid()
# start transform service
launcher = oslo_service.service.launch(
self.conf,
transform_service.Transform(),
workers=1)
status = launcher.wait()
except SystemExit as exc:
traceback.print_exc()
status = exc.code
except BaseException:
try:
traceback.print_exc()
except BaseException:
print("Could not print traceback")
status = 2
os._exit(status or 0)
return pid
python类_exit()的实例源码
def ShowOnePage(self, now_page_items, page):
for idx, item in enumerate(now_page_items):
print "\ndownload " + item[1]
self.saveFile(item[0], page, idx)
#print '========one page done.================='
print '========Please hit the Enter.================='
if self.unload_page_num == page:
print '========all pages done. clean the repeated files.=========='
self.CleanRepeatImage() #at last, deal with the repeated images.
print 'Nothing left. Now close this application.'
# self.enable = False #let the main thread know it's time to quit
os._exit(0) #can teminal main thread.
# ???????
time.sleep(1)
print 'take a snap for 1s.'
# myInput = raw_input()
# if myInput == ":q":
# self.CleanRepeatImage() #if break manually, must clean work dir.
# self.enable = False
# deal with the repeated image
def serve_forever(self, poll_interval=0.1):
"""Fork the current process and wait for all children to finish."""
if self.prefork is None or self.prefork <= 1:
return super(_SporkMixIn, self).serve_forever(
poll_interval=poll_interval)
pids = []
for dummy in range(self.prefork):
pid = os.fork()
if not pid:
super(_SporkMixIn, self).serve_forever(
poll_interval=poll_interval)
os._exit(0)
else:
self.log.info("Forked worker %s", pid)
pids.append(pid)
self.pids = pids
for pid in self.pids:
_eintr_retry(os.waitpid, pid, 0)
def run(self):
self.log.info("Python Version: {}".format(sys.version_info))
is_success = True
try:
self.initial_action()
self.process_table()
self.log_info()
except SystemExit:
pass
except Exception:
if self.refresh_id:
self.schematizer.update_refresh(
self.refresh_id,
RefreshStatus.FAILED,
self.processed_row_count
)
# Sends an email containing the exception encountered.
self._email_exception_in_exception_context()
is_success = False
finally:
# We don't want to drop the blackhole table until the replication handler is using
# the schema_tracker database stably. (TODO: DATAPIPE-845)
# self.final_action()
if not is_success:
os._exit(1)
def process_request(self, request, client_address):
"""Fork a new subprocess to process the request."""
self.collect_children()
pid = os.fork()
if pid:
# Parent process
if self.active_children is None:
self.active_children = []
self.active_children.append(pid)
self.close_request(request) #close handle in parent process
return
else:
# Child process.
# This must never return, hence os._exit()!
try:
self.finish_request(request, client_address)
self.shutdown_request(request)
os._exit(0)
except:
try:
self.handle_error(request, client_address)
self.shutdown_request(request)
finally:
os._exit(1)
def myexit(code):
'''
Substitute for sys.exit. MUST be used at EOF.
This wrapper flushes output and calls `os._exit`.
Python 2.7.10 on NetBSD 6.1 x86-32 has a bug that causes the
interpreter to hang after the program has finished if it has ever
called `subprocess.Popen`. All of `exit`, `sys.exit`, `quit` and
end of file are affected.
Using `os._exit` won't work either because output is buffered and
not flushed on exit.
https://github.com/oskar-skog/anonymine/issues/7
http://bugs.python.org/issue28807
http://gnats.netbsd.org/cgi-bin/query-pr-single.pl?number=51657
'''
sys.stdout.flush()
sys.stderr.flush()
os._exit(code)
def client_03(port, prefix):
c = RemoteControl(('',port), None, timeout=10)
while True:
if random.random() > 0.7:
c = RemoteControl(('',port), None, timeout=10)
try:
c.raise_ave_exception({'message':'hello', 'recognize':'me'})
except Exit:
os._exit(0)
except AveException, e:
if 'recognize' in e.details:
continue
print('client PID=%d got exception: %s' % (os.getpid(), e))
os._exit(2)
except Exception, e:
print('client PID=%d got exception: %s' % (os.getpid(), e))
os._exit(1)
# load test for control. send hickup if the control freezes up
def t07(w):
pretty = '%s t7' % __file__
print(pretty)
base = os.path.join(w.path, '.ave', 'config')
os.makedirs(base)
try:
authkeys = ave.config.load_authkeys(w.path)
print('FAIL %s: could load invalid config: %s' % (pretty, authkeys))
return False
except Exception, e:
name = ave.pwd.getpwuid_name(os.getuid())
if 'run "ave-config --bootstrap=%s"' % name not in unicode(e):
print('FAIL %s: wrong error: %s' % (pretty, e))
return False
return True
# used by t8-t10. calls os._exit() so only use from within child process.
def check_fds(pretty, dump, ref):
# check that 0-2 are the stdio file descriptors. i.e. that they are
# connected to pseudo terminals.
for i in range(3):
if not dump[i].startswith('/dev/pts'):
print('FAIL %s: wrong stdio file at %d: %s' % (pretty, i, dump[i]))
os._exit(2)
# any file descriptors in the range [3..max(all fds)] must be files that
# were opened by this process. for this test we expect all of them to point
# to the same file (the current .py file). otherwise they are not intact.
if max(dump.keys()) <= 2:
os._exit(0) # all OK
for i in range(3, max(ref.keys())): # check that all ref keys are intact
if not dump[i] == ref[i]:
print('FAIL %s: clobbered fd at %d: %s' % (pretty, i, dump[i]))
os._exit(5)
# check if ave.config.load_etc() clobbers file descriptors. this is a bug in
# winbindd which is used by PAM to implement a backend for Python's pwd module.
# we *have* to use the pwd module, so the global side effect (clobbering a file
# descriptor) must be hidden from the caller.
def shutdown(self, details=None):
'''
Exit the main loop and write a last exit message on all connections
before closing them. The exit message will be serialized as an ``Exit``
exception.
'''
# close all open connections
for connection in self.accepting:
connection.close()
for connection in self.authenticating:
if details:
self.write_exit_message(connection, details)
connection.close()
for connection in self.established:
if details:
self.write_exit_message(connection, details)
connection.close()
if self.listener:
self.listener.close()
self.join_deferred()
os._exit(1) # causes queued messages on outbound sockets to be flushed
# in the background. Man page: socket(7) SO_LINGER
def t07(w):
pretty = '%s t7' % __file__
print(pretty)
base = os.path.join(w.path, '.ave', 'config')
os.makedirs(base)
try:
authkeys = ave.config.load_authkeys(w.path)
print('FAIL %s: could load invalid config: %s' % (pretty, authkeys))
return False
except Exception, e:
name = ave.pwd.getpwuid_name(os.getuid())
if 'run "ave-config --bootstrap=%s"' % name not in unicode(e):
print('FAIL %s: wrong error: %s' % (pretty, e))
return False
return True
# used by t8-t10. calls os._exit() so only use from within child process.
def check_fds(pretty, dump, ref):
# check that 0-2 are the stdio file descriptors. i.e. that they are
# connected to pseudo terminals.
for i in range(3):
if not dump[i].startswith('/dev/pts'):
print('FAIL %s: wrong stdio file at %d: %s' % (pretty, i, dump[i]))
os._exit(2)
# any file descriptors in the range [3..max(all fds)] must be files that
# were opened by this process. for this test we expect all of them to point
# to the same file (the current .py file). otherwise they are not intact.
if max(dump.keys()) <= 2:
os._exit(0) # all OK
for i in range(3, max(ref.keys())): # check that all ref keys are intact
if not dump[i] == ref[i]:
print('FAIL %s: clobbered fd at %d: %s' % (pretty, i, dump[i]))
os._exit(5)
# check if ave.config.load_etc() clobbers file descriptors. this is a bug in
# winbindd which is used by PAM to implement a backend for Python's pwd module.
# we *have* to use the pwd module, so the global side effect (clobbering a file
# descriptor) must be hidden from the caller.
def shutdown(self, details=None):
'''
Exit the main loop and write a last exit message on all connections
before closing them. The exit message will be serialized as an ``Exit``
exception.
'''
# close all open connections
for connection in self.accepting:
connection.close()
for connection in self.authenticating:
if details:
self.write_exit_message(connection, details)
connection.close()
for connection in self.established:
if details:
self.write_exit_message(connection, details)
connection.close()
if self.listener:
self.listener.close()
self.join_deferred()
os._exit(1) # causes queued messages on outbound sockets to be flushed
# in the background. Man page: socket(7) SO_LINGER
def _check_analysis_queue(queue_name, thread_id=0):
"""
Private static method whose create the queue_name queue as singleton
"""
# check if connection exists for the thread
if thread_id not in Queue.connections:
try:
Queue.connections[thread_id] = pika.BlockingConnection(
pika.ConnectionParameters(Queue.host))
except pika.exceptions.ConnectionClosed as e:
logging.error("Error with RMQ server, check it's started.")
os._exit(1)
Queue.consumers[thread_id] = True
# check if channel exists for the thread
if queue_name not in Queue.channels\
or Queue.channels[queue_name].is_closed:
Queue.channels[queue_name] = Queue.connections[thread_id].channel()
Queue.channels[queue_name].queue_declare(queue=queue_name)
def process_request(self, request, client_address):
"""Fork a new subprocess to process the request."""
self.collect_children()
pid = os.fork()
if pid:
# Parent process
if self.active_children is None:
self.active_children = set()
self.active_children.add(pid)
self.close_request(request) #close handle in parent process
return
else:
# Child process.
# This must never return, hence os._exit()!
try:
self.finish_request(request, client_address)
self.shutdown_request(request)
os._exit(0)
except:
try:
self.handle_error(request, client_address)
self.shutdown_request(request)
finally:
os._exit(1)
def startLogging(logfilename, sysLog, prefix, nodaemon):
if logfilename == '-':
if not nodaemon:
print 'daemons cannot log to stdout'
os._exit(1)
logFile = sys.stdout
elif sysLog:
syslog.startLogging(prefix)
elif nodaemon and not logfilename:
logFile = sys.stdout
else:
logFile = app.getLogFile(logfilename or 'twistd.log')
try:
import signal
except ImportError:
pass
else:
def rotateLog(signal, frame):
from twisted.internet import reactor
reactor.callFromThread(logFile.rotate)
signal.signal(signal.SIGUSR1, rotateLog)
if not sysLog:
log.startLogging(logFile)
sys.stdout.flush()
def daemonize():
# See http://www.erlenstar.demon.co.uk/unix/faq_toc.html#TOC16
if os.fork(): # launch child and...
os._exit(0) # kill off parent
os.setsid()
if os.fork(): # launch child and...
os._exit(0) # kill off parent again.
os.umask(077)
null=os.open('/dev/null', os.O_RDWR)
for i in range(3):
try:
os.dup2(null, i)
except OSError, e:
if e.errno != errno.EBADF:
raise
os.close(null)
def fixPdb():
def do_stop(self, arg):
self.clear_all_breaks()
self.set_continue()
from twisted.internet import reactor
reactor.callLater(0, reactor.stop)
return 1
def help_stop(self):
print """stop - Continue execution, then cleanly shutdown the twisted reactor."""
def set_quit(self):
os._exit(0)
pdb.Pdb.set_quit = set_quit
pdb.Pdb.do_stop = do_stop
pdb.Pdb.help_stop = help_stop
def closed(self):
global old
log.msg('closed %s' % self)
log.msg(repr(self.conn.channels))
if not options['nocache']: # fork into the background
if os.fork():
if old:
fd = sys.stdin.fileno()
tty.tcsetattr(fd, tty.TCSANOW, old)
if (options['command'] and options['tty']) or \
not options['notty']:
signal.signal(signal.SIGWINCH, signal.SIG_DFL)
os._exit(0)
os.setsid()
for i in range(3):
try:
os.close(i)
except OSError, e:
import errno
if e.errno != errno.EBADF:
raise
def on_sa_profile(self, mapper, action):
profile_name = action.profile
path = find_profile(profile_name)
if path:
with self.lock:
if path != self.current_profile and not self.current_profile.endswith(".mod"):
# Switch only if target profile is not active
# and active profile is not being editted.
try:
if self.config['autoswitch_osd']:
msg = (_("Switched to profile") + " " + profile_name)
self.socket.send(b"OSD: " + msg.encode('utf-8') + b"\n")
self.socket.send(b"Profile: " + path.encode('utf-8') + b"\n")
except:
log.error("Socket write failed")
os._exit(2)
return
else:
log.error("Cannot switch to profile '%s', profile file not found", self.conds[c])
def stop(stimuli, bci, graph, bci_queue, pupil=None):
print('Terminating from the main thread...')
#termination handling for windows
event.set()
while True:
if bci_queue is None or bci_queue.get() == 'SAVED_BCI' or os.name != 'nt':
#(in windows) 'SAVED_BCI' ensures data has saved before process termination
try:
stimuli.terminate()
bci.terminate()
graph.terminate()
os._exit(0)
except AttributeError:
pass
break
if pupil:
pupil.terminate()
def run(command):
# TODO: replace this with fork()
# (https://docs.python.org/2/library/os.html#os.fork)
pid = 0
if pid == 0:
# This is the child, we'll try to do some containment here
try:
contain(command)
except Exception:
traceback.print_exc()
os._exit(1) # something went wrong in contain()
# This is the parent, pid contains the PID of the forked process
# wait for the forked child and fetch the exit status
_, status = os.waitpid(pid, 0)
print('{} exited with status {}'.format(pid, status))
def run(image_name, image_dir, container_dir, command):
container_id = str(uuid.uuid4())
pid = os.fork()
if pid == 0:
# This is the child, we'll try to do some containment here
try:
contain(command, image_name, image_dir, container_id,
container_dir)
except Exception:
traceback.print_exc()
os._exit(1) # something went wrong in contain()
# This is the parent, pid contains the PID of the forked process
# wait for the forked child, fetch the exit status
_, status = os.waitpid(pid, 0)
print('{} exited with status {}'.format(pid, status))
def run(image_name, image_dir, container_dir, command):
container_id = str(uuid.uuid4())
pid = os.fork()
if pid == 0:
# This is the child, we'll try to do some containment here
try:
contain(command, image_name, image_dir, container_id,
container_dir)
except Exception:
traceback.print_exc()
os._exit(1) # something went wrong in contain()
# This is the parent, pid contains the PID of the forked process
# wait for the forked child, fetch the exit status
_, status = os.waitpid(pid, 0)
print('{} exited with status {}'.format(pid, status))
def run(image_name, image_dir, container_dir, command):
container_id = str(uuid.uuid4())
pid = os.fork()
if pid == 0:
# This is the child, we'll try to do some containment here
try:
contain(command, image_name, image_dir, container_id,
container_dir)
except Exception:
traceback.print_exc()
os._exit(1) # something went wrong in contain()
# This is the parent, pid contains the PID of the forked process
# wait for the forked child, fetch the exit status
_, status = os.waitpid(pid, 0)
print('{} exited with status {}'.format(pid, status))
def run(image_name, image_dir, container_dir, command):
container_id = str(uuid.uuid4())
pid = os.fork()
if pid == 0:
# This is the child, we'll try to do some containment here
try:
contain(command, image_name, image_dir, container_id, container_dir)
except Exception:
traceback.print_exc()
os._exit(1) # something went wrong in contain()
# This is the parent, pid contains the PID of the forked process
# wait for the forked child, fetch the exit status
_, status = os.waitpid(pid, 0)
print('{} exited with status {}'.format(pid, status))
def run(image_name, image_dir, container_dir, command):
container_id = str(uuid.uuid4())
# TODO: Switching to a new PID namespace (using unshare) would only affect
# the children of a process (because we can't change the PID of a
# running process), so we'll have to unshare here OR replace
# os.fork() with linux.clone()
pid = os.fork()
if pid == 0:
# This is the child, we'll try to do some containment here
try:
contain(command, image_name, image_dir, container_id,
container_dir)
except Exception:
traceback.print_exc()
os._exit(1) # something went wrong in contain()
# This is the parent, pid contains the PID of the forked process
# wait for the forked child, fetch the exit status
_, status = os.waitpid(pid, 0)
print('{} exited with status {}'.format(pid, status))
def main(argv):
"""
Used to fetch the snabb instance information from the JET app.
:param argv: Arguments for the command
:return: Dictionary of instances state information
"""
try:
# log device initialized successfully
print "Device initialized for the configuration updates"
#Start a thread to do the polling
t = Thread(target=poll_snabb)
t.daemon = True
t.start()
opw = OpServer()
server.register_instance(opw)
print ("Starting the reactor")
server.serve_forever()
except Exception as e:
# log device initialization failed
print("JET app exiting due to exception: %s" %str(e.message))
os._exit(0)
return
def info(args):
"""Get info on vm"""
names = args.names
output = args.output
fields = args.fields
values = args.values
lastvm = "%s/.kcli/vm" % os.environ.get('HOME')
if not names:
if os.path.exists(lastvm) and os.stat(lastvm).st_size > 0:
names = [open(lastvm).readlines()[0].strip()]
common.pprint("Using %s as vm" % names[0], color='green')
else:
common.pprint("Missing Vm's name", color='red')
return
global config
k = config.k
codes = []
for name in names:
result = k.info(name, output=output, fields=fields, values=values)
code = common.handle_response(result, name, quiet=True)
codes.append(code)
os._exit(1 if 1 in codes else 0)
def disk(args):
"""Add/Delete disk of vm"""
name = args.name
delete = args.delete
size = args.size
diskname = args.diskname
template = args.template
pool = args.pool
global config
k = config.k
if delete:
if diskname is None:
common.pprint("Missing diskname. Leaving...", color='red')
os._exit(1)
common.pprint("Deleting disk %s from %s..." % (diskname, name), color='green')
k.delete_disk(name, diskname)
return
if size is None:
common.pprint("Missing size. Leaving...", color='red')
os._exit(1)
if pool is None:
common.pprint("Missing pool. Leaving...", color='red')
os._exit(1)
common.pprint("Adding disk to %s..." % (name), color='green')
k.add_disk(name=name, size=size, pool=pool, template=template)
