Commit 8cde1c34 authored by Vincent Pelletier's avatar Vincent Pelletier

master.handlers.client: Inline single-use locals.

parent e8a423e2
...@@ -75,16 +75,21 @@ class ClientServiceHandler(MasterHandler): ...@@ -75,16 +75,21 @@ class ClientServiceHandler(MasterHandler):
raise ProtocolError('No storage node ready for transaction') raise ProtocolError('No storage node ready for transaction')
identified_node_list = app.nm.getIdentifiedList(pool_set=uuid_set) identified_node_list = app.nm.getIdentifiedList(pool_set=uuid_set)
usable_uuid_set = set(x.getUUID() for x in identified_node_list)
partitions = app.pt.getPartitions()
peer_id = conn.getPeerId()
tid = app.tm.prepare(ttid, partitions, oid_list, usable_uuid_set,
peer_id)
# Request locking data. # Request locking data.
# build a new set as we may not send the message to all nodes as some # build a new set as we may not send the message to all nodes as some
# might be not reachable at that time # might be not reachable at that time
p = Packets.AskLockInformation(ttid, tid, oid_list) p = Packets.AskLockInformation(
ttid,
app.tm.prepare(
ttid,
app.pt.getPartitions(),
oid_list,
set(x.getUUID() for x in identified_node_list),
conn.getPeerId(),
),
oid_list,
)
for node in identified_node_list: for node in identified_node_list:
node.ask(p, timeout=60) node.ask(p, timeout=60)
......
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