Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions builds/gnu/Makefile.am
Original file line number Diff line number Diff line change
Expand Up @@ -77,6 +77,7 @@ src_libbitcoin_node_la_SOURCES = \
${srcdir}/../../src/protocols/protocol_block_in_106.cpp \
${srcdir}/../../src/protocols/protocol_block_in_31800.cpp \
${srcdir}/../../src/protocols/protocol_block_out_106.cpp \
${srcdir}/../../src/protocols/protocol_block_out_70001.cpp \
${srcdir}/../../src/protocols/protocol_block_out_70012.cpp \
${srcdir}/../../src/protocols/protocol_filter_out_70015.cpp \
${srcdir}/../../src/protocols/protocol_header_in_31800.cpp \
Expand All @@ -88,6 +89,7 @@ src_libbitcoin_node_la_SOURCES = \
${srcdir}/../../src/protocols/protocol_performer.cpp \
${srcdir}/../../src/protocols/protocol_transaction_in_106.cpp \
${srcdir}/../../src/protocols/protocol_transaction_out_106.cpp \
${srcdir}/../../src/protocols/protocol_transaction_out_70001.cpp \
${srcdir}/../../src/sessions/session.cpp \
${srcdir}/../../src/sessions/session_inbound.cpp \
${srcdir}/../../src/sessions/session_manual.cpp \
Expand Down Expand Up @@ -162,6 +164,7 @@ include_bitcoin_node_protocols_HEADERS = \
${srcdir}/../../include/bitcoin/node/protocols/protocol_block_in_106.hpp \
${srcdir}/../../include/bitcoin/node/protocols/protocol_block_in_31800.hpp \
${srcdir}/../../include/bitcoin/node/protocols/protocol_block_out_106.hpp \
${srcdir}/../../include/bitcoin/node/protocols/protocol_block_out_70001.hpp \
${srcdir}/../../include/bitcoin/node/protocols/protocol_block_out_70012.hpp \
${srcdir}/../../include/bitcoin/node/protocols/protocol_filter_out_70015.hpp \
${srcdir}/../../include/bitcoin/node/protocols/protocol_header_in_31800.hpp \
Expand All @@ -173,6 +176,7 @@ include_bitcoin_node_protocols_HEADERS = \
${srcdir}/../../include/bitcoin/node/protocols/protocol_performer.hpp \
${srcdir}/../../include/bitcoin/node/protocols/protocol_transaction_in_106.hpp \
${srcdir}/../../include/bitcoin/node/protocols/protocol_transaction_out_106.hpp \
${srcdir}/../../include/bitcoin/node/protocols/protocol_transaction_out_70001.hpp \
${srcdir}/../../include/bitcoin/node/protocols/protocols.hpp

include_bitcoin_node_sessionsdir = \
Expand Down
4 changes: 4 additions & 0 deletions builds/msvc/vs2022/libbitcoin-node/libbitcoin-node.vcxproj
Original file line number Diff line number Diff line change
Expand Up @@ -146,6 +146,7 @@
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_in_106.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_in_31800.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_out_106.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_out_70001.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_out_70012.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_filter_out_70015.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_header_in_31800.cpp" />
Expand All @@ -157,6 +158,7 @@
<ClCompile Include="..\..\..\..\src\protocols\protocol_performer.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_transaction_in_106.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_transaction_out_106.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_transaction_out_70001.cpp" />
<ClCompile Include="..\..\..\..\src\sessions\session.cpp" />
<ClCompile Include="..\..\..\..\src\sessions\session_inbound.cpp" />
<ClCompile Include="..\..\..\..\src\sessions\session_manual.cpp" />
Expand Down Expand Up @@ -196,6 +198,7 @@
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_in_106.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_in_31800.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_out_106.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_out_70001.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_out_70012.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_filter_out_70015.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_header_in_31800.hpp" />
Expand All @@ -207,6 +210,7 @@
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_performer.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_transaction_in_106.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_transaction_out_106.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_transaction_out_70001.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocols.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\sessions\session.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\sessions\session_inbound.hpp" />
Expand Down
12 changes: 12 additions & 0 deletions builds/msvc/vs2022/libbitcoin-node/libbitcoin-node.vcxproj.filters
Original file line number Diff line number Diff line change
Expand Up @@ -132,6 +132,9 @@
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_out_106.cpp">
<Filter>src\protocols</Filter>
</ClCompile>
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_out_70001.cpp">
<Filter>src\protocols</Filter>
</ClCompile>
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_out_70012.cpp">
<Filter>src\protocols</Filter>
</ClCompile>
Expand Down Expand Up @@ -165,6 +168,9 @@
<ClCompile Include="..\..\..\..\src\protocols\protocol_transaction_out_106.cpp">
<Filter>src\protocols</Filter>
</ClCompile>
<ClCompile Include="..\..\..\..\src\protocols\protocol_transaction_out_70001.cpp">
<Filter>src\protocols</Filter>
</ClCompile>
<ClCompile Include="..\..\..\..\src\sessions\session.cpp">
<Filter>src\sessions</Filter>
</ClCompile>
Expand Down Expand Up @@ -278,6 +284,9 @@
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_out_106.hpp">
<Filter>include\bitcoin\node\protocols</Filter>
</ClInclude>
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_out_70001.hpp">
<Filter>include\bitcoin\node\protocols</Filter>
</ClInclude>
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_out_70012.hpp">
<Filter>include\bitcoin\node\protocols</Filter>
</ClInclude>
Expand Down Expand Up @@ -311,6 +320,9 @@
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_transaction_out_106.hpp">
<Filter>include\bitcoin\node\protocols</Filter>
</ClInclude>
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_transaction_out_70001.hpp">
<Filter>include\bitcoin\node\protocols</Filter>
</ClInclude>
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocols.hpp">
<Filter>include\bitcoin\node\protocols</Filter>
</ClInclude>
Expand Down
4 changes: 4 additions & 0 deletions builds/msvc/vs2026/libbitcoin-node/libbitcoin-node.vcxproj
Original file line number Diff line number Diff line change
Expand Up @@ -146,6 +146,7 @@
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_in_106.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_in_31800.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_out_106.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_out_70001.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_out_70012.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_filter_out_70015.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_header_in_31800.cpp" />
Expand All @@ -157,6 +158,7 @@
<ClCompile Include="..\..\..\..\src\protocols\protocol_performer.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_transaction_in_106.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_transaction_out_106.cpp" />
<ClCompile Include="..\..\..\..\src\protocols\protocol_transaction_out_70001.cpp" />
<ClCompile Include="..\..\..\..\src\sessions\session.cpp" />
<ClCompile Include="..\..\..\..\src\sessions\session_inbound.cpp" />
<ClCompile Include="..\..\..\..\src\sessions\session_manual.cpp" />
Expand Down Expand Up @@ -196,6 +198,7 @@
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_in_106.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_in_31800.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_out_106.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_out_70001.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_out_70012.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_filter_out_70015.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_header_in_31800.hpp" />
Expand All @@ -207,6 +210,7 @@
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_performer.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_transaction_in_106.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_transaction_out_106.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_transaction_out_70001.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocols.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\sessions\session.hpp" />
<ClInclude Include="..\..\..\..\include\bitcoin\node\sessions\session_inbound.hpp" />
Expand Down
12 changes: 12 additions & 0 deletions builds/msvc/vs2026/libbitcoin-node/libbitcoin-node.vcxproj.filters
Original file line number Diff line number Diff line change
Expand Up @@ -132,6 +132,9 @@
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_out_106.cpp">
<Filter>src\protocols</Filter>
</ClCompile>
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_out_70001.cpp">
<Filter>src\protocols</Filter>
</ClCompile>
<ClCompile Include="..\..\..\..\src\protocols\protocol_block_out_70012.cpp">
<Filter>src\protocols</Filter>
</ClCompile>
Expand Down Expand Up @@ -165,6 +168,9 @@
<ClCompile Include="..\..\..\..\src\protocols\protocol_transaction_out_106.cpp">
<Filter>src\protocols</Filter>
</ClCompile>
<ClCompile Include="..\..\..\..\src\protocols\protocol_transaction_out_70001.cpp">
<Filter>src\protocols</Filter>
</ClCompile>
<ClCompile Include="..\..\..\..\src\sessions\session.cpp">
<Filter>src\sessions</Filter>
</ClCompile>
Expand Down Expand Up @@ -278,6 +284,9 @@
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_out_106.hpp">
<Filter>include\bitcoin\node\protocols</Filter>
</ClInclude>
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_out_70001.hpp">
<Filter>include\bitcoin\node\protocols</Filter>
</ClInclude>
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_block_out_70012.hpp">
<Filter>include\bitcoin\node\protocols</Filter>
</ClInclude>
Expand Down Expand Up @@ -311,6 +320,9 @@
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_transaction_out_106.hpp">
<Filter>include\bitcoin\node\protocols</Filter>
</ClInclude>
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocol_transaction_out_70001.hpp">
<Filter>include\bitcoin\node\protocols</Filter>
</ClInclude>
<ClInclude Include="..\..\..\..\include\bitcoin\node\protocols\protocols.hpp">
<Filter>include\bitcoin\node\protocols</Filter>
</ClInclude>
Expand Down
17 changes: 10 additions & 7 deletions include/bitcoin/node/impl/sessions/session_peer.ipp
Original file line number Diff line number Diff line change
Expand Up @@ -140,22 +140,25 @@ inline void CLASS::attach_protocols(const channel_ptr& channel) NOEXCEPT
channel->attach<protocol_header_out_70012>(self)->start();
channel->attach<protocol_block_out_70012>(self)->start();
}
else if (headers && peer->is_negotiated(level::headers_protocol))
{
channel->attach<protocol_header_out_31800>(self)->start();
channel->attach<protocol_block_out_106>(self)->start();
}
else
{
channel->attach<protocol_block_out_106>(self)->start();
if (headers && peer->is_negotiated(level::headers_protocol))
channel->attach<protocol_header_out_31800>(self)->start();

// not_found is defined at bip37.
if (peer->is_negotiated(level::bip37))
channel->attach<protocol_block_out_70001>(self)->start();
else
channel->attach<protocol_block_out_106>(self)->start();
}
}

