Skip to content

Commit 8d6ff46

Browse files
committed
scripted-diff: Rename OUTBOUND ConnectionType to OUTBOUND_FULL_RELAY
-BEGIN VERIFY SCRIPT- sed -i 's/OUTBOUND, /OUTBOUND_FULL_RELAY, /g' src/net.h sed -i 's/ConnectionType::OUTBOUND/ConnectionType::OUTBOUND_FULL_RELAY/g' src/test/net_tests.cpp src/test/fuzz/process_message.cpp src/test/fuzz/process_messages.cpp src/net.cpp src/test/denialofservice_tests.cpp src/net.h src/test/fuzz/net.cpp -END VERIFY SCRIPT-
1 parent c157a50 commit 8d6ff46

File tree

7 files changed

+15
-15
lines changed

7 files changed

+15
-15
lines changed

src/net.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1847,7 +1847,7 @@ void CConnman::ThreadOpenConnections(const std::vector<std::string> connect)
18471847
case ConnectionType::INBOUND:
18481848
case ConnectionType::MANUAL:
18491849
break;
1850-
case ConnectionType::OUTBOUND:
1850+
case ConnectionType::OUTBOUND_FULL_RELAY:
18511851
case ConnectionType::BLOCK_RELAY:
18521852
case ConnectionType::ADDR_FETCH:
18531853
case ConnectionType::FEELER:
@@ -1953,12 +1953,12 @@ void CConnman::ThreadOpenConnections(const std::vector<std::string> connect)
19531953
if (fFeeler) {
19541954
conn_type = ConnectionType::FEELER;
19551955
} else if (nOutboundFullRelay < m_max_outbound_full_relay) {
1956-
conn_type = ConnectionType::OUTBOUND;
1956+
conn_type = ConnectionType::OUTBOUND_FULL_RELAY;
19571957
} else if (nOutboundBlockRelay < m_max_outbound_block_relay) {
19581958
conn_type = ConnectionType::BLOCK_RELAY;
19591959
} else {
19601960
// GetTryNewOutboundPeer() is true
1961-
conn_type = ConnectionType::OUTBOUND;
1961+
conn_type = ConnectionType::OUTBOUND_FULL_RELAY;
19621962
}
19631963

19641964
OpenNetworkConnection(addrConnect, (int)setConnected.size() >= std::min(nMaxConnections - 1, 2), &grant, nullptr, conn_type);

src/net.h

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ struct CSerializedNetMsg
119119
* connection. Aside from INBOUND, all types are initiated by us. */
120120
enum class ConnectionType {
121121
INBOUND, /**< peer initiated connections */
122-
OUTBOUND, /**< full relay connections (blocks, addrs, txns) made automatically. Addresses selected from AddrMan. */
122+
OUTBOUND_FULL_RELAY, /**< full relay connections (blocks, addrs, txns) made automatically. Addresses selected from AddrMan. */
123123
MANUAL, /**< connections to addresses added via addnode or the connect command line argument */
124124
FEELER, /**< short lived connections used to test address validity */
125125
BLOCK_RELAY, /**< only relay blocks to these automatic outbound connections. Addresses selected from AddrMan. */
@@ -209,7 +209,7 @@ class CConnman
209209
bool GetNetworkActive() const { return fNetworkActive; };
210210
bool GetUseAddrmanOutgoing() const { return m_use_addrman_outgoing; };
211211
void SetNetworkActive(bool active);
212-
void OpenNetworkConnection(const CAddress& addrConnect, bool fCountFailure, CSemaphoreGrant *grantOutbound = nullptr, const char *strDest = nullptr, ConnectionType conn_type = ConnectionType::OUTBOUND);
212+
void OpenNetworkConnection(const CAddress& addrConnect, bool fCountFailure, CSemaphoreGrant *grantOutbound = nullptr, const char *strDest = nullptr, ConnectionType conn_type = ConnectionType::OUTBOUND_FULL_RELAY);
213213
bool CheckIncomingNonce(uint64_t nonce);
214214

215215
bool ForNode(NodeId id, std::function<bool(CNode* pnode)> func);
@@ -824,7 +824,7 @@ class CNode
824824

825825
bool IsOutboundOrBlockRelayConn() const {
826826
switch(m_conn_type) {
827-
case ConnectionType::OUTBOUND:
827+
case ConnectionType::OUTBOUND_FULL_RELAY:
828828
case ConnectionType::BLOCK_RELAY:
829829
return true;
830830
case ConnectionType::INBOUND:
@@ -838,7 +838,7 @@ class CNode
838838
}
839839

840840
bool IsFullOutboundConn() const {
841-
return m_conn_type == ConnectionType::OUTBOUND;
841+
return m_conn_type == ConnectionType::OUTBOUND_FULL_RELAY;
842842
}
843843

844844
bool IsManualConn() const {
@@ -867,7 +867,7 @@ class CNode
867867
case ConnectionType::MANUAL:
868868
case ConnectionType::FEELER:
869869
return false;
870-
case ConnectionType::OUTBOUND:
870+
case ConnectionType::OUTBOUND_FULL_RELAY:
871871
case ConnectionType::BLOCK_RELAY:
872872
case ConnectionType::ADDR_FETCH:
873873
return true;

src/test/denialofservice_tests.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ BOOST_AUTO_TEST_CASE(outbound_slow_chain_eviction)
8484

8585
// Mock an outbound peer
8686
CAddress addr1(ip(0xa0b0c001), NODE_NONE);
87-
CNode dummyNode1(id++, ServiceFlags(NODE_NETWORK|NODE_WITNESS), 0, INVALID_SOCKET, addr1, 0, 0, CAddress(), "", ConnectionType::OUTBOUND);
87+
CNode dummyNode1(id++, ServiceFlags(NODE_NETWORK|NODE_WITNESS), 0, INVALID_SOCKET, addr1, 0, 0, CAddress(), "", ConnectionType::OUTBOUND_FULL_RELAY);
8888
dummyNode1.SetSendVersion(PROTOCOL_VERSION);
8989

9090
peerLogic->InitializeNode(&dummyNode1);
@@ -136,7 +136,7 @@ BOOST_AUTO_TEST_CASE(outbound_slow_chain_eviction)
136136
static void AddRandomOutboundPeer(std::vector<CNode *> &vNodes, PeerLogicValidation &peerLogic, CConnmanTest* connman)
137137
{
138138
CAddress addr(ip(g_insecure_rand_ctx.randbits(32)), NODE_NONE);
139-
vNodes.emplace_back(new CNode(id++, ServiceFlags(NODE_NETWORK|NODE_WITNESS), 0, INVALID_SOCKET, addr, 0, 0, CAddress(), "", ConnectionType::OUTBOUND));
139+
vNodes.emplace_back(new CNode(id++, ServiceFlags(NODE_NETWORK|NODE_WITNESS), 0, INVALID_SOCKET, addr, 0, 0, CAddress(), "", ConnectionType::OUTBOUND_FULL_RELAY));
140140
CNode &node = *vNodes.back();
141141
node.SetSendVersion(PROTOCOL_VERSION);
142142

src/test/fuzz/net.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ void test_one_input(const std::vector<uint8_t>& buffer)
4646
fuzzed_data_provider.ConsumeIntegral<uint64_t>(),
4747
*address_bind,
4848
fuzzed_data_provider.ConsumeRandomLengthString(32),
49-
fuzzed_data_provider.PickValueInArray({ConnectionType::INBOUND, ConnectionType::OUTBOUND, ConnectionType::MANUAL, ConnectionType::FEELER, ConnectionType::BLOCK_RELAY, ConnectionType::ADDR_FETCH})};
49+
fuzzed_data_provider.PickValueInArray({ConnectionType::INBOUND, ConnectionType::OUTBOUND_FULL_RELAY, ConnectionType::MANUAL, ConnectionType::FEELER, ConnectionType::BLOCK_RELAY, ConnectionType::ADDR_FETCH})};
5050
while (fuzzed_data_provider.ConsumeBool()) {
5151
switch (fuzzed_data_provider.ConsumeIntegralInRange<int>(0, 12)) {
5252
case 0: {

src/test/fuzz/process_message.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ void test_one_input(const std::vector<uint8_t>& buffer)
6868
return;
6969
}
7070
CDataStream random_bytes_data_stream{fuzzed_data_provider.ConsumeRemainingBytes<unsigned char>(), SER_NETWORK, PROTOCOL_VERSION};
71-
CNode& p2p_node = *MakeUnique<CNode>(0, ServiceFlags(NODE_NETWORK | NODE_WITNESS | NODE_BLOOM), 0, INVALID_SOCKET, CAddress{CService{in_addr{0x0100007f}, 7777}, NODE_NETWORK}, 0, 0, CAddress{}, std::string{}, ConnectionType::OUTBOUND).release();
71+
CNode& p2p_node = *MakeUnique<CNode>(0, ServiceFlags(NODE_NETWORK | NODE_WITNESS | NODE_BLOOM), 0, INVALID_SOCKET, CAddress{CService{in_addr{0x0100007f}, 7777}, NODE_NETWORK}, 0, 0, CAddress{}, std::string{}, ConnectionType::OUTBOUND_FULL_RELAY).release();
7272
p2p_node.fSuccessfullyConnected = true;
7373
p2p_node.nVersion = PROTOCOL_VERSION;
7474
p2p_node.SetSendVersion(PROTOCOL_VERSION);

src/test/fuzz/process_messages.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ void test_one_input(const std::vector<uint8_t>& buffer)
4444
const auto num_peers_to_add = fuzzed_data_provider.ConsumeIntegralInRange(1, 3);
4545
for (int i = 0; i < num_peers_to_add; ++i) {
4646
const ServiceFlags service_flags = ServiceFlags(fuzzed_data_provider.ConsumeIntegral<uint64_t>());
47-
const ConnectionType conn_type = fuzzed_data_provider.PickValueInArray({ConnectionType::INBOUND, ConnectionType::OUTBOUND, ConnectionType::MANUAL, ConnectionType::FEELER, ConnectionType::BLOCK_RELAY, ConnectionType::ADDR_FETCH});
47+
const ConnectionType conn_type = fuzzed_data_provider.PickValueInArray({ConnectionType::INBOUND, ConnectionType::OUTBOUND_FULL_RELAY, ConnectionType::MANUAL, ConnectionType::FEELER, ConnectionType::BLOCK_RELAY, ConnectionType::ADDR_FETCH});
4848
peers.push_back(MakeUnique<CNode>(i, service_flags, 0, INVALID_SOCKET, CAddress{CService{in_addr{0x0100007f}, 7777}, NODE_NETWORK}, 0, 0, CAddress{}, std::string{}, conn_type).release());
4949
CNode& p2p_node = *peers.back();
5050

src/test/net_tests.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -183,7 +183,7 @@ BOOST_AUTO_TEST_CASE(cnode_simple_test)
183183
CAddress addr = CAddress(CService(ipv4Addr, 7777), NODE_NETWORK);
184184
std::string pszDest;
185185

186-
std::unique_ptr<CNode> pnode1 = MakeUnique<CNode>(id++, NODE_NETWORK, height, hSocket, addr, 0, 0, CAddress(), pszDest, ConnectionType::OUTBOUND);
186+
std::unique_ptr<CNode> pnode1 = MakeUnique<CNode>(id++, NODE_NETWORK, height, hSocket, addr, 0, 0, CAddress(), pszDest, ConnectionType::OUTBOUND_FULL_RELAY);
187187
BOOST_CHECK(pnode1->IsInboundConn() == false);
188188

189189
std::unique_ptr<CNode> pnode2 = MakeUnique<CNode>(id++, NODE_NETWORK, height, hSocket, addr, 1, 1, CAddress(), pszDest, ConnectionType::INBOUND);
@@ -283,7 +283,7 @@ BOOST_AUTO_TEST_CASE(ipv4_peer_with_ipv6_addrMe_test)
283283
in_addr ipv4AddrPeer;
284284
ipv4AddrPeer.s_addr = 0xa0b0c001;
285285
CAddress addr = CAddress(CService(ipv4AddrPeer, 7777), NODE_NETWORK);
286-
std::unique_ptr<CNode> pnode = MakeUnique<CNode>(0, NODE_NETWORK, 0, INVALID_SOCKET, addr, 0, 0, CAddress{}, std::string{}, ConnectionType::OUTBOUND);
286+
std::unique_ptr<CNode> pnode = MakeUnique<CNode>(0, NODE_NETWORK, 0, INVALID_SOCKET, addr, 0, 0, CAddress{}, std::string{}, ConnectionType::OUTBOUND_FULL_RELAY);
287287
pnode->fSuccessfullyConnected.store(true);
288288

289289
// the peer claims to be reaching us via IPv6

0 commit comments

Comments
 (0)