Commit a771b9f1 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 4b02cadb
...@@ -494,7 +494,7 @@ class NodeManager(EventQueue): ...@@ -494,7 +494,7 @@ class NodeManager(EventQueue):
map(Node.asTuple, self._node_set), ' * '))) map(Node.asTuple, self._node_set), ' * ')))
self.logQueuedEvents() self.logQueuedEvents()
# node_type -> node_klass # {} node_type -> node_klass
@apply @apply
def NODE_TYPE_MAPPING(): def NODE_TYPE_MAPPING():
def setmethod(cls, attr, value): def setmethod(cls, attr, value):
......
...@@ -750,7 +750,7 @@ class NotifyPartitionTable(Packet): ...@@ -750,7 +750,7 @@ class NotifyPartitionTable(Packet):
class PartitionChanges(Packet): class PartitionChanges(Packet):
""" """
Notify a subset of a partition table. This is used to notify changes. Notify a subset of a partition table. This is used to notify changes.
PM -> S, C. XXX also -> A (see RecoveryManager) PM -> S, C.
""" """
_fmt = PStruct('notify_partition_changes', _fmt = PStruct('notify_partition_changes',
PPTID('ptid'), PPTID('ptid'),
......
...@@ -200,7 +200,7 @@ class Serialized(object): ...@@ -200,7 +200,7 @@ class Serialized(object):
with cls._busy_cond: with cls._busy_cond:
while cls._busy: while cls._busy:
cls._busy_cond.wait() cls._busy_cond.wait()
for app in check_timeout: # XXX hack (?), used only in 1 place for app in check_timeout: # XXX hack?, used only in 1 place (testBackupUpstreamStorageDead)
app.em.epoll.check_timeout = True app.em.epoll.check_timeout = True
app.em.wakeup() app.em.wakeup()
del app del app
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment