36 static constexpr std::array<NetAux, 6> nets{
45 const size_t nets_index{rand ==
nullptr
46 ? fuzzed_data_provider.ConsumeIntegralInRange<
size_t>(0, nets.size() - 1)
47 :
static_cast<size_t>(rand->randrange(nets.size()))};
49 const auto& aux = nets[nets_index];
54 if (rand ==
nullptr) {
55 addr.
SetInternal(fuzzed_data_provider.ConsumeBytesAsString(32));
57 const auto v = rand->randbytes(32);
65 s << static_cast<uint8_t>(aux.bip155);
67 std::vector<uint8_t> addr_bytes;
68 if (rand ==
nullptr) {
69 addr_bytes = fuzzed_data_provider.ConsumeBytes<uint8_t>(aux.len);
70 addr_bytes.resize(aux.len);
72 addr_bytes = rand->randbytes(aux.len);
95 constexpr std::array ADDR_ENCODINGS{
99 constexpr std::array ADDR_FORMATS{
103 if constexpr (std::is_same_v<P, CNetAddr::SerParams>) {
104 return P{
PickValue(fuzzed_data_provider, ADDR_ENCODINGS)};
106 if constexpr (std::is_same_v<P, CAddress::SerParams>) {
107 return P{{
PickValue(fuzzed_data_provider, ADDR_ENCODINGS)},
PickValue(fuzzed_data_provider, ADDR_FORMATS)};
115 m_fuzzed_data_provider{fuzzed_data_provider},
116 m_selectable{fuzzed_data_provider.ConsumeBool()}
131 assert(
false &&
"Move of Sock into FuzzedSock not allowed.");
137 constexpr std::array send_errnos{
172 constexpr std::array recv_errnos{
184 assert(buf !=
nullptr || len == 0);
192 std::vector<uint8_t> random_bytes;
197 if ((
flags & MSG_PEEK) == 0) {
200 pad_to_len_bytes =
false;
201 }
else if ((
flags & MSG_PEEK) != 0) {
204 if (!random_bytes.empty()) {
206 pad_to_len_bytes =
false;
212 if (random_bytes.empty()) {
219 std::memcpy(buf, random_bytes.data(), random_bytes.size());
220 if (pad_to_len_bytes) {
221 if (len > random_bytes.size()) {
222 std::memset((
char*)buf + random_bytes.size(), 0, len - random_bytes.size());
227 std::this_thread::sleep_for(std::chrono::milliseconds{2});
229 return random_bytes.size();
237 constexpr std::array connect_errnos{
261 constexpr std::array bind_errnos{
281 constexpr std::array listen_errnos{
295 constexpr std::array accept_errnos{
302 return std::unique_ptr<FuzzedSock>();
309 constexpr std::array getsockopt_errnos{
317 if (opt_val ==
nullptr) {
328 constexpr std::array setsockopt_errnos{
341 constexpr std::array getsockname_errnos{
355 constexpr std::array setnonblocking_errnos{
373 constexpr std::array wait_errnos{
382 if (occurred !=
nullptr) {
390 for (
auto& [sock, events] : events_per_sock) {
402 errmsg =
"disconnected at random by the fuzzer";
408 connman.Handshake(
node,
409 fuzzed_data_provider.ConsumeBool(),
412 fuzzed_data_provider.ConsumeIntegralInRange<int32_t>(
MIN_PEER_PROTO_VERSION, std::numeric_limits<int32_t>::max()),
413 fuzzed_data_provider.ConsumeBool());
A CService with information about it as peer.
static constexpr SerParams V2_NETWORK
bool SetInternal(const std::string &name)
Create an "internal" address that represents a name or FQDN.
BIP155Network
BIP155 network ids recognized by this software.
Information about a peer.
Double ended buffer combining vector and stream-like interfaces.
std::vector< T > ConsumeBytes(size_t num_bytes)
T ConsumeIntegralInRange(T min, T max)
size_t ConsumeData(void *destination, size_t num_bytes)
std::unique_ptr< Sock > Accept(sockaddr *addr, socklen_t *addr_len) const override
accept(2) wrapper.
int GetSockOpt(int level, int opt_name, void *opt_val, socklen_t *opt_len) const override
getsockopt(2) wrapper.
bool Wait(std::chrono::milliseconds timeout, Event requested, Event *occurred=nullptr) const override
Wait for readiness for input (recv) or output (send).
int Listen(int backlog) const override
listen(2) wrapper.
const bool m_selectable
Whether to pretend that the socket is select(2)-able.
bool WaitMany(std::chrono::milliseconds timeout, EventsPerSock &events_per_sock) const override
Same as Wait(), but wait on many sockets within the same timeout.
bool IsConnected(std::string &errmsg) const override
Check if still connected.
int Connect(const sockaddr *, socklen_t) const override
connect(2) wrapper.
ssize_t Send(const void *data, size_t len, int flags) const override
send(2) wrapper.
FuzzedSock & operator=(Sock &&other) override
Move assignment operator, grab the socket from another object and close ours (if set).
std::optional< uint8_t > m_peek_data
Data to return when MSG_PEEK is used as a Recv() flag.
FuzzedDataProvider & m_fuzzed_data_provider
bool IsSelectable() const override
Check if the underlying socket can be used for select(2) (or the Wait() method).
bool SetNonBlocking() const override
Set the non-blocking option on the socket.
int SetSockOpt(int level, int opt_name, const void *opt_val, socklen_t opt_len) const override
setsockopt(2) wrapper.
ssize_t Recv(void *buf, size_t len, int flags) const override
recv(2) wrapper.
int GetSockName(sockaddr *name, socklen_t *name_len) const override
getsockname(2) wrapper.
FuzzedSock(FuzzedDataProvider &fuzzed_data_provider)
int Bind(const sockaddr *, socklen_t) const override
bind(2) wrapper.
RAII helper class that manages a socket and closes it automatically when it goes out of scope.
SOCKET m_socket
Contained socket.
std::unordered_map< std::shared_ptr< const Sock >, Events, HashSharedPtrSock, EqualSharedPtrSock > EventsPerSock
On which socket to wait for what events in WaitMany().
static constexpr uint8_t CJDNS_PREFIX
All CJDNS addresses start with 0xFC.
static constexpr size_t ADDR_CJDNS_SIZE
Size of CJDNS address (in bytes).
static constexpr size_t ADDR_TORV3_SIZE
Size of TORv3 address (in bytes).
static constexpr size_t ADDR_I2P_SIZE
Size of I2P address (in bytes).
static constexpr size_t ADDR_IPV4_SIZE
Size of IPv4 address (in bytes).
@ NET_ONION
TOR (v2 or v3)
@ NET_INTERNAL
A set of addresses that represent the hash of a string or FQDN.
static constexpr size_t ADDR_IPV6_SIZE
Size of IPv6 address (in bytes).
static const int MIN_PEER_PROTO_VERSION
disconnect from peers older than this proto version
P ConsumeDeserializationParams(FuzzedDataProvider &fuzzed_data_provider) noexcept
CAddress ConsumeAddress(FuzzedDataProvider &fuzzed_data_provider) noexcept
CNetAddr ConsumeNetAddr(FuzzedDataProvider &fuzzed_data_provider, FastRandomContext *rand) noexcept
Create a CNetAddr.
void FillNode(FuzzedDataProvider &fuzzed_data_provider, ConnmanTestMsg &connman, CNode &node) noexcept
CService ConsumeService(FuzzedDataProvider &fuzzed_data_provider) noexcept
WeakEnumType ConsumeWeakEnum(FuzzedDataProvider &fuzzed_data_provider, const WeakEnumType(&all_types)[size]) noexcept
auto & PickValue(FuzzedDataProvider &fuzzed_data_provider, Collection &col)
void SetFuzzedErrNo(FuzzedDataProvider &fuzzed_data_provider, const std::array< T, size > &errnos)
Sets errno to a value selected from the given std::array errnos.
std::vector< B > ConsumeFixedLengthByteVector(FuzzedDataProvider &fuzzed_data_provider, const size_t length) noexcept
Returns a byte vector of specified size regardless of the number of remaining bytes available from th...
constexpr ServiceFlags ALL_SERVICE_FLAGS[]
std::chrono::time_point< NodeClock, std::chrono::seconds > NodeSeconds