sikkienl/dash
1
0
Fork 0
mirror of https://github.com/dashpay/dash.git synced 2024-12-25 20:12:57 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: use unique port for interface_zmq_dash.py - follow-up for bitcoin/bitcoin#26805

Browse Source
This commit is contained in:
Konstantin Akimov 2024-10-29 15:16:42 +07:00
parent 87caafb92f
commit 80c5481c3e
No known key found for this signature in database
GPG Key ID: 2176C4A5D01EA524
1 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
test/functional/interface_zmq_dash.py
View File

@ -14,7 +14,11 @@ import time
from test_framework.test_framework import DashTestFramework from test_framework.test_framework import DashTestFramework
from test_framework.p2p import P2PInterface from test_framework.p2p import P2PInterface
from test_framework.util import assert_equal, assert_raises_rpc_error from test_framework.util import (
assert_equal,
assert_raises_rpc_error,
p2p_port,
)
from test_framework.messages import ( from test_framework.messages import (
CBlock, CBlock,
CGovernanceObject, CGovernanceObject,
@ -99,16 +103,20 @@ class TestP2PConn(P2PInterface):
class DashZMQTest (DashTestFramework): class DashZMQTest (DashTestFramework):
def set_test_params(self): def set_test_params(self):
self.set_dash_test_params(5, 4)
# That's where the zmq publisher will listen for subscriber # That's where the zmq publisher will listen for subscriber
self.address = "tcp://127.0.0.1:28331" self.zmq_port_base = p2p_port(self.num_nodes + 1)
self.address = f"tcp://127.0.0.1:{self.zmq_port_base}"
# node0 creates all available ZMQ publisher # node0 creates all available ZMQ publisher
node0_extra_args = ["-zmqpub%s=%s" % (pub.value, self.address) for pub in ZMQPublisher] node0_extra_args = [f"-zmqpub{pub.value}={self.address}" for pub in ZMQPublisher]
node0_extra_args.append("-whitelist=127.0.0.1") node0_extra_args.append("-whitelist=127.0.0.1")
node0_extra_args.append("-watchquorums") # have to watch quorums to receive recsigs and trigger zmq node0_extra_args.append("-watchquorums") # have to watch quorums to receive recsigs and trigger zmq
extra_args = [[]] * 5 #extra_args = [node0_extra_args, [], [], [], []]
extra_args[0] = node0_extra_args self.extra_args[0] = node0_extra_args
self.set_dash_test_params(5, 4, extra_args=extra_args)
self.set_dash_llmq_test_params(4, 4) self.set_dash_llmq_test_params(4, 4)
def skip_test_if_missing_module(self): def skip_test_if_missing_module(self):