Commit abccd411 authored by Grégory Wisniewski's avatar Grégory Wisniewski

Select only identified client nodes.

Between closure request and effect, a client node can be registered to the
node manager without a connection. As there is no needs to use an
unconnected client node, always set only_identified parameter to True.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@2098 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 956d5c91
...@@ -73,7 +73,7 @@ class StorageServiceHandler(BaseServiceHandler): ...@@ -73,7 +73,7 @@ class StorageServiceHandler(BaseServiceHandler):
transaction_node = t.getNode() transaction_node = t.getNode()
invalidate_objects = Packets.InvalidateObjects(t.getOIDList(), tid) invalidate_objects = Packets.InvalidateObjects(t.getOIDList(), tid)
answer_transaction_finished = Packets.AnswerTransactionFinished(tid) answer_transaction_finished = Packets.AnswerTransactionFinished(tid)
for client_node in nm.getClientList(): for client_node in nm.getClientList(only_identified=True):
c = client_node.getConnection() c = client_node.getConnection()
if client_node is transaction_node: if client_node is transaction_node:
c.answer(answer_transaction_finished, msg_id=t.getMessageId()) c.answer(answer_transaction_finished, msg_id=t.getMessageId())
......
...@@ -167,7 +167,7 @@ class Application(object): ...@@ -167,7 +167,7 @@ class Application(object):
if node is not None and node.isHidden(): if node is not None and node.isHidden():
self.wait() self.wait()
# drop any client node and clear event queue # drop any client node and clear event queue
for node in self.nm.getClientList(): for node in self.nm.getClientList(only_identified=True):
node.getConnection().close() node.getConnection().close()
self.event_queue = deque() self.event_queue = deque()
try: try:
......
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