a fK@sdddlZddlZddlZGdddejZGdddejZddZdd d Zdd dZ ddZ dS)Nc@seZdZdZdZdZdZdS) PluginStateN)__name__ __module__ __qualname__startingrunningstoppederrorrr1/sparta/input/plugins/osms/agent/shared/common.pyr srcs$eZdZfddZddZZS)StoppableThreadcs&tj|i|d|_t|_dS)NT)super__init__daemon threadingEvent _stop_event)selfargskwargs __class__rrrszStoppableThread.__init__cCs|jdSN)rset)rrrrstopszStoppableThread.stop)rrr rr __classcell__rrrrrs rcCs2d}d}dt|vr"||kr.|}n ||kr.|}|S)Nii: z403 Client Error)repr)r check_intervaldefault_circuit_breaker_timeout!no_policy_circuit_breaker_timeoutrrrcircuit_breakers r$Gc Cst`}||krZz*|d|f|dWWdStyV|d7}Yq 0q Wdn1sn0YtddS)NrzNo free ports in range.)socketbind getsocknameOSErrorIOError)portmax_port new_socketrrrget_random_open_port's  .r0rcCs|dur|||dSr)rjoin)threadtimeoutrrr stop_thread2sr4cCsB|didg}|D]$}|ddkr|ddkSqdS)N agentConfig pluginsConfignamezOS Management Hub Agent desiredStateENABLEDF)get)instance_metadataplugins_config plugin_configrrris_plugin_oci_osmh_enabled8s r>)r%r&)r) enumr(rEnumrThreadrr$r0r4r>rrrrs