mirror of https://github.com/bitcoin/bitcoin.git
365 lines
10 KiB
C++
365 lines
10 KiB
C++
// Copyright (c) 2020-present The Bitcoin Core developers
|
|
// Distributed under the MIT software license, see the accompanying
|
|
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
|
|
|
#ifndef BITCOIN_TEST_UTIL_NET_H
|
|
#define BITCOIN_TEST_UTIL_NET_H
|
|
|
|
#include <compat/compat.h>
|
|
#include <netmessagemaker.h>
|
|
#include <net.h>
|
|
#include <net_permissions.h>
|
|
#include <net_processing.h>
|
|
#include <netaddress.h>
|
|
#include <node/connection_types.h>
|
|
#include <node/eviction.h>
|
|
#include <span.h>
|
|
#include <sync.h>
|
|
#include <util/sock.h>
|
|
|
|
#include <algorithm>
|
|
#include <array>
|
|
#include <cassert>
|
|
#include <chrono>
|
|
#include <condition_variable>
|
|
#include <cstdint>
|
|
#include <cstring>
|
|
#include <memory>
|
|
#include <optional>
|
|
#include <string>
|
|
#include <unordered_map>
|
|
#include <vector>
|
|
|
|
class FastRandomContext;
|
|
|
|
struct ConnmanTestMsg : public CConnman {
|
|
using CConnman::CConnman;
|
|
|
|
void SetMsgProc(NetEventsInterface* msgproc)
|
|
{
|
|
m_msgproc = msgproc;
|
|
}
|
|
|
|
void SetPeerConnectTimeout(std::chrono::seconds timeout)
|
|
{
|
|
m_peer_connect_timeout = timeout;
|
|
}
|
|
|
|
void ResetAddrCache();
|
|
void ResetMaxOutboundCycle();
|
|
|
|
std::vector<CNode*> TestNodes()
|
|
{
|
|
LOCK(m_nodes_mutex);
|
|
return m_nodes;
|
|
}
|
|
|
|
void AddTestNode(CNode& node)
|
|
{
|
|
LOCK(m_nodes_mutex);
|
|
m_nodes.push_back(&node);
|
|
|
|
if (node.IsManualOrFullOutboundConn()) ++m_network_conn_counts[node.addr.GetNetwork()];
|
|
}
|
|
|
|
void ClearTestNodes()
|
|
{
|
|
LOCK(m_nodes_mutex);
|
|
for (CNode* node : m_nodes) {
|
|
delete node;
|
|
}
|
|
m_nodes.clear();
|
|
}
|
|
|
|
void Handshake(CNode& node,
|
|
bool successfully_connected,
|
|
ServiceFlags remote_services,
|
|
ServiceFlags local_services,
|
|
int32_t version,
|
|
bool relay_txs)
|
|
EXCLUSIVE_LOCKS_REQUIRED(NetEventsInterface::g_msgproc_mutex);
|
|
|
|
bool ProcessMessagesOnce(CNode& node) EXCLUSIVE_LOCKS_REQUIRED(NetEventsInterface::g_msgproc_mutex)
|
|
{
|
|
return m_msgproc->ProcessMessages(&node, flagInterruptMsgProc);
|
|
}
|
|
|
|
void NodeReceiveMsgBytes(CNode& node, std::span<const uint8_t> msg_bytes, bool& complete) const;
|
|
|
|
bool ReceiveMsgFrom(CNode& node, CSerializedNetMsg&& ser_msg) const;
|
|
void FlushSendBuffer(CNode& node) const;
|
|
|
|
bool AlreadyConnectedToAddressPublic(const CNetAddr& addr) { return AlreadyConnectedToAddress(addr); };
|
|
|
|
CNode* ConnectNodePublic(PeerManager& peerman, const char* pszDest, ConnectionType conn_type)
|
|
EXCLUSIVE_LOCKS_REQUIRED(!m_unused_i2p_sessions_mutex);
|
|
};
|
|
|
|
constexpr ServiceFlags ALL_SERVICE_FLAGS[]{
|
|
NODE_NONE,
|
|
NODE_NETWORK,
|
|
NODE_BLOOM,
|
|
NODE_WITNESS,
|
|
NODE_COMPACT_FILTERS,
|
|
NODE_NETWORK_LIMITED,
|
|
NODE_P2P_V2,
|
|
};
|
|
|
|
constexpr NetPermissionFlags ALL_NET_PERMISSION_FLAGS[]{
|
|
NetPermissionFlags::None,
|
|
NetPermissionFlags::BloomFilter,
|
|
NetPermissionFlags::Relay,
|
|
NetPermissionFlags::ForceRelay,
|
|
NetPermissionFlags::NoBan,
|
|
NetPermissionFlags::Mempool,
|
|
NetPermissionFlags::Addr,
|
|
NetPermissionFlags::Download,
|
|
NetPermissionFlags::Implicit,
|
|
NetPermissionFlags::All,
|
|
};
|
|
|
|
constexpr ConnectionType ALL_CONNECTION_TYPES[]{
|
|
ConnectionType::INBOUND,
|
|
ConnectionType::OUTBOUND_FULL_RELAY,
|
|
ConnectionType::MANUAL,
|
|
ConnectionType::FEELER,
|
|
ConnectionType::BLOCK_RELAY,
|
|
ConnectionType::ADDR_FETCH,
|
|
};
|
|
|
|
constexpr auto ALL_NETWORKS = std::array{
|
|
Network::NET_UNROUTABLE,
|
|
Network::NET_IPV4,
|
|
Network::NET_IPV6,
|
|
Network::NET_ONION,
|
|
Network::NET_I2P,
|
|
Network::NET_CJDNS,
|
|
Network::NET_INTERNAL,
|
|
};
|
|
|
|
/**
|
|
* A mocked Sock alternative that succeeds on all operations.
|
|
* Returns infinite amount of 0x0 bytes on reads.
|
|
*/
|
|
class ZeroSock : public Sock
|
|
{
|
|
public:
|
|
ZeroSock();
|
|
|
|
~ZeroSock() override;
|
|
|
|
ssize_t Send(const void*, size_t len, int) const override;
|
|
|
|
ssize_t Recv(void* buf, size_t len, int flags) const override;
|
|
|
|
int Connect(const sockaddr*, socklen_t) const override;
|
|
|
|
int Bind(const sockaddr*, socklen_t) const override;
|
|
|
|
int Listen(int) const override;
|
|
|
|
std::unique_ptr<Sock> Accept(sockaddr* addr, socklen_t* addr_len) const override;
|
|
|
|
int GetSockOpt(int level, int opt_name, void* opt_val, socklen_t* opt_len) const override;
|
|
|
|
int SetSockOpt(int, int, const void*, socklen_t) const override;
|
|
|
|
int GetSockName(sockaddr* name, socklen_t* name_len) const override;
|
|
|
|
bool SetNonBlocking() const override;
|
|
|
|
bool IsSelectable() const override;
|
|
|
|
bool Wait(std::chrono::milliseconds timeout,
|
|
Event requested,
|
|
Event* occurred = nullptr) const override;
|
|
|
|
bool WaitMany(std::chrono::milliseconds timeout, EventsPerSock& events_per_sock) const override;
|
|
|
|
private:
|
|
ZeroSock& operator=(Sock&& other) override;
|
|
};
|
|
|
|
/**
|
|
* A mocked Sock alternative that returns a statically contained data upon read and succeeds
|
|
* and ignores all writes. The data to be returned is given to the constructor and when it is
|
|
* exhausted an EOF is returned by further reads.
|
|
*/
|
|
class StaticContentsSock : public ZeroSock
|
|
{
|
|
public:
|
|
explicit StaticContentsSock(const std::string& contents);
|
|
|
|
/**
|
|
* Return parts of the contents that was provided at construction until it is exhausted
|
|
* and then return 0 (EOF).
|
|
*/
|
|
ssize_t Recv(void* buf, size_t len, int flags) const override;
|
|
|
|
bool IsConnected(std::string&) const override
|
|
{
|
|
return true;
|
|
}
|
|
|
|
private:
|
|
StaticContentsSock& operator=(Sock&& other) override;
|
|
|
|
const std::string m_contents;
|
|
mutable size_t m_consumed{0};
|
|
};
|
|
|
|
/**
|
|
* A mocked Sock alternative that allows providing the data to be returned by Recv()
|
|
* and inspecting the data that has been supplied to Send().
|
|
*/
|
|
class DynSock : public ZeroSock
|
|
{
|
|
public:
|
|
/**
|
|
* Unidirectional bytes or CNetMessage queue (FIFO).
|
|
*/
|
|
class Pipe
|
|
{
|
|
public:
|
|
/**
|
|
* Get bytes and remove them from the pipe.
|
|
* @param[in] buf Destination to write bytes to.
|
|
* @param[in] len Write up to this number of bytes.
|
|
* @param[in] flags Same as the flags of `recv(2)`. Just `MSG_PEEK` is honored.
|
|
* @return The number of bytes written to `buf`. `0` if `Eof()` has been called.
|
|
* If no bytes are available then `-1` is returned and `errno` is set to `EAGAIN`.
|
|
*/
|
|
ssize_t GetBytes(void* buf, size_t len, int flags = 0) EXCLUSIVE_LOCKS_REQUIRED(!m_mutex);
|
|
|
|
/**
|
|
* Deserialize a `CNetMessage` and remove it from the pipe.
|
|
* If not enough bytes are available then the function will wait. If parsing fails
|
|
* or EOF is signaled to the pipe, then `std::nullopt` is returned.
|
|
*/
|
|
std::optional<CNetMessage> GetNetMsg() EXCLUSIVE_LOCKS_REQUIRED(!m_mutex);
|
|
|
|
/**
|
|
* Push bytes to the pipe.
|
|
*/
|
|
void PushBytes(const void* buf, size_t len) EXCLUSIVE_LOCKS_REQUIRED(!m_mutex);
|
|
|
|
/**
|
|
* Construct and push CNetMessage to the pipe.
|
|
*/
|
|
template <typename... Args>
|
|
void PushNetMsg(const std::string& type, Args&&... payload) EXCLUSIVE_LOCKS_REQUIRED(!m_mutex);
|
|
|
|
/**
|
|
* Signal end-of-file on the receiving end (`GetBytes()` or `GetNetMsg()`).
|
|
*/
|
|
void Eof() EXCLUSIVE_LOCKS_REQUIRED(!m_mutex);
|
|
|
|
private:
|
|
/**
|
|
* Return when there is some data to read or EOF has been signaled.
|
|
* @param[in,out] lock Unique lock that must have been derived from `m_mutex` by `WAIT_LOCK(m_mutex, lock)`.
|
|
*/
|
|
void WaitForDataOrEof(UniqueLock<Mutex>& lock) EXCLUSIVE_LOCKS_REQUIRED(m_mutex);
|
|
|
|
Mutex m_mutex;
|
|
std::condition_variable m_cond;
|
|
std::vector<uint8_t> m_data GUARDED_BY(m_mutex);
|
|
bool m_eof GUARDED_BY(m_mutex){false};
|
|
};
|
|
|
|
struct Pipes {
|
|
Pipe recv;
|
|
Pipe send;
|
|
};
|
|
|
|
/**
|
|
* A basic thread-safe queue, used for queuing sockets to be returned by Accept().
|
|
*/
|
|
class Queue
|
|
{
|
|
public:
|
|
using S = std::unique_ptr<DynSock>;
|
|
|
|
void Push(S s) EXCLUSIVE_LOCKS_REQUIRED(!m_mutex)
|
|
{
|
|
LOCK(m_mutex);
|
|
m_queue.push(std::move(s));
|
|
}
|
|
|
|
std::optional<S> Pop() EXCLUSIVE_LOCKS_REQUIRED(!m_mutex)
|
|
{
|
|
LOCK(m_mutex);
|
|
if (m_queue.empty()) {
|
|
return std::nullopt;
|
|
}
|
|
S front{std::move(m_queue.front())};
|
|
m_queue.pop();
|
|
return front;
|
|
}
|
|
|
|
bool Empty() const EXCLUSIVE_LOCKS_REQUIRED(!m_mutex)
|
|
{
|
|
LOCK(m_mutex);
|
|
return m_queue.empty();
|
|
}
|
|
|
|
private:
|
|
mutable Mutex m_mutex;
|
|
std::queue<S> m_queue GUARDED_BY(m_mutex);
|
|
};
|
|
|
|
/**
|
|
* Create a new mocked sock.
|
|
* @param[in] pipes Send/recv pipes used by the Send() and Recv() methods.
|
|
* @param[in] accept_sockets Sockets to return by the Accept() method.
|
|
*/
|
|
explicit DynSock(std::shared_ptr<Pipes> pipes, std::shared_ptr<Queue> accept_sockets);
|
|
|
|
~DynSock();
|
|
|
|
ssize_t Recv(void* buf, size_t len, int flags) const override;
|
|
|
|
ssize_t Send(const void* buf, size_t len, int) const override;
|
|
|
|
std::unique_ptr<Sock> Accept(sockaddr* addr, socklen_t* addr_len) const override;
|
|
|
|
bool Wait(std::chrono::milliseconds timeout,
|
|
Event requested,
|
|
Event* occurred = nullptr) const override;
|
|
|
|
bool WaitMany(std::chrono::milliseconds timeout, EventsPerSock& events_per_sock) const override;
|
|
|
|
private:
|
|
DynSock& operator=(Sock&&) override;
|
|
|
|
std::shared_ptr<Pipes> m_pipes;
|
|
std::shared_ptr<Queue> m_accept_sockets;
|
|
};
|
|
|
|
template <typename... Args>
|
|
void DynSock::Pipe::PushNetMsg(const std::string& type, Args&&... payload)
|
|
{
|
|
auto msg = NetMsg::Make(type, std::forward<Args>(payload)...);
|
|
V1Transport transport{NodeId{0}};
|
|
|
|
const bool queued{transport.SetMessageToSend(msg)};
|
|
assert(queued);
|
|
|
|
LOCK(m_mutex);
|
|
|
|
for (;;) {
|
|
const auto& [bytes, _more, _msg_type] = transport.GetBytesToSend(/*have_next_message=*/true);
|
|
if (bytes.empty()) {
|
|
break;
|
|
}
|
|
m_data.insert(m_data.end(), bytes.begin(), bytes.end());
|
|
transport.MarkBytesSent(bytes.size());
|
|
}
|
|
|
|
m_cond.notify_all();
|
|
}
|
|
|
|
std::vector<NodeEvictionCandidate> GetRandomNodeEvictionCandidates(int n_candidates, FastRandomContext& random_context);
|
|
|
|
#endif // BITCOIN_TEST_UTIL_NET_H
|