U #FZh/ @sXddlZddlZddlZddlmmZeeZ GdddZ Gdddej Z dS)Nc@s8eZdZdZddZddZddZdd Zd d Zd S) RefreshThreadManagerzD Organizes exactly one background job that refresh a token. cCsd|_t|_dS)zInitializes the manager.N)_worker threadingLock_lockselfr b/home/aprabhat/apps/x.techxrdev.in/venv/lib/python3.8/site-packages/google/auth/_refresh_worker.py__init__szRefreshThreadManager.__init__c Cs|dks|dkrtd|j\|jdk rF|jjdk rFW5QRdS|jdksZ|jsxt|t|d|_|j W5QRXdS)auStarts a refresh thread for the given credentials. The credentials are refreshed using the request parameter. request and cred MUST not be None Returns True if a background refresh was kicked off. False otherwise. Args: cred: A credentials object. request: A request object. Returns: bool NzQUnable to start refresh. cred and request must be valid and instantiated objects.F)credrequestT) eZ InvalidValuerr _error_infois_alive RefreshThreadcopydeepcopystart)rr r r r r start_refresh#s z"RefreshThreadManager.start_refreshc Cs$|j|jrd|j_W5QRXdS)zU Removes any errors that were stored from previous background refreshes. N)rrrrr r r clear_error>sz RefreshThreadManager.clear_errorcCs|j}d|d<|S)z2Pickle helper that serializes the _lock attribute.Nr)__dict__rrstater r r __getstate__Fs z!RefreshThreadManager.__getstate__cCst|d<|j|dS)z4Pickle helper that deserializes the _lock attribute.rN)rrrupdaterr r r __setstate__Ls z!RefreshThreadManager.__setstate__N) __name__ __module__ __qualname____doc__r rrrrr r r r rs rcs(eZdZdZfddZddZZS)rz, Thread that refreshes credentials. c s$tjf|||_||_d|_dS)zInitializes the thread. Args: cred: A Credential object to refresh. request: A Request object used to perform a credential refresh. **kwargs: Additional keyword arguments. N)superr _cred_requestr)rr r kwargs __class__r r r Ws zRefreshThread.__init__c CsPz|j|jWn8tk rJ}ztd|||_W5d}~XYnXdS)z1 Perform the credential refresh. z"Background refresh failed due to: N)r"refreshr# Exception_LOGGERerrorr)rerrr r r runes zRefreshThread.run)rrrr r r, __classcell__r r r%r rRs r) rloggingrZgoogle.auth.exceptionsauth exceptionsr getLoggerrr)rThreadrr r r r s  :