/* 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. cpp-ethereum 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 cpp-ethereum. If not, see . */ /** @file WebThree.cpp * @author Gav Wood * @date 2014 */ #include "WebThree.h" #include #include #include #include #include #include #include #include using namespace std; using namespace dev; using namespace dev::p2p; using namespace dev::eth; using namespace dev::shh; WebThreeDirect::WebThreeDirect(std::string const& _clientVersion, std::string const& _dbPath, bool _forceClean, std::set const& _interfaces, NetworkPreferences const& _n, bytesConstRef _network, int miners): m_clientVersion(_clientVersion), m_net(_clientVersion, _n, _network) { if (_dbPath.size()) Defaults::setDBPath(_dbPath); if (_interfaces.count("eth")) m_ethereum.reset(new eth::Client(&m_net, _dbPath, _forceClean, 0, miners)); if (_interfaces.count("shh")) m_whisper = m_net.registerCapability(new WhisperHost); } WebThreeDirect::~WebThreeDirect() { // Utterly horrible right now - WebThree owns everything (good), but: // m_net (Host) owns the eth::EthereumHost via a shared_ptr. // The eth::EthereumHost depends on eth::Client (it maintains a reference to the BlockChain field of Client). // eth::Client (owned by us via a unique_ptr) uses eth::EthereumHost (via a weak_ptr). // Really need to work out a clean way of organising ownership and guaranteeing startup/shutdown is perfect. // Have to call stop here to get the Host to kill its io_service otherwise we end up with left-over reads, // still referencing Sessions getting deleted *after* m_ethereum is reset, causing bad things to happen, since // the guarantee is that m_ethereum is only reset *after* all sessions have ended (sessions are allowed to // use bits of data owned by m_ethereum). m_net.stop(); m_ethereum.reset(); } void WebThreeDirect::setNetworkPreferences(p2p::NetworkPreferences const& _n) { auto had = haveNetwork(); if (had) stopNetwork(); m_net.setNetworkPreferences(_n); if (had) startNetwork(); } std::vector WebThreeDirect::peers() { return m_net.peerSessionInfo(); } size_t WebThreeDirect::peerCount() const { return m_net.peerCount(); } void WebThreeDirect::setIdealPeerCount(size_t _n) { return m_net.setIdealPeerCount(_n); } bytes WebThreeDirect::saveNetwork() { return m_net.saveNetwork(); } void WebThreeDirect::connect(std::string const& _seedHost, unsigned short _port) { m_net.addNode(NodeId(), _seedHost, _port, _port); }