Skip to content

Commit 51e9393

Browse files
committed
refactor: s/command/msg_type/ in CNetMsgMaker and CSerializedNetMsg
1 parent 88d8b4e commit 51e9393

File tree

4 files changed

+10
-10
lines changed

4 files changed

+10
-10
lines changed

src/net.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -723,7 +723,7 @@ void V1TransportSerializer::prepareForTransport(CSerializedNetMsg& msg, std::vec
723723
uint256 hash = Hash(msg.data.begin(), msg.data.end());
724724

725725
// create header
726-
CMessageHeader hdr(Params().MessageStart(), msg.command.c_str(), msg.data.size());
726+
CMessageHeader hdr(Params().MessageStart(), msg.m_type.c_str(), msg.data.size());
727727
memcpy(hdr.pchChecksum, hash.begin(), CMessageHeader::CHECKSUM_SIZE);
728728

729729
// serialize header
@@ -2736,7 +2736,7 @@ bool CConnman::NodeFullyConnected(const CNode* pnode)
27362736
void CConnman::PushMessage(CNode* pnode, CSerializedNetMsg&& msg)
27372737
{
27382738
size_t nMessageSize = msg.data.size();
2739-
LogPrint(BCLog::NET, "sending %s (%d bytes) peer=%d\n", SanitizeString(msg.command), nMessageSize, pnode->GetId());
2739+
LogPrint(BCLog::NET, "sending %s (%d bytes) peer=%d\n", SanitizeString(msg.m_type), nMessageSize, pnode->GetId());
27402740

27412741
// make sure we use the appropriate network transport format
27422742
std::vector<unsigned char> serializedHeader;
@@ -2748,8 +2748,8 @@ void CConnman::PushMessage(CNode* pnode, CSerializedNetMsg&& msg)
27482748
LOCK(pnode->cs_vSend);
27492749
bool optimisticSend(pnode->vSendMsg.empty());
27502750

2751-
//log total amount of bytes per command
2752-
pnode->mapSendBytesPerMsgCmd[msg.command] += nTotalSize;
2751+
//log total amount of bytes per message type
2752+
pnode->mapSendBytesPerMsgCmd[msg.m_type] += nTotalSize;
27532753
pnode->nSendSize += nTotalSize;
27542754

27552755
if (pnode->nSendSize > nSendBufferMaxSize)

src/net.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ struct CSerializedNetMsg
108108
CSerializedNetMsg& operator=(const CSerializedNetMsg&) = delete;
109109

110110
std::vector<unsigned char> data;
111-
std::string command;
111+
std::string m_type;
112112
};
113113

114114

src/netmessagemaker.h

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,18 +15,18 @@ class CNetMsgMaker
1515
explicit CNetMsgMaker(int nVersionIn) : nVersion(nVersionIn){}
1616

1717
template <typename... Args>
18-
CSerializedNetMsg Make(int nFlags, std::string sCommand, Args&&... args) const
18+
CSerializedNetMsg Make(int nFlags, std::string msg_type, Args&&... args) const
1919
{
2020
CSerializedNetMsg msg;
21-
msg.command = std::move(sCommand);
21+
msg.m_type = std::move(msg_type);
2222
CVectorWriter{ SER_NETWORK, nFlags | nVersion, msg.data, 0, std::forward<Args>(args)... };
2323
return msg;
2424
}
2525

2626
template <typename... Args>
27-
CSerializedNetMsg Make(std::string sCommand, Args&&... args) const
27+
CSerializedNetMsg Make(std::string msg_type, Args&&... args) const
2828
{
29-
return Make(0, std::move(sCommand), std::forward<Args>(args)...);
29+
return Make(0, std::move(msg_type), std::forward<Args>(args)...);
3030
}
3131

3232
private:

src/test/fuzz/process_messages.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ void test_one_input(const std::vector<uint8_t>& buffer)
6262
const std::string random_message_type{fuzzed_data_provider.ConsumeBytesAsString(CMessageHeader::COMMAND_SIZE).c_str()};
6363

6464
CSerializedNetMsg net_msg;
65-
net_msg.command = random_message_type;
65+
net_msg.m_type = random_message_type;
6666
net_msg.data = ConsumeRandomLengthByteVector(fuzzed_data_provider);
6767

6868
CNode& random_node = *peers.at(fuzzed_data_provider.ConsumeIntegralInRange<int>(0, peers.size() - 1));

0 commit comments

Comments
 (0)