// Relay is configured, active, and txs are ready (txs in/out).
if (txs_in_out)
{
// Attached above bip37, where not_found is defined.
if (peer->peer_version()->relay)
channel->attach<protocol_transaction_out_106>(self)->start();
channel->attach<protocol_transaction_out_70001>(self)->start();
}
}

Expand Down
5 changes: 4 additions & 1 deletion include/bitcoin/node/protocols/protocol_block_out_106.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -54,6 +54,7 @@ class BCN_API protocol_block_out_106
protected:
using get_data = network::messages::peer::get_data;
using get_blocks = network::messages::peer::get_blocks;
using inventory_item = network::messages::peer::inventory_item;

/// Block announcements are superseded by send_headers.
virtual bool superseded() const NOEXCEPT;
Expand All @@ -71,9 +72,11 @@ class BCN_API protocol_block_out_106
const get_data::cptr& message) NOEXCEPT;
virtual void send_block(const code& ec) NOEXCEPT;

/// The requested item cannot be served, stops the channel.
virtual void handle_unservable(const inventory_item& item) NOEXCEPT;

private:
using inventory = network::messages::peer::inventory;
using inventory_item = network::messages::peer::inventory_item;
using inventory_items = network::messages::peer::inventory_items;

bool is_under_checkpoint(const database::header_link& link) NOEXCEPT;
Expand Down
55 changes: 55 additions & 0 deletions include/bitcoin/node/protocols/protocol_block_out_70001.hpp
Original file line number Diff line number Diff line change
@@ -0,0 +1,55 @@
/**
* Copyright (c) 2011-2026 libbitcoin developers
*
* This file is part of libbitcoin.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program 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 Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#ifndef LIBBITCOIN_NODE_PROTOCOLS_PROTOCOL_BLOCK_OUT_70001_HPP
#define LIBBITCOIN_NODE_PROTOCOLS_PROTOCOL_BLOCK_OUT_70001_HPP

#include <bitcoin/node/define.hpp>
#include <bitcoin/node/protocols/protocol_block_out_106.hpp>

namespace libbitcoin {
namespace node {

class BCN_API protocol_block_out_70001
: public protocol_block_out_106,
protected network::tracker<protocol_block_out_70001>
{
public:
typedef std::shared_ptr<protocol_block_out_70001> ptr;

protocol_block_out_70001(const auto& session,
const network::channel::ptr& channel) NOEXCEPT
: protocol_block_out_106(session, channel),
enable_not_found_(session->network_settings().enable_not_found),
network::tracker<protocol_block_out_70001>(session->log)
{
}

protected:
/// The requested item cannot be served, replies not_found.
void handle_unservable(const inventory_item& item) NOEXCEPT override;

private:
// This is thread safe.
const bool enable_not_found_;
};

} // namespace node
} // namespace libbitcoin

#endif
6 changes: 3 additions & 3 deletions include/bitcoin/node/protocols/protocol_block_out_70012.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -20,21 +20,21 @@
#define LIBBITCOIN_NODE_PROTOCOLS_PROTOCOL_BLOCK_OUT_70012_HPP

#include <bitcoin/node/define.hpp>
#include <bitcoin/node/protocols/protocol_block_out_106.hpp>
#include <bitcoin/node/protocols/protocol_block_out_70001.hpp>

namespace libbitcoin {
namespace node {

class BCN_API protocol_block_out_70012
: public protocol_block_out_106,
: public protocol_block_out_70001,
protected network::tracker<protocol_block_out_70012>
{
public:
typedef std::shared_ptr<protocol_block_out_70012> ptr;

protocol_block_out_70012(const auto& session,
const network::channel::ptr& channel) NOEXCEPT
: protocol_block_out_106(session, channel),
: protocol_block_out_70001(session, channel),
network::tracker<protocol_block_out_70012>(session->log)
{
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -63,6 +63,11 @@ class BCN_API protocol_transaction_out_106
virtual void send_transaction(const code& ec, size_t index,
const network::messages::peer::get_data::cptr& message) NOEXCEPT;

/// The requested item cannot be served, stops the channel.
virtual void handle_unservable(
const network::messages::peer::inventory_item& item, size_t index,
const network::messages::peer::get_data::cptr& message) NOEXCEPT;

virtual bool announce(const system::hash_digest& hash) NOEXCEPT;

private:
Expand Down
58 changes: 58 additions & 0 deletions include/bitcoin/node/protocols/protocol_transaction_out_70001.hpp
Original file line number Diff line number Diff line change
@@ -0,0 +1,58 @@
/**
* Copyright (c) 2011-2026 libbitcoin developers
*
* This file is part of libbitcoin.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program 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 Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#ifndef LIBBITCOIN_NODE_PROTOCOLS_PROTOCOL_TRANSACTION_OUT_70001_HPP
#define LIBBITCOIN_NODE_PROTOCOLS_PROTOCOL_TRANSACTION_OUT_70001_HPP

#include <bitcoin/node/define.hpp>
#include <bitcoin/node/protocols/protocol_transaction_out_106.hpp>

namespace libbitcoin {
namespace node {

class BCN_API protocol_transaction_out_70001
: public protocol_transaction_out_106,
protected network::tracker<protocol_transaction_out_70001>
{
public:
typedef std::shared_ptr<protocol_transaction_out_70001> ptr;

protocol_transaction_out_70001(const auto& session,
const network::channel::ptr& channel) NOEXCEPT
: protocol_transaction_out_106(session, channel),
enable_not_found_(session->network_settings().enable_not_found),
network::tracker<protocol_transaction_out_70001>(session->log)
{
}

protected:
/// The requested item cannot be served, replies not_found.
void handle_unservable(
const network::messages::peer::inventory_item& item, size_t index,
const network::messages::peer::get_data::cptr& message) NOEXCEPT
override;

private:
// This is thread safe.
const bool enable_not_found_;
};

} // namespace node
} // namespace libbitcoin

#endif
2 changes: 2 additions & 0 deletions include/bitcoin/node/protocols/protocols.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@
#include <bitcoin/node/protocols/protocol_block_in_106.hpp>
#include <bitcoin/node/protocols/protocol_block_in_31800.hpp>
#include <bitcoin/node/protocols/protocol_block_out_106.hpp>
#include <bitcoin/node/protocols/protocol_block_out_70001.hpp>
#include <bitcoin/node/protocols/protocol_block_out_70012.hpp>
#include <bitcoin/node/protocols/protocol_filter_out_70015.hpp>
#include <bitcoin/node/protocols/protocol_header_in_31800.hpp>
Expand All @@ -34,5 +35,6 @@
#include <bitcoin/node/protocols/protocol_performer.hpp>
#include <bitcoin/node/protocols/protocol_transaction_in_106.hpp>
#include <bitcoin/node/protocols/protocol_transaction_out_106.hpp>
#include <bitcoin/node/protocols/protocol_transaction_out_70001.hpp>

#endif
Loading
Loading