34 v4_addr.s_addr = fuzzed_data_provider.ConsumeIntegral<uint32_t>();
37 if (fuzzed_data_provider.remaining_bytes() >= 16) {
38 in6_addr v6_addr = {};
39 memcpy(v6_addr.s6_addr, fuzzed_data_provider.ConsumeBytes<uint8_t>(16).data(), 16);
40 net_addr =
CNetAddr{v6_addr, fuzzed_data_provider.ConsumeIntegral<uint32_t>()};
43 net_addr.
SetInternal(fuzzed_data_provider.ConsumeBytesAsString(32));
45 auto pub_key{fuzzed_data_provider.ConsumeBytes<uint8_t>(
ADDR_TORV3_SIZE)};
61 constexpr std::array ADDR_ENCODINGS{
65 constexpr std::array ADDR_FORMATS{
69 if constexpr (std::is_same_v<P, CNetAddr::SerParams>) {
70 return P{
PickValue(fuzzed_data_provider, ADDR_ENCODINGS)};
72 if constexpr (std::is_same_v<P, CAddress::SerParams>) {
73 return P{{
PickValue(fuzzed_data_provider, ADDR_ENCODINGS)},
PickValue(fuzzed_data_provider, ADDR_FORMATS)};
80 : m_fuzzed_data_provider{fuzzed_data_provider}, m_selectable{fuzzed_data_provider.ConsumeBool()}
96 assert(
false &&
"Move of Sock into FuzzedSock not allowed.");
102 constexpr std::array send_errnos{
137 constexpr std::array recv_errnos{
149 assert(buf !=
nullptr || len == 0);
157 std::vector<uint8_t> random_bytes;
162 if ((
flags & MSG_PEEK) == 0) {
165 pad_to_len_bytes =
false;
166 }
else if ((
flags & MSG_PEEK) != 0) {
169 if (!random_bytes.empty()) {
171 pad_to_len_bytes =
false;
177 if (random_bytes.empty()) {
184 std::memcpy(buf, random_bytes.data(), random_bytes.size());
185 if (pad_to_len_bytes) {
186 if (len > random_bytes.size()) {
187 std::memset((
char*)buf + random_bytes.size(), 0, len - random_bytes.size());
192 std::this_thread::sleep_for(std::chrono::milliseconds{2});
194 return random_bytes.size();
202 constexpr std::array connect_errnos{
226 constexpr std::array bind_errnos{
246 constexpr std::array listen_errnos{
260 constexpr std::array accept_errnos{
267 return std::unique_ptr<FuzzedSock>();
274 constexpr std::array getsockopt_errnos{
282 if (opt_val ==
nullptr) {
293 constexpr std::array setsockopt_errnos{
306 constexpr std::array getsockname_errnos{
320 constexpr std::array setnonblocking_errnos{
338 constexpr std::array wait_errnos{
347 if (occurred !=
nullptr) {
355 for (
auto& [sock, events] : events_per_sock) {
367 errmsg =
"disconnected at random by the fuzzer";
373 connman.Handshake(
node,
374 fuzzed_data_provider.ConsumeBool(),
377 fuzzed_data_provider.ConsumeIntegralInRange<int32_t>(
MIN_PEER_PROTO_VERSION, std::numeric_limits<int32_t>::max()),
378 fuzzed_data_provider.ConsumeBool());
A CService with information about it as peer.
bool SetSpecial(const std::string &addr)
Parse a Tor or I2P address and set this object to it.
bool SetInternal(const std::string &name)
Create an "internal" address that represents a name or FQDN.
Information about a peer.
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.
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().
std::string OnionToString(Span< const uint8_t > addr)
static constexpr size_t ADDR_TORV3_SIZE
Size of TORv3 address (in bytes).
@ NET_ONION
TOR (v2 or v3)
@ NET_INTERNAL
A set of addresses that represent the hash of a string or FQDN.
P ConsumeDeserializationParams(FuzzedDataProvider &fuzzed_data_provider) noexcept
CNetAddr ConsumeNetAddr(FuzzedDataProvider &fuzzed_data_provider) noexcept
CAddress ConsumeAddress(FuzzedDataProvider &fuzzed_data_provider) noexcept
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
static const int MIN_PEER_PROTO_VERSION
disconnect from peers older than this proto version