cerc-io/solidity
16
0
Fork 0
mirror of https://github.com/ethereum/solidity synced 2023-10-03 13:03:40 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix whispertopic test

Browse Source
This commit is contained in:
subtly 2015-02-04 17:50:03 -08:00
parent 74e509acd2
commit c44376d1f9
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
whisperTopic.cpp
View File

@ -40,15 +40,6 @@ BOOST_AUTO_TEST_CASE(topic)
auto whOther = phOther.registerCapability(new WhisperHost()); auto whOther = phOther.registerCapability(new WhisperHost());
phOther.start(); phOther.start();
Host ph("Test", NetworkPreferences(30300, "127.0.0.1", false, true));
auto wh = ph.registerCapability(new WhisperHost());
ph.start();
this_thread::sleep_for(chrono::milliseconds(100));
ph.addNode(phOther.id(), "127.0.0.1", 30303, 30303);
this_thread::sleep_for(chrono::milliseconds(500));
bool started = false; bool started = false;
unsigned result = 0; unsigned result = 0;
std::thread listener([&]() std::thread listener([&]()
@ -66,7 +57,7 @@ BOOST_AUTO_TEST_CASE(topic)
{ {
for (auto i: whOther->checkWatch(w)) for (auto i: whOther->checkWatch(w))
{ {
Message msg = wh->envelope(i).open(wh->fullTopic(w)); Message msg = whOther->envelope(i).open(whOther->fullTopic(w));
last = RLP(msg.payload()).toInt<unsigned>(); last = RLP(msg.payload()).toInt<unsigned>();
if (received.count(last)) if (received.count(last))
continue; continue;
@ -78,6 +69,15 @@ BOOST_AUTO_TEST_CASE(topic)
} }
}); });
Host ph("Test", NetworkPreferences(30300, "127.0.0.1", false, true));
auto wh = ph.registerCapability(new WhisperHost());
ph.start();
this_thread::sleep_for(chrono::milliseconds(100));
ph.addNode(phOther.id(), "127.0.0.1", 30303, 30303);
this_thread::sleep_for(chrono::milliseconds(500));
while (!started) while (!started)
this_thread::sleep_for(chrono::milliseconds(2)); this_thread::sleep_for(chrono::milliseconds(2));