mirror of
https://github.com/ethereum/solidity
synced 2023-10-03 13:03:40 +00:00
Merge pull request #1186 from onepremise/develop
Updates for Building all cpp-ethereum on MinGW(64)
This commit is contained in:
commit
0c2a7fbe7d
@ -23,7 +23,9 @@
|
||||
|
||||
#include <thread>
|
||||
#include <chrono>
|
||||
|
||||
#include <boost/filesystem/path.hpp>
|
||||
|
||||
#include <libethereum/Client.h>
|
||||
#include <liblll/Compiler.h>
|
||||
#include <libevm/VMFactory.h>
|
||||
|
@ -22,7 +22,9 @@
|
||||
#pragma once
|
||||
|
||||
#include <functional>
|
||||
|
||||
#include <boost/test/unit_test.hpp>
|
||||
|
||||
#include "JsonSpiritHeaders.h"
|
||||
#include <libethereum/State.h>
|
||||
#include <libevm/ExtVMFace.h>
|
||||
|
@ -23,8 +23,10 @@
|
||||
#include <string>
|
||||
#include <iostream>
|
||||
#include <chrono>
|
||||
|
||||
#include <boost/random.hpp>
|
||||
#include <boost/filesystem/path.hpp>
|
||||
|
||||
#pragma GCC diagnostic ignored "-Wunused-parameter"
|
||||
#include <json_spirit/json_spirit.h>
|
||||
#include <json_spirit/json_spirit_reader_template.h>
|
||||
|
1
fork.cpp
1
fork.cpp
@ -22,6 +22,7 @@
|
||||
|
||||
#include <boost/test/unit_test.hpp>
|
||||
#include <boost/filesystem/operations.hpp>
|
||||
|
||||
#include <libethereum/Client.h>
|
||||
#include <libethereum/CanonBlockChain.h>
|
||||
#include <libethereum/EthereumHost.h>
|
||||
|
@ -22,10 +22,12 @@
|
||||
|
||||
#include <fstream>
|
||||
#include <random>
|
||||
|
||||
#include <boost/test/unit_test.hpp>
|
||||
|
||||
#include "JsonSpiritHeaders.h"
|
||||
#include <libdevcore/CommonIO.h>
|
||||
#include <libethereum/CanonBlockChain.h>
|
||||
#include <boost/test/unit_test.hpp>
|
||||
#include "TestHelper.h"
|
||||
|
||||
using namespace std;
|
||||
@ -40,7 +42,7 @@ BOOST_AUTO_TEST_CASE(emptySHA3Types)
|
||||
{
|
||||
h256 emptyListSHA3(fromHex("1dcc4de8dec75d7aab85b567b6ccd41ad312451b948a7413f0a142fd40d49347"));
|
||||
BOOST_REQUIRE_EQUAL(emptyListSHA3, EmptyListSHA3);
|
||||
|
||||
|
||||
h256 emptySHA3(fromHex("c5d2460186f7233c927e7db2dcc703c0e500b653ca82273b7bfad8045d85a470"));
|
||||
BOOST_REQUIRE_EQUAL(emptySHA3, EmptySHA3);
|
||||
}
|
||||
|
@ -21,11 +21,13 @@
|
||||
*/
|
||||
|
||||
#include <fstream>
|
||||
|
||||
#include <boost/test/unit_test.hpp>
|
||||
|
||||
#include "JsonSpiritHeaders.h"
|
||||
#include <libdevcore/Log.h>
|
||||
#include <libdevcore/CommonIO.h>
|
||||
#include <libdevcrypto/TrieCommon.h>
|
||||
#include <boost/test/unit_test.hpp>
|
||||
#include "TestHelper.h"
|
||||
|
||||
using namespace std;
|
||||
@ -53,8 +55,8 @@ BOOST_AUTO_TEST_CASE(hexPrefix_test)
|
||||
for (auto& i: o["seq"].get_array())
|
||||
v.push_back((byte)i.get_int());
|
||||
auto e = hexPrefixEncode(v, o["term"].get_bool());
|
||||
BOOST_REQUIRE( ! o["out"].is_null() );
|
||||
BOOST_CHECK( o["out"].get_str() == toHex(e) );
|
||||
BOOST_REQUIRE( ! o["out"].is_null() );
|
||||
BOOST_CHECK( o["out"].get_str() == toHex(e) );
|
||||
}
|
||||
}
|
||||
|
||||
|
37
net.cpp
37
net.cpp
@ -20,6 +20,7 @@
|
||||
*/
|
||||
|
||||
#include <boost/test/unit_test.hpp>
|
||||
|
||||
#include <libdevcore/Worker.h>
|
||||
#include <libdevcrypto/Common.h>
|
||||
#include <libp2p/UDP.h>
|
||||
@ -43,7 +44,7 @@ public:
|
||||
void start() { startWorking(); }
|
||||
void doWork() { m_io.run(); }
|
||||
void doneWorking() { m_io.reset(); m_io.poll(); m_io.reset(); }
|
||||
|
||||
|
||||
protected:
|
||||
ba::io_service m_io;
|
||||
};
|
||||
@ -52,23 +53,23 @@ struct TestNodeTable: public NodeTable
|
||||
{
|
||||
/// Constructor
|
||||
TestNodeTable(ba::io_service& _io, KeyPair _alias, uint16_t _port = 30300): NodeTable(_io, _alias, _port) {}
|
||||
|
||||
|
||||
static std::vector<std::pair<KeyPair,unsigned>> createTestNodes(unsigned _count)
|
||||
{
|
||||
std::vector<std::pair<KeyPair,unsigned>> ret;
|
||||
asserts(_count < 1000);
|
||||
static uint16_t s_basePort = 30500;
|
||||
|
||||
|
||||
ret.clear();
|
||||
for (unsigned i = 0; i < _count; i++)
|
||||
{
|
||||
KeyPair k = KeyPair::create();
|
||||
ret.push_back(make_pair(k,s_basePort+i));
|
||||
}
|
||||
|
||||
|
||||
return std::move(ret);
|
||||
}
|
||||
|
||||
|
||||
void pingTestNodes(std::vector<std::pair<KeyPair,unsigned>> const& _testNodes)
|
||||
{
|
||||
bi::address ourIp = bi::address::from_string("127.0.0.1");
|
||||
@ -78,7 +79,7 @@ struct TestNodeTable: public NodeTable
|
||||
this_thread::sleep_for(chrono::milliseconds(2));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void populateTestNodes(std::vector<std::pair<KeyPair,unsigned>> const& _testNodes, size_t _count = 0)
|
||||
{
|
||||
if (!_count)
|
||||
@ -91,7 +92,7 @@ struct TestNodeTable: public NodeTable
|
||||
else
|
||||
break;
|
||||
}
|
||||
|
||||
|
||||
void reset()
|
||||
{
|
||||
Guard l(x_state);
|
||||
@ -108,13 +109,13 @@ struct TestNodeTableHost: public TestHost
|
||||
~TestNodeTableHost() { m_io.stop(); stopWorking(); }
|
||||
|
||||
void setup() { for (auto n: testNodes) nodeTables.push_back(make_shared<TestNodeTable>(m_io,n.first,n.second)); }
|
||||
|
||||
|
||||
void pingAll() { for (auto& t: nodeTables) t->pingTestNodes(testNodes); }
|
||||
|
||||
|
||||
void populateAll(size_t _count = 0) { for (auto& t: nodeTables) t->populateTestNodes(testNodes, _count); }
|
||||
|
||||
|
||||
void populate(size_t _count = 0) { nodeTable->populateTestNodes(testNodes, _count); }
|
||||
|
||||
|
||||
KeyPair m_alias;
|
||||
shared_ptr<TestNodeTable> nodeTable;
|
||||
std::vector<std::pair<KeyPair,unsigned>> testNodes; // keypair and port
|
||||
@ -130,7 +131,7 @@ public:
|
||||
void onReceived(UDPSocketFace*, bi::udp::endpoint const&, bytesConstRef _packet) { if (_packet.toString() == "AAAA") success = true; }
|
||||
|
||||
shared_ptr<UDPSocket<TestUDPSocket, 1024>> m_socket;
|
||||
|
||||
|
||||
bool success = false;
|
||||
};
|
||||
|
||||
@ -139,7 +140,7 @@ BOOST_AUTO_TEST_CASE(test_neighbours_packet)
|
||||
KeyPair k = KeyPair::create();
|
||||
std::vector<std::pair<KeyPair,unsigned>> testNodes(TestNodeTable::createTestNodes(16));
|
||||
bi::udp::endpoint to(boost::asio::ip::address::from_string("127.0.0.1"), 30000);
|
||||
|
||||
|
||||
Neighbours out(to);
|
||||
for (auto n: testNodes)
|
||||
{
|
||||
@ -186,25 +187,25 @@ BOOST_AUTO_TEST_CASE(kademlia)
|
||||
node.setup();
|
||||
node.populate();
|
||||
clog << "NodeTable:\n" << *node.nodeTable.get() << endl;
|
||||
|
||||
|
||||
node.populateAll();
|
||||
clog << "NodeTable:\n" << *node.nodeTable.get() << endl;
|
||||
|
||||
|
||||
auto nodes = node.nodeTable->nodes();
|
||||
nodes.sort();
|
||||
|
||||
|
||||
node.nodeTable->reset();
|
||||
clog << "NodeTable:\n" << *node.nodeTable.get() << endl;
|
||||
|
||||
node.populate(1);
|
||||
clog << "NodeTable:\n" << *node.nodeTable.get() << endl;
|
||||
|
||||
|
||||
node.nodeTable->discover();
|
||||
this_thread::sleep_for(chrono::milliseconds(2000));
|
||||
clog << "NodeTable:\n" << *node.nodeTable.get() << endl;
|
||||
|
||||
BOOST_REQUIRE_EQUAL(node.nodeTable->count(), 8);
|
||||
|
||||
|
||||
auto netNodes = node.nodeTable->nodes();
|
||||
netNodes.sort();
|
||||
|
||||
|
148
rlp.cpp
148
rlp.cpp
@ -22,11 +22,13 @@
|
||||
|
||||
#include <fstream>
|
||||
#include <sstream>
|
||||
|
||||
#include <boost/test/unit_test.hpp>
|
||||
|
||||
#include <libdevcore/Log.h>
|
||||
#include <libdevcore/RLP.h>
|
||||
#include <libdevcore/Common.h>
|
||||
#include <libdevcore/CommonIO.h>
|
||||
#include <boost/test/unit_test.hpp>
|
||||
#include <algorithm>
|
||||
#include "JsonSpiritHeaders.h"
|
||||
#include "TestHelper.h"
|
||||
@ -66,76 +68,76 @@ namespace dev
|
||||
testPath += "/BasicTests";
|
||||
|
||||
string s = asString(contents(testPath + "/rlptest.json"));
|
||||
BOOST_REQUIRE_MESSAGE( s.length() > 0,
|
||||
"Contents of 'rlptest.json' is empty. Have you cloned the 'tests' repo branch develop?");
|
||||
BOOST_REQUIRE_MESSAGE( s.length() > 0,
|
||||
"Contents of 'rlptest.json' is empty. Have you cloned the 'tests' repo branch develop?");
|
||||
js::read_string(s, v);
|
||||
}
|
||||
}
|
||||
|
||||
static void checkRLPTestCase(js::mObject& o)
|
||||
{
|
||||
BOOST_REQUIRE( o.count("in") > 0 );
|
||||
BOOST_REQUIRE( o.count("out") > 0 );
|
||||
BOOST_REQUIRE(!o["out"].is_null());
|
||||
}
|
||||
{
|
||||
BOOST_REQUIRE( o.count("in") > 0 );
|
||||
BOOST_REQUIRE( o.count("out") > 0 );
|
||||
BOOST_REQUIRE(!o["out"].is_null());
|
||||
}
|
||||
|
||||
static void checkRLPAgainstJson(js::mValue& v, RLP& u)
|
||||
{
|
||||
if ( v.type() == js::str_type )
|
||||
{
|
||||
if ( v.type() == js::str_type )
|
||||
{
|
||||
const std::string& expectedText = v.get_str();
|
||||
if ( !expectedText.empty() && expectedText.front() == '#' )
|
||||
{
|
||||
// Deal with bigint instead of a raw string
|
||||
std::string bigIntStr = expectedText.substr(1,expectedText.length()-1);
|
||||
std::stringstream bintStream(bigIntStr);
|
||||
bigint val;
|
||||
bintStream >> val;
|
||||
BOOST_CHECK( !u.isList() );
|
||||
if ( !expectedText.empty() && expectedText.front() == '#' )
|
||||
{
|
||||
// Deal with bigint instead of a raw string
|
||||
std::string bigIntStr = expectedText.substr(1,expectedText.length()-1);
|
||||
std::stringstream bintStream(bigIntStr);
|
||||
bigint val;
|
||||
bintStream >> val;
|
||||
BOOST_CHECK( !u.isList() );
|
||||
BOOST_CHECK( !u.isNull() );
|
||||
BOOST_CHECK( u ); // operator bool()
|
||||
BOOST_CHECK(u == val);
|
||||
}
|
||||
else
|
||||
{
|
||||
BOOST_CHECK( !u.isList() );
|
||||
BOOST_CHECK( !u.isNull() );
|
||||
BOOST_CHECK( u.isData() );
|
||||
BOOST_CHECK( u );
|
||||
BOOST_CHECK( u.size() == expectedText.length() );
|
||||
BOOST_CHECK(u == expectedText);
|
||||
BOOST_CHECK(u == val);
|
||||
}
|
||||
}
|
||||
else if ( v.type() == js::int_type )
|
||||
{
|
||||
const int expectedValue = v.get_int();
|
||||
BOOST_CHECK( u.isInt() );
|
||||
BOOST_CHECK( !u.isList() );
|
||||
else
|
||||
{
|
||||
BOOST_CHECK( !u.isList() );
|
||||
BOOST_CHECK( !u.isNull() );
|
||||
BOOST_CHECK( u.isData() );
|
||||
BOOST_CHECK( u );
|
||||
BOOST_CHECK( u.size() == expectedText.length() );
|
||||
BOOST_CHECK(u == expectedText);
|
||||
}
|
||||
}
|
||||
else if ( v.type() == js::int_type )
|
||||
{
|
||||
const int expectedValue = v.get_int();
|
||||
BOOST_CHECK( u.isInt() );
|
||||
BOOST_CHECK( !u.isList() );
|
||||
BOOST_CHECK( !u.isNull() );
|
||||
BOOST_CHECK( u ); // operator bool()
|
||||
BOOST_CHECK(u == expectedValue);
|
||||
}
|
||||
else if ( v.type() == js::array_type )
|
||||
{
|
||||
BOOST_CHECK( u.isList() );
|
||||
BOOST_CHECK( !u.isInt() );
|
||||
BOOST_CHECK( !u.isData() );
|
||||
js::mArray& arr = v.get_array();
|
||||
BOOST_CHECK( u.itemCount() == arr.size() );
|
||||
unsigned i;
|
||||
for( i = 0; i < arr.size(); i++ )
|
||||
{
|
||||
RLP item = u[i];
|
||||
checkRLPAgainstJson(arr[i], item);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
BOOST_CHECK(u == expectedValue);
|
||||
}
|
||||
else if ( v.type() == js::array_type )
|
||||
{
|
||||
BOOST_CHECK( u.isList() );
|
||||
BOOST_CHECK( !u.isInt() );
|
||||
BOOST_CHECK( !u.isData() );
|
||||
js::mArray& arr = v.get_array();
|
||||
BOOST_CHECK( u.itemCount() == arr.size() );
|
||||
unsigned i;
|
||||
for( i = 0; i < arr.size(); i++ )
|
||||
{
|
||||
RLP item = u[i];
|
||||
checkRLPAgainstJson(arr[i], item);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
BOOST_ERROR("Invalid Javascript object!");
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
BOOST_AUTO_TEST_SUITE(BasicTests)
|
||||
|
||||
@ -154,30 +156,30 @@ BOOST_AUTO_TEST_CASE(rlp_encoding_test)
|
||||
RLPStream s;
|
||||
dev::test::buildRLP(o["in"], s);
|
||||
|
||||
std::string expectedText(o["out"].get_str());
|
||||
std::transform(expectedText.begin(), expectedText.end(), expectedText.begin(), ::tolower );
|
||||
std::string expectedText(o["out"].get_str());
|
||||
std::transform(expectedText.begin(), expectedText.end(), expectedText.begin(), ::tolower );
|
||||
|
||||
const std::string& computedText = toHex(s.out());
|
||||
const std::string& computedText = toHex(s.out());
|
||||
|
||||
std::stringstream msg;
|
||||
std::stringstream msg;
|
||||
msg << "Encoding Failed: expected: " << expectedText << std::endl;
|
||||
msg << " But Computed: " << computedText;
|
||||
msg << " But Computed: " << computedText;
|
||||
|
||||
BOOST_CHECK_MESSAGE(
|
||||
expectedText == computedText,
|
||||
expectedText == computedText,
|
||||
msg.str()
|
||||
);
|
||||
);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
BOOST_AUTO_TEST_CASE(rlp_decoding_test)
|
||||
{
|
||||
cnote << "Testing RLP decoding...";
|
||||
// Uses the same test cases as encoding but in reverse.
|
||||
// We read into the string of hex values, convert to bytes,
|
||||
// and then compare the output structure to the json of the
|
||||
// input object.
|
||||
cnote << "Testing RLP decoding...";
|
||||
// Uses the same test cases as encoding but in reverse.
|
||||
// We read into the string of hex values, convert to bytes,
|
||||
// and then compare the output structure to the json of the
|
||||
// input object.
|
||||
js::mValue v;
|
||||
dev::test::getRLPTestCases(v);
|
||||
for (auto& i: v.get_obj())
|
||||
@ -185,11 +187,11 @@ BOOST_AUTO_TEST_CASE(rlp_decoding_test)
|
||||
js::mObject& o = i.second.get_obj();
|
||||
cnote << i.first;
|
||||
dev::test::checkRLPTestCase(o);
|
||||
|
||||
js::mValue& inputData = o["in"];
|
||||
bytes payloadToDecode = fromHex(o["out"].get_str());
|
||||
|
||||
RLP payload(payloadToDecode);
|
||||
js::mValue& inputData = o["in"];
|
||||
bytes payloadToDecode = fromHex(o["out"].get_str());
|
||||
|
||||
RLP payload(payloadToDecode);
|
||||
|
||||
dev::test::checkRLPAgainstJson(inputData, payload);
|
||||
|
||||
|
@ -22,6 +22,7 @@
|
||||
|
||||
#include <boost/filesystem/operations.hpp>
|
||||
#include <boost/test/unit_test.hpp>
|
||||
|
||||
#include "JsonSpiritHeaders.h"
|
||||
#include <libdevcore/CommonIO.h>
|
||||
#include <libethereum/CanonBlockChain.h>
|
||||
|
4
trie.cpp
4
trie.cpp
@ -22,12 +22,14 @@
|
||||
|
||||
#include <fstream>
|
||||
#include <random>
|
||||
|
||||
#include <boost/test/unit_test.hpp>
|
||||
|
||||
#include "JsonSpiritHeaders.h"
|
||||
#include <libdevcore/CommonIO.h>
|
||||
#include <libdevcrypto/TrieDB.h>
|
||||
#include "TrieHash.h"
|
||||
#include "MemTrie.h"
|
||||
#include <boost/test/unit_test.hpp>
|
||||
#include "TestHelper.h"
|
||||
|
||||
using namespace std;
|
||||
|
@ -22,6 +22,7 @@
|
||||
|
||||
#include <boost/test/unit_test.hpp>
|
||||
#include <boost/filesystem/operations.hpp>
|
||||
|
||||
#include <libethereum/Client.h>
|
||||
#include <libethereum/CanonBlockChain.h>
|
||||
#include <libethereum/EthereumHost.h>
|
||||
|
6
vm.cpp
6
vm.cpp
@ -21,7 +21,9 @@
|
||||
*/
|
||||
|
||||
#include <chrono>
|
||||
|
||||
#include <boost/filesystem.hpp>
|
||||
|
||||
#include <libethereum/Executive.h>
|
||||
#include <libevm/VMFactory.h>
|
||||
#include "vm.h"
|
||||
@ -286,7 +288,7 @@ eth::OnOpFunc FakeExtVM::simpleTrace()
|
||||
/*add the storage*/
|
||||
Object storage;
|
||||
for (auto const& i: std::get<2>(ext.addresses.find(ext.myAddress)->second))
|
||||
storage.push_back(Pair( (string)i.first , (string)i.second));
|
||||
storage.push_back(Pair( (string)i.first , (string)i.second));
|
||||
|
||||
/*add all the other details*/
|
||||
o_step.push_back(Pair("storage", storage));
|
||||
@ -365,7 +367,7 @@ void doVMTests(json_spirit::mValue& v, bool _fillin)
|
||||
auto argc = boost::unit_test::framework::master_test_suite().argc;
|
||||
auto argv = boost::unit_test::framework::master_test_suite().argv;
|
||||
for (auto i = 0; i < argc; ++i)
|
||||
{
|
||||
{
|
||||
if (std::string(argv[i]) == "--show-times")
|
||||
{
|
||||
auto testDuration = endTime - startTime;
|
||||
|
2
vm.h
2
vm.h
@ -25,7 +25,9 @@ along with cpp-ethereum. If not, see <http://www.gnu.org/licenses/>.
|
||||
|
||||
#include <fstream>
|
||||
#include <cstdint>
|
||||
|
||||
#include <boost/test/unit_test.hpp>
|
||||
|
||||
#include <json_spirit/json_spirit.h>
|
||||
#include <libdevcore/Log.h>
|
||||
#include <libdevcore/CommonIO.h>
|
||||
|
@ -19,7 +19,9 @@
|
||||
* @date 2014
|
||||
*/
|
||||
#include <functional>
|
||||
|
||||
#include <boost/test/unit_test.hpp>
|
||||
|
||||
#include <libp2p/Host.h>
|
||||
#include <libwhisper/WhisperPeer.h>
|
||||
#include <libwhisper/WhisperHost.h>
|
||||
@ -40,10 +42,10 @@ BOOST_AUTO_TEST_CASE(topic)
|
||||
Host host1("Test", NetworkPreferences(30303, "127.0.0.1", false, true));
|
||||
auto whost1 = host1.registerCapability(new WhisperHost());
|
||||
host1.start();
|
||||
|
||||
|
||||
while (!host1.isStarted())
|
||||
this_thread::sleep_for(chrono::milliseconds(2));
|
||||
|
||||
|
||||
bool started = false;
|
||||
unsigned result = 0;
|
||||
std::thread listener([&]()
|
||||
@ -71,19 +73,19 @@ BOOST_AUTO_TEST_CASE(topic)
|
||||
}
|
||||
this_thread::sleep_for(chrono::milliseconds(50));
|
||||
}
|
||||
|
||||
|
||||
});
|
||||
|
||||
|
||||
Host host2("Test", NetworkPreferences(30300, "127.0.0.1", false, true));
|
||||
auto whost2 = host2.registerCapability(new WhisperHost());
|
||||
host2.start();
|
||||
|
||||
|
||||
while (!host2.isStarted())
|
||||
this_thread::sleep_for(chrono::milliseconds(2));
|
||||
|
||||
|
||||
this_thread::sleep_for(chrono::milliseconds(100));
|
||||
host2.addNode(host1.id(), "127.0.0.1", 30303, 30303);
|
||||
|
||||
|
||||
this_thread::sleep_for(chrono::milliseconds(500));
|
||||
|
||||
while (!started)
|
||||
@ -107,7 +109,7 @@ BOOST_AUTO_TEST_CASE(forwarding)
|
||||
cnote << "Testing Whisper forwarding...";
|
||||
auto oldLogVerbosity = g_logVerbosity;
|
||||
g_logVerbosity = 0;
|
||||
|
||||
|
||||
// Host must be configured not to share peers.
|
||||
Host host1("Listner", NetworkPreferences(30303, "", false, true));
|
||||
host1.setIdealPeerCount(0);
|
||||
@ -115,7 +117,7 @@ BOOST_AUTO_TEST_CASE(forwarding)
|
||||
host1.start();
|
||||
while (!host1.isStarted())
|
||||
this_thread::sleep_for(chrono::milliseconds(2));
|
||||
|
||||
|
||||
unsigned result = 0;
|
||||
bool done = false;
|
||||
|
||||
@ -142,7 +144,7 @@ BOOST_AUTO_TEST_CASE(forwarding)
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
|
||||
// Host must be configured not to share peers.
|
||||
Host host2("Forwarder", NetworkPreferences(30305, "", false, true));
|
||||
host2.setIdealPeerCount(1);
|
||||
@ -150,7 +152,7 @@ BOOST_AUTO_TEST_CASE(forwarding)
|
||||
host2.start();
|
||||
while (!host2.isStarted())
|
||||
this_thread::sleep_for(chrono::milliseconds(2));
|
||||
|
||||
|
||||
Public fwderid;
|
||||
bool startedForwarder = false;
|
||||
std::thread forwarder([&]()
|
||||
@ -210,7 +212,7 @@ BOOST_AUTO_TEST_CASE(asyncforwarding)
|
||||
|
||||
unsigned result = 0;
|
||||
bool done = false;
|
||||
|
||||
|
||||
// Host must be configured not to share peers.
|
||||
Host host1("Forwarder", NetworkPreferences(30305, "", false, true));
|
||||
host1.setIdealPeerCount(1);
|
||||
@ -223,7 +225,7 @@ BOOST_AUTO_TEST_CASE(asyncforwarding)
|
||||
std::thread forwarder([&]()
|
||||
{
|
||||
setThreadName("forwarder");
|
||||
|
||||
|
||||
this_thread::sleep_for(chrono::milliseconds(500));
|
||||
// ph.addNode("127.0.0.1", 30303, 30303);
|
||||
|
||||
@ -245,7 +247,7 @@ BOOST_AUTO_TEST_CASE(asyncforwarding)
|
||||
|
||||
while (!startedForwarder)
|
||||
this_thread::sleep_for(chrono::milliseconds(2));
|
||||
|
||||
|
||||
{
|
||||
Host host2("Sender", NetworkPreferences(30300, "", false, true));
|
||||
host2.setIdealPeerCount(1);
|
||||
@ -257,7 +259,7 @@ BOOST_AUTO_TEST_CASE(asyncforwarding)
|
||||
|
||||
while (!host2.peerCount())
|
||||
this_thread::sleep_for(chrono::milliseconds(5));
|
||||
|
||||
|
||||
KeyPair us = KeyPair::create();
|
||||
whost2->post(us.sec(), RLPStream().append(1).out(), BuildTopic("test"));
|
||||
this_thread::sleep_for(chrono::milliseconds(250));
|
||||
|
Loading…
Reference in New Issue
Block a user