Show More
@@ -203,3 +203,12 b' class RedisPickleBackend(Serializer, red' | |||||
203 | for key, value in mapping.items(): |
|
203 | for key, value in mapping.items(): | |
204 | pipe.setex(key, self.redis_expiration_time, value) |
|
204 | pipe.setex(key, self.redis_expiration_time, value) | |
205 | pipe.execute() |
|
205 | pipe.execute() | |
|
206 | ||||
|
207 | def get_mutex(self, key): | |||
|
208 | u = redis_backend.u | |||
|
209 | if self.distributed_lock: | |||
|
210 | lock_key = u('_lock_{0}').format(key) | |||
|
211 | log.debug('Trying to acquire Redis lock for key %s', lock_key) | |||
|
212 | return self.client.lock(lock_key, self.lock_timeout, self.lock_sleep) | |||
|
213 | else: | |||
|
214 | return None |
General Comments 0
You need to be logged in to leave comments.
Login now