o i @s^ddlZddlZddlZddlmZGdddejZGdddeZGdddej d Z dS) N)Lockc@seZdZdZdZdZdS) ServiceStatuszA Service status.stoppedrunningN)__name__ __module__ __qualname____doc__STOPPEDRUNNINGr r L/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/internal/service.pyrsrcs*eZdZdddeddffdd ZZS)ServiceStatusError service_clsz type[Service]current_statusreturnNcs&||_tt|d|j|jfdS)Nz%s is already in status %s)rsuperr__init__rvalue)selfrr __class__r r rs zServiceStatusError.__init__)rrrrr __classcell__r r rr rsrc@seZdZdZdddZddZdd Zd d Zd ej d ej ddfddZ e j d ej d ej ddfddZ d ej d ej ddfddZe j d ej d ej ddfddZ ddejeddfddZdS)Servicez)A service that can be started or stopped.rNcCstj|_t|_dSN)rr statusr _service_lockrr r r r zService.__init__cCsD|jj}dd|jD}ddd|D}|d|dS)NcSs i|] \}}|ds||qS)_) startswith.0kvr r r $s z$Service.__repr__..z, css"|] \}}|d|VqdS)=Nr r!r r r %s z#Service.__repr__..())rr__dict__itemsjoin)r class_nameattrs attrs_strr r r __repr__"szService.__repr__cCs ||Sr)startrr r r __enter__(szService.__enter__cCs||dSr)stopr,)rexc_type exc_value tracebackr r r __exit__,rzService.__exit__argskwargscO^|j"|jtjkrt|j|j|j|i|tj|_WddS1s(wYdS)zStart the service.N)rrrr rr_start_servicerr8r9r r r r10s   "z Service.startcOdS)zStart the service for real. This method uses the internal lock to be sure there's no race conditions and that the service is really started once start() returns. Nr r<r r r r;>zService._start_servicecOr:)zStop the service.N)rrrr rr _stop_servicer<r r r r3Ks   "z Service.stopcOr=)zStop the service for real. This method uses the internal lock to be sure there's no race conditions and that the service is really stopped once start() returns. Nr r<r r r r?Wr>zService._stop_servicetimeoutcCr=)zJoin the service once stopped.Nr )rr@r r r r,dr>z Service.join)rNr)rrrr rr0r2r7typingAnyr1abcabstractmethodr;r3r?Optionalfloatr,r r r r rsT       r) metaclass) rCenumrAddtrace.internal.threadsrEnumr RuntimeErrorrABCMetarr r r r s