forked from goodboy/tractor
60 lines
1.3 KiB
Python
60 lines
1.3 KiB
Python
|
|
import sys
|
|
import trio
|
|
import argparse
|
|
|
|
from ._actor import Actor
|
|
from ._entry import _trio_main
|
|
|
|
|
|
"""This is the "bootloader" for actors started using the native trio backend
|
|
added in #128
|
|
"""
|
|
|
|
|
|
if __name__ == "__main__":
|
|
|
|
parser = argparse.ArgumentParser()
|
|
|
|
parser.add_argument("name")
|
|
parser.add_argument("rpc_module_paths") # comma separated mod paths
|
|
parser.add_argument("uid")
|
|
parser.add_argument("loglevel")
|
|
parser.add_argument("bind_addr")
|
|
parser.add_argument("parent_addr")
|
|
parser.add_argument("arbiter_addr")
|
|
|
|
args = parser.parse_args()
|
|
|
|
rpc_paths = []
|
|
for rpc_mod_path in args.rpc_module_paths.split(";"):
|
|
rpc_paths.append(rpc_mod_path)
|
|
|
|
bind_addr = args.bind_addr.split(":")
|
|
bind_addr = (bind_addr[0], int(bind_addr[1]))
|
|
|
|
parent_addr = args.parent_addr.split(":")
|
|
parent_addr = (parent_addr[0], int(parent_addr[1]))
|
|
|
|
arbiter_addr = args.arbiter_addr.split(":")
|
|
arbiter_addr = (arbiter_addr[0], int(arbiter_addr[1]))
|
|
|
|
if args.loglevel == "None":
|
|
loglevel = None
|
|
else:
|
|
loglevel = args.loglevel
|
|
|
|
subactor = Actor(
|
|
args.name,
|
|
rpc_module_paths=rpc_paths,
|
|
uid=args.uid,
|
|
loglevel=loglevel,
|
|
arbiter_addr=arbiter_addr
|
|
)
|
|
|
|
_trio_main(
|
|
subactor,
|
|
bind_addr,
|
|
parent_addr=parent_addr
|
|
)
|