本文整理汇总了Python中tornado.netutil.bind_unix_socket函数的典型用法代码示例。如果您正苦于以下问题:Python bind_unix_socket函数的具体用法?Python bind_unix_socket怎么用?Python bind_unix_socket使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了bind_unix_socket函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: start
def start(self):
self.tornadoApp=tornado.web.Application(self.handlers)
self.tornadoApp.server=self
if self.ssl_crt and self.ssl_key:
import ssl
ssl_options = ssl.create_default_context(ssl.Purpose.CLIENT_AUTH)
ssl_options.load_cert_chain(self.ssl_crt,self.ssl_key)
else:
ssl_options = None
server = HTTPServer(self.tornadoApp, ssl_options=ssl_options)
if self.port:
server.listen(int(self.port))
#self.tornadoApp.listen(int(self.port))
else:
socket_path = os.path.join(gnrConfigPath(), 'sockets', '%s.tornado'%self.instance_name)
main_socket = bind_unix_socket(socket_path)
#server = HTTPServer(self.tornadoApp)
server.add_socket(main_socket)
debug_socket_path = os.path.join(gnrConfigPath(), 'sockets', '%s_debug.tornado'%self.instance_name)
debug_socket = bind_unix_socket(debug_socket_path)
debug_server = GnrDebugServer(self.io_loop)
#debug_server.listen(8888)
debug_server.add_socket(debug_socket)
debug_server.application = self.tornadoApp
signal.signal(signal.SIGTERM, self.onSignal)
signal.signal(signal.SIGINT, self.onSignal)
self.io_loop.start()
开发者ID:genropy,项目名称:genropy,代码行数:27,代码来源:gnrasync.py
示例2: setup_server
def setup_server():
# Config tornado.curl_httpclient to use NullHandler
tornado_logger = logging.getLogger('tornado.curl_httpclient')
tornado_logger.addHandler(logging.NullHandler())
tornado_logger.propagate = False
settings = dict(
autoreload=True,
secret="ElasticKube",
)
configure(settings)
handlers = [
(r"/api/v1/auth/providers", AuthProvidersHandler),
(r"/api/v1/auth/signup", SignupHandler),
(r"/api/v1/auth/login", PasswordHandler),
(r"/api/v1/auth/google", GoogleOAuth2LoginHandler),
(r"/api/v1/ws", MainWebSocketHandler),
(r"/icons/(?P<entity_id>[^\/]+)\/(?P<chart_id>[^\/]+)", IconGenerator)
]
application = Application(handlers, **settings)
server = HTTPServer(application)
socket = bind_unix_socket("/var/run/elastickube-api.sock", mode=0777)
server.add_socket(socket)
IOLoop.current().add_callback(initialize, settings)
开发者ID:carolling,项目名称:elastickube,代码行数:29,代码来源:server.py
示例3: unix_socket_server
def unix_socket_server(application, options):
""" unix socket server """
log.info("Binding application to unix socket {0}".format(options.unix_socket))
server = HTTPServer(application)
socket = bind_unix_socket(options.unix_socket)
server.add_socket(socket)
开发者ID:CartoDB,项目名称:pyjojo,代码行数:7,代码来源:servers.py
示例4: bind
def bind(server, port, usocket, address=None):
"""Make server listen on port (inet socket).
If given, prefer `usocket`, path to a unix socket.
The latter is useful for reverse proxying.
If listening on a inet socket, `address` might be
given. `address` may be either an IP address or hostname.
If it's a hostname, the server will listen on all IP addresses
associated with the name. If not given (and not listening on a unix
socket) will listen on all available interfaces."""
# If we have a unix socket path
if usocket:
LOG.info('Starting on unix socket %r', usocket)
try:
socket = bind_unix_socket(usocket, mode=options.usocket_mode)
os.chown(usocket, options.usocket_uid, options.usocket_gid)
except OSError as error:
LOG.error('Cannot create unix socket: %r', error)
else:
server.add_socket(socket)
LOG.info('Started')
else:
LOG.info('Starting on port %d', port)
sockets = bind_sockets(port, address=address)
server.add_sockets(sockets)
LOG.info('Started')
开发者ID:BitsDevelopmentTeam,项目名称:bits-server,代码行数:27,代码来源:common.py
示例5: run_server
def run_server(
django_host='http://127.0.0.1:8000',
listen_address='0.0.0.0',
listen_port=22000,
unix_socket=None,
socket_mode=0o600,
socket_group=None):
subscribed_channels_url = django_host + reverse('luna_websockets_channels')
BrokerConnection.subscribed_channels_url = subscribed_channels_url
BrokerRouter = sockjs.tornado.SockJSRouter(BrokerConnection, '/ws')
app = tornado.web.Application(BrokerRouter.urls)
if unix_socket:
server = tornado.httpserver.HTTPServer(app)
socket = bind_unix_socket(unix_socket, mode=socket_mode)
if socket_group is not None:
gid = grp.getgrnam(socket_group).gr_gid
os.chown(unix_socket, -1, gid)
server.add_socket(socket)
logging.info('Listening on %s' % unix_socket)
else:
app.listen(listen_port, address=listen_address)
logging.info('Listening on %s:%d' % (listen_address, listen_port))
tornado.ioloop.IOLoop.instance().start()
开发者ID:h2020-westlife-eu,项目名称:VRE,代码行数:29,代码来源:server.py
示例6: __init__
def __init__(self, unixsocket, io_loop=None):
super(RuntimeMock, self).__init__(io_loop=io_loop or ioloop.IOLoop.current())
self.io_loop = io_loop or ioloop.IOLoop.current()
self.actions = list()
self.counter = 1
self.endpoint = unixsocket
self.add_socket(netutil.bind_unix_socket(unixsocket))
开发者ID:gabrielferreira,项目名称:cocaine-framework-python,代码行数:7,代码来源:runtime.py
示例7: launch
def launch(self):
import signal
import tornado.httpserver
signal.signal(signal.SIGTERM, self.sig_handler)
signal.signal(signal.SIGINT, self.sig_handler)
if os.name == "posix":
signal.signal(signal.SIGTSTP, self.sig_handler)
self.http_server = tornado.httpserver.HTTPServer(self.application)
if firenado.conf.app['socket'] or self.socket:
from tornado.netutil import bind_unix_socket
socket_path = firenado.conf.app['socket']
if self.socket:
socket_path = self.socket
socket = bind_unix_socket(socket_path)
self.http_server.add_socket(socket)
logger.info("Firenado listening at socket ""%s" %
socket.getsockname())
else:
addresses = self.addresses
if addresses is None:
addresses = firenado.conf.app['addresses']
port = self.port
if port is None:
port = firenado.conf.app['port']
for address in addresses:
self.http_server.listen(port, address)
logger.info("Firenado listening at ""http://%s:%s" % (address,
port))
logger.info("Firenado server started successfully.")
tornado.ioloop.IOLoop.instance().start()
开发者ID:candango,项目名称:firenado,代码行数:30,代码来源:launcher.py
示例8: launch
def launch(self):
import signal
# TODO: Resolve module if doesn't exists
if firenado.conf.app['pythonpath']:
sys.path.append(firenado.conf.app['pythonpath'])
signal.signal(signal.SIGTERM, self.sig_handler)
signal.signal(signal.SIGINT, self.sig_handler)
if os.name == "posix":
signal.signal(signal.SIGTSTP, self.sig_handler)
self.application = TornadoApplication(debug=firenado.conf.app['debug'])
self.http_server = tornado.httpserver.HTTPServer(
self.application)
if firenado.conf.app['socket']:
from tornado.netutil import bind_unix_socket
socket = bind_unix_socket(firenado.conf.app['socket'])
self.http_server.add_socket(socket)
else:
addresses = firenado.conf.app['addresses']
port = firenado.conf.app['port']
for address in addresses:
self.http_server.listen(port, address)
logger.info("Firenado listening at ""http://%s:%s" % (address,
port))
tornado.ioloop.IOLoop.instance().start()
开发者ID:piraz,项目名称:firenado,代码行数:26,代码来源:tornadoweb.py
示例9: main
def main():
define('ip', default=None, help='IP to listen on')
define('port', default=None, help='port to listen on')
define('socket', default=None, help='unix socket path to bind (instead of ip:port)')
define('group', default='', help='comma separated group list for new users `students,other`')
define('skeldir', default='', help='skeleton directory that will be used for new homedirs')
define('shell', default='/bin/bash', help='default shell')
parse_command_line()
if not options.socket and not (options.port):
options.socket = '/var/run/restuser.sock'
app = web.Application(
[(r'/([^/]+)', UserHandler)],
group=options.group,
skeldir=options.skeldir,
shell=options.shell)
if options.socket:
socket = bind_unix_socket(options.socket, mode=0o600)
server = HTTPServer(app)
server.add_socket(socket)
else:
app.listen(options.port, options.ip)
try:
IOLoop.current().start()
except KeyboardInterrupt:
print("\ninterrupted\n", file=sys.stderr)
return
开发者ID:AdrianGPrado,项目名称:restuser,代码行数:29,代码来源:restuser.py
示例10: setUp
def setUp(self):
super(HTTPUnixClientTestCase, self).setUp()
self.socket_path = os.path.join(os.path.abspath(os.path.dirname(__file__)),
"test_socket")
self.http_server = self.get_http_server()
sock = netutil.bind_unix_socket(self.socket_path)
self.http_server.add_sockets([sock])
开发者ID:werehuman,项目名称:cocaine-tools,代码行数:7,代码来源:test_tools.py
示例11: listen
def listen(self, port, address=""):
"""Bind to a unix domain socket and add to self.
Note that port in our case actually contains the uds file name"""
# Create a Unix domain socket and bind
socket = bind_unix_socket(port)
# Add to self
self.add_socket(socket)
开发者ID:hvishwanath,项目名称:msgpack-rpc-python,代码行数:9,代码来源:uds.py
示例12: unix_socket
def unix_socket(path, u, g):
uid = pwd.getpwnam(u).pw_uid
gid = grp.getgrnam(g).gr_gid
with netutil.bind_unix_socket(path) as socket:
os.chown(path, uid, gid)
try:
yield socket
finally:
os.remove(path)
开发者ID:legnaleurc,项目名称:ovpnkey,代码行数:9,代码来源:utils.py
示例13: standalone
def standalone():
"""
Initializes Tornado and our application. Forks worker processes to handle
requests. Does not return until all child processes exit normally.
"""
# Parse arguments
parser = argparse.ArgumentParser(description="Ellis web server")
parser.add_argument("--background", action="store_true", help="Detach and run server in background")
args = parser.parse_args()
# We don't initialize logging until we fork because we want each child to
# have its own logging and it's awkward to reconfigure logging that is
# defined by the parent.
application = create_application()
if args.background:
# Get a new logfile, rotating the old one if present.
err_log_name = os.path.join(settings.LOGS_DIR, settings.LOG_FILE_PREFIX + "-err.log")
try:
os.rename(err_log_name, err_log_name + ".old")
except OSError:
pass
# Fork into background.
utils.daemonize(err_log_name)
utils.install_sigusr1_handler(settings.LOG_FILE_PREFIX)
# Drop a pidfile.
pid = os.getpid()
with open(settings.PID_FILE, "w") as pidfile:
pidfile.write(str(pid) + "\n")
# Fork off a child process per core. In the parent process, the
# fork_processes call blocks until the children exit.
num_processes = settings.TORNADO_PROCESSES_PER_CORE * tornado.process.cpu_count()
task_id = tornado.process.fork_processes(num_processes)
if task_id is not None:
logging_config.configure_logging(settings.LOG_LEVEL, settings.LOGS_DIR, settings.LOG_FILE_PREFIX, task_id)
# We're a child process, start up.
_log.info("Process %s starting up", task_id)
connection.init_connection()
http_server = httpserver.HTTPServer(application)
unix_socket = bind_unix_socket(settings.HTTP_UNIX + "-" + str(task_id),
0666);
http_server.add_socket(unix_socket)
homestead.ping()
background.start_background_worker_io_loop()
io_loop = tornado.ioloop.IOLoop.instance()
io_loop.start()
else:
# This shouldn't happen since the children should run their IOLoops
# forever.
_log.critical("Children all exited")
开发者ID:AiprNick,项目名称:ellis,代码行数:56,代码来源:main.py
示例14: run_server
def run_server(application, context):
server = HTTPServer(application)
define(
'unix_socket',
group='webserver',
default=thumbor_socket,
help='Path to unix socket to bind')
socket = bind_unix_socket(options.unix_socket)
server.add_socket(socket)
server.start(1)
开发者ID:angelmoreno87,项目名称:serverless-image-handler,代码行数:10,代码来源:lambda_function.py
示例15: setUp
def setUp(self):
super(UnixSocketTest, self).setUp()
self.tmpdir = tempfile.mkdtemp()
self.sockfile = os.path.join(self.tmpdir, "test.sock")
sock = netutil.bind_unix_socket(self.sockfile)
app = Application([("/hello", HelloWorldRequestHandler)])
self.server = HTTPServer(app)
self.server.add_socket(sock)
self.stream = IOStream(socket.socket(socket.AF_UNIX))
self.io_loop.run_sync(lambda: self.stream.connect(self.sockfile))
开发者ID:bdarnell,项目名称:tornado,代码行数:10,代码来源:httpserver_test.py
示例16: main
def main():
application = Application([(r"/(.*)/", ChatHandler)])
server = HTTPServer(application)
socket = bind_unix_socket(config.get("app:main", "cherubplay.socket_chat"), mode=0o777)
server.add_socket(socket)
signal.signal(signal.SIGTERM, sig_handler)
signal.signal(signal.SIGINT, sig_handler)
ioloop.start()
开发者ID:tehdragonfly,项目名称:cherubplay,代码行数:12,代码来源:chat.py
示例17: run
def run():
parse_command_line()
if options.socket:
print('Listening on {}'.format(options.socket))
server = HTTPServer(application)
socket = bind_unix_socket(options.socket, mode=0777)
server.add_socket(socket)
else:
print('Listening on {}:{}'.format(options.addr, options.port))
application.listen(options.port, address=options.addr)
application.debug = not production
tornado.ioloop.IOLoop.instance().start()
开发者ID:zabka14,项目名称:paste-py,代码行数:12,代码来源:paste.py
示例18: __init__
def __init__(self, usocket, starting_point, allow_design):
"""Used to run the plugins that are installed based on the starting point
@param socket Unix socket you are watching
@param starting_point The starting point of the plugins
"""
self.queue = sundaytasks.utils.get_plugins()
self.extensions = sundaytasks.utils.get_extensions()
self.starting_point = starting_point
self.instance = IOLoop.instance()
self._allow_design = allow_design
unix_socket = netutil.bind_unix_socket(usocket)
netutil.add_accept_handler(unix_socket, self.accept)
开发者ID:olafura,项目名称:sundaytasks-py,代码行数:13,代码来源:main.py
示例19: start
def start(self):
self.events.start()
if self.options.inspect:
self.state.start()
if self.options.unix_socket:
server = HTTPServer(self)
socket = bind_unix_socket(self.options.unix_socket)
server.add_socket(socket)
else:
self.listen(self.options.port, address=self.options.address,
ssl_options=self.ssl, xheaders=self.options.xheaders)
self.io_loop.start()
开发者ID:presencelearning,项目名称:flower,代码行数:13,代码来源:app.py
示例20: build_listener
def build_listener(address, backlog=0):
"""address: tuple ('0.0.0.0', 1234) or unix domain socket path such as '/tmp/tmp.sock'"""
address_type = get_address_type(address)
if address_type == 'tcp':
host, port = address
socks = netutil.bind_sockets(port, address=host, backlog=backlog)
return socks
if address_type == 'uds':
sock = netutil.bind_unix_socket(address, mode=0o600, backlog=backlog)
return [sock]
开发者ID:Michael2011,项目名称:torpc,代码行数:13,代码来源:util.py
注:本文中的tornado.netutil.bind_unix_socket函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论