本文整理汇总了Python中rfoo.utils.rconsole.spawn_server函数的典型用法代码示例。如果您正苦于以下问题：Python spawn_server函数的具体用法？Python spawn_server怎么用？Python spawn_server使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了spawn_server函数的9个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: init_rconsole_server
def init_rconsole_server():
try:
from rfoo.utils import rconsole
rconsole.spawn_server()
except ImportError:
logger.error("No socket opened for debugging -> please install rfoo")
开发者ID:bossjones，项目名称:scarlett_os，代码行数:7，代码来源:debugger.py
示例2: start
def start(self):
if self.started:
return
self.init()
env.start(True, isLocal=self.isLocal)
self.scheduler.start()
self.started = True
atexit.register(self.stop)
def handler(signm, frame):
logger.error("got signal %d, exit now", signm)
self.scheduler.shutdown()
signal.signal(signal.SIGTERM, handler)
signal.signal(signal.SIGHUP, handler)
signal.signal(signal.SIGABRT, handler)
signal.signal(signal.SIGQUIT, handler)
try:
from rfoo.utils import rconsole
rconsole.spawn_server(locals(), 0)
except ImportError:
pass
开发者ID:Dshadowzh，项目名称:dpark，代码行数:25，代码来源:context.py
示例3: defer_start
def defer_start():
self.logger.debug("Spawning rconsole")
from rfoo.utils import rconsole
rconsole.spawn_server()
self.rconsole_started = True
self.logger.debug("rconsole started")
开发者ID:brucelane，项目名称:ableton-live-webapi，代码行数:7，代码来源:WebAPI.py
示例4: __init__
def __init__(self, uid, cr):
super( osv.osv, self ).__init__(uid, cr)
orm['self'] = self
orm['cr'] = cr
orm['uid'] = uid
rconsole.spawn_server()
print '>>>>>>>>>>>>>>>>>>>>>>>>>> Console Loaded <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<'
print '>>>>>>>>>>>>>>>> access with openerp-console/rconsole <<<<<<<<<<<<<<<<<<<<<<<'
开发者ID:allanwong，项目名称:openerp-ktv，代码行数:9，代码来源:console_module.py
示例5: spawn_rconsole
def spawn_rconsole(env):
rfoo_logger = logging.getLogger('rfoo')
rfoo_logger.disabled = 1
try:
from rfoo.utils import rconsole
import rfoo._rfoo
rfoo._rfoo.logging = rconsole.logging = rfoo_logger
rconsole.spawn_server(env, 0)
except ImportError:
pass
开发者ID:douban，项目名称:dpark，代码行数:10，代码来源:debug.py
示例6: __init__
def __init__(self, master=None):
if 'MESOS_SLAVE_PID' in os.environ and 'DRUN_SIZE' not in os.environ:
from executor import run
run()
sys.exit(0)
options = parse_options()
self.options = options
master = master or options.master
if master == 'local':
self.scheduler = LocalScheduler()
self.isLocal = True
elif master == 'process':
self.scheduler = MultiProcessScheduler(options.parallel)
self.isLocal = True
else:
if master == 'mesos':
master = os.environ.get('MESOS_MASTER')
if not master:
raise Exception("invalid uri of mesos master: %s" % master)
if master.startswith('mesos://'):
if '@' in master:
master = master[master.rfind('@')+1:]
else:
master = master[master.rfind('//')+2:]
elif master.startswith('zoo://'):
master = 'zk' + master[3:]
if ':' not in master:
master += ':5050'
self.scheduler = MesosScheduler(master, options)
self.isLocal = False
self.master = master
if options.parallel:
self.defaultParallelism = options.parallel
else:
self.defaultParallelism = self.scheduler.defaultParallelism()
self.defaultMinSplits = max(self.defaultParallelism, 2)
try:
from rfoo.utils import rconsole
rconsole.spawn_server(locals(), 0)
except ImportError:
pass
self.started = False
开发者ID:cute，项目名称:dpark，代码行数:50，代码来源:context.py
示例7: wsgi_serve
def wsgi_serve(self, with_reloader):
if not with_reloader or self._reloader_key not in os.environ:
self.logger.info('Listening on: %s:%s' % (self.host, self.port))
if self._reloader_key in os.environ:
self.logger.info('Monitoring code files')
reloader.install()
if self._reloader_key in os.environ or not with_reloader:
if self.use_rfoo:
from rfoo.utils import rconsole
rconsole.spawn_server(self.rfoo_namespace, self.rfoo_port)
self.logger.info('Rfoo listening on port %i' % self.rfoo_port)
self.logger.info('http ready')
server = WSGIServer(self.application, self.host,
self.port, get_http_logger(self.logger))
server.serve_forever()
return
self.restart_with_reloader()
开发者ID:clueproject，项目名称:clue_script，代码行数:21，代码来源:_wsgi.py
示例8: print
import sys
import time
import timeit
import os
import platform
import subprocess
import numpy
import fabio
import os.path as op
import logging
sys.path.append(op.join(op.dirname(op.dirname(op.abspath(__file__))), "test"))
import utilstest
try:
from rfoo.utils import rconsole
rconsole.spawn_server()
except ImportError:
print("No socket opened for debugging -> please install rfoo")
#We use the locally build version of PyFAI
pyFAI = utilstest.UtilsTest.pyFAI
ocl = pyFAI.opencl.ocl
from pyFAI.gui_utils import pylab, update_fig
ds_list = ["Pilatus1M.poni", "halfccd.poni", "Frelon2k.poni", "Pilatus6M.poni", "Mar3450.poni", "Fairchild.poni"]
datasets = {"Fairchild.poni":utilstest.UtilsTest.getimage("1880/Fairchild.edf"),
"halfccd.poni":utilstest.UtilsTest.getimage("1882/halfccd.edf"),
"Frelon2k.poni":utilstest.UtilsTest.getimage("1881/Frelon2k.edf"),
"Pilatus6M.poni":utilstest.UtilsTest.getimage("1884/Pilatus6M.cbf"),
"Pilatus1M.poni":utilstest.UtilsTest.getimage("1883/Pilatus1M.edf"),
"Mar3450.poni":utilstest.UtilsTest.getimage("2201/LaB6_260210.mar3450")
开发者ID:isaxs，项目名称:pyFAI，代码行数:31，代码来源:benchmark.py
示例9: handler
logging.debug("Connecting to mesos master %s", options.master)
driver = mesos.MesosSchedulerDriver(sched, sched.framework,
options.master)
driver.start()
def handler(signm, frame):
logging.warning("got signal %d, exit now", signm)
sched.stop(3)
signal.signal(signal.SIGTERM, handler)
signal.signal(signal.SIGHUP, handler)
signal.signal(signal.SIGABRT, handler)
signal.signal(signal.SIGQUIT, handler)
try:
from rfoo.utils import rconsole
rconsole.spawn_server(locals(), 0)
except ImportError:
pass
start = time.time()
try:
while not sched.stopped:
time.sleep(1)
now = time.time()
sched.check(driver)
if not sched.started and sched.next_try > 0 and now > sched.next_try:
sched.next_try = 0
driver.reviveOffers()
if not sched.started and now > sched.last_offer_time + 60 + random.randint(0,5):
开发者ID:guibog，项目名称:dpark，代码行数:31，代码来源:scheduler.py
注：本文中的rfoo.utils.rconsole.spawn_server函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论