3 \] @sjddlZddlZddlmZy ddlZWnek r@dZYnXddlmZddZGdddeZ dS) N)urlparse)AsyncPubSubManagercCsjt|}|jdkrtd|jdk}|jp,d}|jp6d}|j}|jrXt|jdd}nd}|||||fS) NredisredisszInvalid redis url localhostirr>rr)rscheme ValueErrorhostnameportpasswordpathint)urlpsslhostr r dbrI/tmp/pip-build-mqc4i71p/python-socketio/socketio/asyncio_redis_manager.py_parse_redis_url s    rcs6eZdZdZdZd fdd Zd d Zd d ZZS)AsyncRedisManageraRedis based client manager for asyncio servers. This class implements a Redis backend for event sharing across multiple processes. Only kept here as one more example of how to build a custom backend, since the kombu backend is perfectly adequate to support a Redis message queue. To use a Redis backend, initialize the :class:`Server` instance as follows:: server = socketio.Server(client_manager=socketio.AsyncRedisManager( 'redis://hostname:port/0')) :param url: The connection URL for the Redis server. For a default Redis store running on the same host, use ``redis://``. To use an SSL connection, use ``rediss://``. :param channel: The channel name on which the server sends and receives notifications. Must be the same in all the servers. :param write_only: If set ot ``True``, only initialize to emit events. The default of ``False`` initializes the class for emitting and receiving. aioredisredis://localhost:6379/0socketioFNcsNtdkrtdt|\|_|_|_|_|_d|_d|_ t j |||ddS)NzORedis package is not installed (Run "pip install aioredis" in your virtualenv).)channel write_onlylogger) r RuntimeErrorrrr r rrpubsubsuper__init__)selfrrrr) __class__rrr"5s zAsyncRedisManager.__init__c sd}xyN|jdkr:tj|j|jf|j|j|jdIdH|_|jj|j t j |IdHStj t fk r|r|jjdd|_d}n|jjdPYqXqWdS)NT)rr rz#Cannot publish to redis... retryingFz$Cannot publish to redis... giving up)rr create_redisrr rr rpublishrpickledumps RedisErrorOSError _get_loggererror)r#dataretryrrr_publishBs   zAsyncRedisManager._publishc sd}xy\|jdkr:tj|j|jf|j|j|jdIdH|_|jj|j IdHd|_ |j j IdHStj t fk r|jjdj|d|_tj|IdH|d9}|dkrd}YqXqWdS)Nr)rr rrz0Cannot receive from redis... retrying in {} secs<)r rr%rr rr r subscriberchgetr)r*r+r,formatasynciosleep)r#Z retry_sleeprrr_listenXs"  zAsyncRedisManager._listen)rrFN) __name__ __module__ __qualname____doc__namer"r/r8 __classcell__rr)r$rrs  r) r6r' urllib.parserr ImportErrorZasyncio_pubsub_managerrrrrrrrs