o “Hbã@s²ddlZddlZddlZddlZddlZddlmZddlmZddlm Z dgZ ejdkr.send)ÚdupÚ_resource_sharerÚregisterÚcloseÚ_id)ÚselfZsockrrrrÚ__init__szDupSocket.__init__cCsBt |j¡}| ¡}t |¡WdƒS1swYdS)z1Get the socket. This should only be called once.N)rÚget_connectionrZ recv_bytesÚsocketZ fromshare)rrrrrrÚdetach$s$þzDupSocket.detachN©Ú__name__Ú __module__Ú__qualname__Ú__doc__rrrrrrrsÚDupFdc@r )r!z-Wrapper for fd which can be used at any time.cs4t |¡‰‡fdd„}‡fdd„}t ||¡|_dS)Ncst |ˆ|¡dSr )rZsend_handle)rr ©Znew_fdrrr1szDupFd.__init__..sendcst ˆ¡dSr )Úosrrr"rrr3szDupFd.__init__..close)r#rrrr)rÚfdrrrr"rr/s zDupFd.__init__cCs:t |j¡ }t |¡WdƒS1swYdS)z-Get the fd. This should only be called once.N)rrrrZrecv_handle)rrrrrr7s$ÿzDupFd.detachNrrrrrr!-sc@sNeZdZdZdd„Zdd„Zedd„ƒZdd d „Zdd„Z d d„Z dd„ZdS)Ú_ResourceSharerz.Manager for resources using background thread.cCs:d|_i|_t ¡|_d|_d|_d|_t |t j¡dS)Nr)Ú_keyÚ_cacheÚ threadingZLockÚ_lockÚ _listenerÚ_addressÚ_threadrZregister_after_forkr%Ú _afterfork)rrrrr?s z_ResourceSharer.__init__cCsf|j&|jdur | ¡|jd7_||f|j|j<|j|jfWdƒS1s,wYdS)z+Register resource, returning an identifier.Nr)r)r+Ú_startr&r')rrrrrrrHs $ûz_ResourceSharer.registercCs<ddlm}|\}}||t ¡jd}| |t ¡f¡|S)zs" \