a _Æbÿã@sHddlmZz ddlZWney2ddlZYn0Gdd„deƒZdS)é)Ú ConnectionéNcs@eZdZdZ‡fdd„Zdd„Zdd„Zdd „Zd d „Z‡Z S) ÚPoolingConnectionzö Base connection class for connections that use libraries without thread safety and no capacity for connection pooling. To use this just implement a ``_make_connection`` method that constructs a new connection and returns it. cs$t ¡|_tt|ƒj|i|¤ŽdS©N)ÚqueueÚQueueÚ_free_connectionsÚsuperrÚ__init__)ÚselfÚargsÚkwargs©Ú __class__©úF/tmp/pip-target-4jja1joz/lib/python/opensearchpy/connection/pooling.pyr +s zPoolingConnection.__init__cCst‚dSr)ÚNotImplementedError©r rrrÚ_make_connection/sz"PoolingConnection._make_connectioncCs.z |j ¡WStjy(| ¡YS0dSr)rÚ get_nowaitrÚEmptyrrrrrÚ_get_connection2s z!PoolingConnection._get_connectioncCs|j |¡dSr)rÚput)r ÚconrrrÚ_release_connection8sz%PoolingConnection._release_connectioncCsdS)z- Explicitly close connection NrrrrrÚclose;szPoolingConnection.close) Ú__name__Ú __module__Ú __qualname__Ú__doc__r rrrrÚ __classcell__rrrrr#s  r)ÚbaserrÚ ImportErrorrrrrrrÚs