mirror of
https://github.com/ethereum/solidity
synced 2023-10-03 13:03:40 +00:00
Don't count same messages twice.
This commit is contained in:
parent
ded08e82a7
commit
bd3fed43b9
@ -50,6 +50,7 @@ BOOST_AUTO_TEST_CASE(topic)
|
|||||||
auto w = wh->installWatch(BuildTopicMask("odd"));
|
auto w = wh->installWatch(BuildTopicMask("odd"));
|
||||||
|
|
||||||
started = true;
|
started = true;
|
||||||
|
set<unsigned> received;
|
||||||
|
|
||||||
for (int iterout = 0, last = 0; iterout < 200 && last < 81; ++iterout)
|
for (int iterout = 0, last = 0; iterout < 200 && last < 81; ++iterout)
|
||||||
{
|
{
|
||||||
@ -57,6 +58,9 @@ BOOST_AUTO_TEST_CASE(topic)
|
|||||||
{
|
{
|
||||||
Message msg = wh->envelope(i).open(wh->fullTopic(w));
|
Message msg = wh->envelope(i).open(wh->fullTopic(w));
|
||||||
last = RLP(msg.payload()).toInt<unsigned>();
|
last = RLP(msg.payload()).toInt<unsigned>();
|
||||||
|
if (received.count(last))
|
||||||
|
continue;
|
||||||
|
received.insert(last);
|
||||||
cnote << "New message from:" << msg.from().abridged() << RLP(msg.payload()).toInt<unsigned>();
|
cnote << "New message from:" << msg.from().abridged() << RLP(msg.payload()).toInt<unsigned>();
|
||||||
result += last;
|
result += last;
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user