mirror of
https://github.com/ethereum/solidity
synced 2023-10-03 13:03:40 +00:00
Peer network code NYW.
This commit is contained in:
parent
129e4b4dfc
commit
5afc641ea9
8
main.cpp
8
main.cpp
@ -28,15 +28,17 @@ int daggerTest();
|
|||||||
int cryptoTest();
|
int cryptoTest();
|
||||||
int stateTest();
|
int stateTest();
|
||||||
int hexPrefixTest();
|
int hexPrefixTest();
|
||||||
|
int peerTest(int argc, char** argv);
|
||||||
|
|
||||||
int main()
|
int main(int argc, char** argv)
|
||||||
{
|
{
|
||||||
// hexPrefixTest();
|
// hexPrefixTest();
|
||||||
// rlpTest();
|
// rlpTest();
|
||||||
// trieTest();
|
trieTest();
|
||||||
// daggerTest();
|
// daggerTest();
|
||||||
// cryptoTest();
|
// cryptoTest();
|
||||||
stateTest();
|
// stateTest();
|
||||||
|
peerTest(argc, argv);
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
99
peer.cpp
Normal file
99
peer.cpp
Normal file
@ -0,0 +1,99 @@
|
|||||||
|
/*
|
||||||
|
This file is part of cpp-ethereum.
|
||||||
|
|
||||||
|
cpp-ethereum is free software: you can redistribute it and/or modify
|
||||||
|
it under the terms of the GNU General Public License as published by
|
||||||
|
the Free Software Foundation, either version 3 of the License, or
|
||||||
|
(at your option) any later version.
|
||||||
|
|
||||||
|
Foobar is distributed in the hope that it will be useful,
|
||||||
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||||
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||||
|
GNU General Public License for more details.
|
||||||
|
|
||||||
|
You should have received a copy of the GNU General Public License
|
||||||
|
along with Foobar. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
*/
|
||||||
|
/** @file peer.cpp
|
||||||
|
* @author Gav Wood <i@gavwood.com>
|
||||||
|
* @date 2014
|
||||||
|
* Peer Network test functions.
|
||||||
|
*/
|
||||||
|
|
||||||
|
#include <PeerNetwork.h>
|
||||||
|
using namespace std;
|
||||||
|
using namespace eth;
|
||||||
|
using boost::asio::ip::tcp;
|
||||||
|
|
||||||
|
int peerTest(int argc, char** argv)
|
||||||
|
{
|
||||||
|
int port = 30303;
|
||||||
|
PeerServer s(0, port);
|
||||||
|
s.run();
|
||||||
|
/*
|
||||||
|
if (argc == 1)
|
||||||
|
{
|
||||||
|
boost::asio::io_service io_service;
|
||||||
|
tcp::acceptor acceptor_(io_service, tcp::endpoint(tcp::v4(), port));
|
||||||
|
tcp::socket socket_(io_service);
|
||||||
|
function<void()> do_accept;
|
||||||
|
do_accept = [&]()
|
||||||
|
{
|
||||||
|
acceptor_.async_accept(socket_, [&](boost::system::error_code ec)
|
||||||
|
{
|
||||||
|
if (!ec)
|
||||||
|
{
|
||||||
|
auto s = move(socket_);
|
||||||
|
enum { max_length = 1024 };
|
||||||
|
char data_[max_length];
|
||||||
|
|
||||||
|
function<void()> do_read;
|
||||||
|
do_read = [&]()
|
||||||
|
{
|
||||||
|
s.async_read_some(boost::asio::buffer(data_, max_length), [&](boost::system::error_code ec, std::size_t length)
|
||||||
|
{
|
||||||
|
if (!ec)
|
||||||
|
boost::asio::async_write(s, boost::asio::buffer(data_, length), [&](boost::system::error_code ec, std::size_t)
|
||||||
|
{
|
||||||
|
if (!ec)
|
||||||
|
do_read();
|
||||||
|
});
|
||||||
|
});
|
||||||
|
};
|
||||||
|
}
|
||||||
|
do_accept();
|
||||||
|
});
|
||||||
|
};
|
||||||
|
io_service.run();
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
|
||||||
|
}*/
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
/* if (argc == 1)
|
||||||
|
{
|
||||||
|
PeerNetwork pn(0, 30303);
|
||||||
|
while (true)
|
||||||
|
{
|
||||||
|
usleep(100000);
|
||||||
|
pn.process();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
PeerNetwork pn(0);
|
||||||
|
if (pn.connect("127.0.0.1", 30303))
|
||||||
|
cout << "CONNECTED" << endl;
|
||||||
|
while (true)
|
||||||
|
{
|
||||||
|
usleep(100000);
|
||||||
|
pn.process();
|
||||||
|
}
|
||||||
|
}*/
|
||||||
|
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
2
trie.cpp
2
trie.cpp
@ -121,6 +121,7 @@ int trieTest()
|
|||||||
assert(d.root() == hash256(s));
|
assert(d.root() == hash256(s));
|
||||||
for (auto const& i: s)
|
for (auto const& i: s)
|
||||||
{
|
{
|
||||||
|
(void)i;
|
||||||
assert(t.at(i.first) == i.second);
|
assert(t.at(i.first) == i.second);
|
||||||
assert(d.at(i.first) == i.second);
|
assert(d.at(i.first) == i.second);
|
||||||
}
|
}
|
||||||
@ -145,6 +146,7 @@ int trieTest()
|
|||||||
assert(d.root() == hash256(s));
|
assert(d.root() == hash256(s));
|
||||||
for (auto const& i: s)
|
for (auto const& i: s)
|
||||||
{
|
{
|
||||||
|
(void)i;
|
||||||
assert(t.at(i.first) == i.second);
|
assert(t.at(i.first) == i.second);
|
||||||
assert(d.at(i.first) == i.second);
|
assert(d.at(i.first) == i.second);
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user