summaryrefslogtreecommitdiff
path: root/dogpile
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2011-08-24 15:48:26 -0400
committerMike Bayer <mike_mp@zzzcomputing.com>2011-08-24 15:48:26 -0400
commita285ce76e988e6cf14ab9b241188da34cbd4de80 (patch)
tree0a75d67b8cad18e2621692f87665e13f404409b1 /dogpile
parentc80135c7f76c8c2118025f22a478a292d66ee9b3 (diff)
downloaddogpile-core-a285ce76e988e6cf14ab9b241188da34cbd4de80.tar.gz
further cleanup
Diffstat (limited to 'dogpile')
-rw-r--r--dogpile/dogpile.py10
1 files changed, 3 insertions, 7 deletions
diff --git a/dogpile/dogpile.py b/dogpile/dogpile.py
index 65ae6e0..c3d4663 100644
--- a/dogpile/dogpile.py
+++ b/dogpile/dogpile.py
@@ -117,20 +117,16 @@ class Dogpile(object):
if not self.is_expired:
return
- has_createlock = False
if self.has_value:
if not self.dogpilelock.acquire(False):
log.debug("dogpile entering block while another thread does the create")
return
- log.debug("dogpile create lock acquired")
- has_createlock = True
-
- if not has_createlock:
+ else:
log.debug("no value, waiting for create lock")
self.dogpilelock.acquire()
- log.debug("waited for create lock")
-
try:
+ log.debug("value creation lock acquired")
+
# see if someone created the value already
if not self.is_expired:
return