Skip to content

Commit 07c7319

Browse files
committed
refactor: use nodeIdx instead of node.index with MasternodeInfo
node is self.nodes[nodeIdx], so node.index will always be nodeIdx, just fetch nodeIdx directly instead.
1 parent 08e81d8 commit 07c7319

File tree

5 files changed

+17
-17
lines changed

5 files changed

+17
-17
lines changed

test/functional/feature_llmq_data_recovery.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ def set_test_params(self):
3333
self.set_dash_llmq_test_params(4, 3)
3434

3535
def restart_mn(self, mn: MasternodeInfo, reindex=False, qvvec_sync=None, qdata_recovery_enabled=True):
36-
args = self.extra_args[mn.node.index] + ['-masternodeblsprivkey=%s' % mn.keyOperator,
36+
args = self.extra_args[mn.nodeIdx] + ['-masternodeblsprivkey=%s' % mn.keyOperator,
3737
'-llmq-data-recovery=%d' % qdata_recovery_enabled]
3838
if qvvec_sync is None:
3939
qvvec_sync = []
@@ -42,12 +42,12 @@ def restart_mn(self, mn: MasternodeInfo, reindex=False, qvvec_sync=None, qdata_r
4242
if reindex:
4343
args.append('-reindex')
4444
bb_hash = mn.node.getbestblockhash()
45-
self.restart_node(mn.node.index, args)
45+
self.restart_node(mn.nodeIdx, args)
4646
self.wait_until(lambda: mn.node.getbestblockhash() == bb_hash)
4747
else:
48-
self.restart_node(mn.node.index, args)
48+
self.restart_node(mn.nodeIdx, args)
4949
force_finish_mnsync(mn.node)
50-
self.connect_nodes(mn.node.index, 0)
50+
self.connect_nodes(mn.nodeIdx, 0)
5151
if qdata_recovery_enabled:
5252
# trigger recovery threads and wait for them to start
5353
self.generate(self.nodes[0], 1, sync_fun=self.no_op)

test/functional/feature_llmq_signing.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -188,7 +188,7 @@ def assert_sigs_nochange(hasrecsigs, isconflicting1, isconflicting2, timeout):
188188
assert_sigs_nochange(False, False, False, 3)
189189
# Need to re-connect so that it later gets the recovered sig
190190
mn.node.setnetworkactive(True)
191-
self.connect_nodes(mn.node.index, 0)
191+
self.connect_nodes(mn.nodeIdx, 0)
192192
force_finish_mnsync(mn.node)
193193
# Make sure intra-quorum connections were also restored
194194
self.bump_mocktime(1) # need this to bypass quorum connection retry timeout

test/functional/feature_llmq_simplepose.py

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -75,20 +75,20 @@ def isolate_mn(self, mn: MasternodeInfo):
7575

7676
def close_mn_port(self, mn: MasternodeInfo):
7777
self.deaf_mns.append(mn)
78-
self.stop_node(mn.node.index)
78+
self.stop_node(mn.nodeIdx)
7979
self.start_masternode(mn, ["-listen=0", "-nobind"])
80-
self.connect_nodes(mn.node.index, 0)
80+
self.connect_nodes(mn.nodeIdx, 0)
8181
# Make sure the to-be-banned node is still connected well via outbound connections
8282
for mn2 in self.mninfo: # type: MasternodeInfo
8383
if self.deaf_mns.count(mn2) == 0:
84-
self.connect_nodes(mn.node.index, mn2.node.index)
84+
self.connect_nodes(mn.nodeIdx, mn2.node.index)
8585
self.reset_probe_timeouts()
8686
return False, False
8787

8888
def force_old_mn_proto(self, mn: MasternodeInfo):
89-
self.stop_node(mn.node.index)
89+
self.stop_node(mn.nodeIdx)
9090
self.start_masternode(mn, ["-pushversion=70216"])
91-
self.connect_nodes(mn.node.index, 0)
91+
self.connect_nodes(mn.nodeIdx, 0)
9292
self.reset_probe_timeouts()
9393
return False, True
9494

@@ -210,11 +210,11 @@ def repair_masternodes(self, restart):
210210
self.nodes[0].sendtoaddress(addr, 0.1)
211211
self.nodes[0].protx('update_service', mn.proTxHash, f'127.0.0.1:{mn.nodePort}', mn.keyOperator, "", addr)
212212
if restart:
213-
self.stop_node(mn.node.index)
213+
self.stop_node(mn.nodeIdx)
214214
self.start_masternode(mn)
215215
else:
216216
mn.node.setnetworkactive(True)
217-
self.connect_nodes(mn.node.index, 0)
217+
self.connect_nodes(mn.nodeIdx, 0)
218218

219219
# syncing blocks only since node 0 has txes waiting to be mined
220220
self.sync_blocks()
@@ -230,7 +230,7 @@ def repair_masternodes(self, restart):
230230
self.wait_until(lambda: mn.node.getconnectioncount() == 0)
231231
mn.node.setnetworkactive(True)
232232
force_finish_mnsync(mn.node)
233-
self.connect_nodes(mn.node.index, 0)
233+
self.connect_nodes(mn.nodeIdx, 0)
234234

235235
def reset_probe_timeouts(self):
236236
# Make sure all masternodes will reconnect/re-probe

test/functional/feature_mnehf.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ def restart_all_nodes(self, params=None):
4242

4343
self.restart_node(0)
4444
for mn in self.mninfo: # type: MasternodeInfo
45-
index = mn.node.index
45+
index = mn.nodeIdx
4646
self.stop_node(index)
4747
self.start_masternode(mn)
4848
for i in range(1, self.num_nodes):

test/functional/p2p_quorum_data.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -124,12 +124,12 @@ def set_test_params(self):
124124
self.set_dash_test_params(4, 3, extra_args=extra_args)
125125

126126
def restart_mn(self, mn: MasternodeInfo, reindex=False):
127-
args = self.extra_args[mn.node.index] + ['-masternodeblsprivkey=%s' % mn.keyOperator]
127+
args = self.extra_args[mn.nodeIdx] + ['-masternodeblsprivkey=%s' % mn.keyOperator]
128128
if reindex:
129129
args.append('-reindex')
130-
self.restart_node(mn.node.index, args)
130+
self.restart_node(mn.nodeIdx, args)
131131
force_finish_mnsync(mn.node)
132-
self.connect_nodes(mn.node.index, 0)
132+
self.connect_nodes(mn.nodeIdx, 0)
133133
self.sync_blocks()
134134

135135
def run_test(self):

0 commit comments

Comments
 (0)