s/aquire/acquire/g
This commit is contained in:
parent
0aff09f6c9
commit
62ce3034f3
|
@ -539,12 +539,12 @@ class FederationServer(FederationBase):
|
||||||
# If we're missing stuff, ensure we only fetch stuff one
|
# If we're missing stuff, ensure we only fetch stuff one
|
||||||
# at a time.
|
# at a time.
|
||||||
logger.info(
|
logger.info(
|
||||||
"Aquiring lock for room %r to fetch %d missing events: %r...",
|
"Acquiring lock for room %r to fetch %d missing events: %r...",
|
||||||
pdu.room_id, len(prevs - seen), list(prevs - seen)[:5],
|
pdu.room_id, len(prevs - seen), list(prevs - seen)[:5],
|
||||||
)
|
)
|
||||||
with (yield self._room_pdu_linearizer.queue(pdu.room_id)):
|
with (yield self._room_pdu_linearizer.queue(pdu.room_id)):
|
||||||
logger.info(
|
logger.info(
|
||||||
"Aquired lock for room %r to fetch %d missing events",
|
"Acquired lock for room %r to fetch %d missing events",
|
||||||
pdu.room_id, len(prevs - seen),
|
pdu.room_id, len(prevs - seen),
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
|
@ -185,7 +185,7 @@ class Linearizer(object):
|
||||||
self.key_to_defer[key] = new_defer
|
self.key_to_defer[key] = new_defer
|
||||||
|
|
||||||
if current_defer:
|
if current_defer:
|
||||||
logger.info("Waiting to aquire linearizer lock for key %r", key)
|
logger.info("Waiting to acquire linearizer lock for key %r", key)
|
||||||
with PreserveLoggingContext():
|
with PreserveLoggingContext():
|
||||||
yield current_defer
|
yield current_defer
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue