o tf@svddlmZddlZddlZddlZddlZddlZddlmZej dkr,ddl m Z nddl m Z GdddZ dS)) annotationsN)ASGIApp) )Selfc@seZdZUdZded<ded<ded<ded <d ed <d*ddZed+ddZed,ddZed-ddZ d.ddZ ddddd d!d/d(d)Z dS)0BackgroundServerz7A threading-based background server for Starlette apps.r_appz str | None_host int | None_portzthreading.Thread | None_server_threadzuvicorn.Server | None_serverappreturnNonecCs"||_d|_d|_d|_d|_dS)zInitialize a background server for the given Starlette app. Parameters ---------- app : ASGIApp The Starlette app to run in the background. N)rr r r r )selfrrb/var/www/html/software/conda/envs/catlas/lib/python3.10/site-packages/servir/_background_server.py__init__s  zBackgroundServer.__init__cCs|jS)z.The Starlette app being run in the background.)rrrrrr(szBackgroundServer.appstrcC"|jdus |jdurtd|jS)z&The host to which the server is bound.NzServer not running)r r RuntimeErrorrrrrhost-zBackgroundServer.hostintcCr)z(The port on which the server is running.NzServer not running.)r r rrrrrport4rzBackgroundServer.portrcCsP|jdur|S|jdusJzd|j_|jWd|_d|_|Sd|_d|_w)z"Stop the background server thread.NT)r r Z should_exitjoinrrrrstop;s  zBackgroundServer.stop localhostNTwarning)rrtimeoutdaemon log_levelrrr"r#boolr$cCs|jdur|Stj|j||pt||d}|j|_|j|_ tj |d|_ t j |j j|d|_|j|j jsAtd|j jr8|S)aStart app in a background thread. Parameters ---------- host : str, optional The host on which to bind the server. If not provided, the server will bind to localhost. You can use "0.0.0.0" to expose the server to the local network or use a hostname. IPv6 addresses are supported. port : int, optional The port on which to run the server. If not provided, a random port will be selected. timeout : int, optional The timeout for keep-alive connections, by default 1. daemon : bool, optional Whether to run the server thread as a daemon thread, by default True. log_level : str, optional The log level for the server, by default "warning". Returns ------- BackgroundServer The background server instance. N)rrrZtimeout_keep_aliver$)config)targetr#gMbP?)r uvicornZConfigr portpickerZpick_unused_portrr rr Serverr threadingThreadrunstartstartedtimesleep)rrrr"r#r$r&rrrr.Ks$    zBackgroundServer.start)rrrr)rr)rr)rr)rr) rrrr r"rr#r%r$rrr) __name__ __module__ __qualname____doc____annotations__rpropertyrrrrr.rrrrrs*      r) __future__rsysr+r0r)r(Zstarlette.typesr version_infotypingrZtyping_extensionsrrrrrs