Skip to content

Commit

Permalink
Net: Make CNetMsgMaker more const
Browse files Browse the repository at this point in the history
  • Loading branch information
jtimon committed Jan 31, 2017
1 parent d45955f commit fc7f2ff
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
10 changes: 5 additions & 5 deletions src/net_processing.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -778,7 +778,7 @@ static uint256 most_recent_block_hash;

void PeerLogicValidation::NewPoWValidBlock(const CBlockIndex *pindex, const std::shared_ptr<const CBlock>& pblock) {
std::shared_ptr<const CBlockHeaderAndShortTxIDs> pcmpctblock = std::make_shared<const CBlockHeaderAndShortTxIDs> (*pblock, true);
CNetMsgMaker msgMaker(PROTOCOL_VERSION);
const CNetMsgMaker msgMaker(PROTOCOL_VERSION);

LOCK(cs_main);

Expand Down Expand Up @@ -960,7 +960,7 @@ void static ProcessGetData(CNode* pfrom, const Consensus::Params& consensusParam
{
std::deque<CInv>::iterator it = pfrom->vRecvGetData.begin();
std::vector<CInv> vNotFound;
CNetMsgMaker msgMaker(pfrom->GetSendVersion());
const CNetMsgMaker msgMaker(pfrom->GetSendVersion());
LOCK(cs_main);

while (it != pfrom->vRecvGetData.end()) {
Expand Down Expand Up @@ -1153,7 +1153,7 @@ inline void static SendBlockTransactions(const CBlock& block, const BlockTransac
resp.txn[i] = block.vtx[req.indexes[i]];
}
LOCK(cs_main);
CNetMsgMaker msgMaker(pfrom->GetSendVersion());
const CNetMsgMaker msgMaker(pfrom->GetSendVersion());
int nSendFlags = State(pfrom->GetId())->fWantsCmpctWitness ? 0 : SERIALIZE_TRANSACTION_NO_WITNESS;
connman.PushMessage(pfrom, msgMaker.Make(nSendFlags, NetMsgType::BLOCKTXN, resp));
}
Expand Down Expand Up @@ -1346,7 +1346,7 @@ bool static ProcessMessage(CNode* pfrom, std::string strCommand, CDataStream& vR
}

// At this point, the outgoing message serialization version can't change.
CNetMsgMaker msgMaker(pfrom->GetSendVersion());
const CNetMsgMaker msgMaker(pfrom->GetSendVersion());

if (strCommand == NetMsgType::VERACK)
{
Expand Down Expand Up @@ -2721,7 +2721,7 @@ bool SendMessages(CNode* pto, CConnman& connman, std::atomic<bool>& interruptMsg
return true;

// If we get here, the outgoing message serialization version is set and can't change.
CNetMsgMaker msgMaker(pto->GetSendVersion());
const CNetMsgMaker msgMaker(pto->GetSendVersion());

//
// Message: ping
Expand Down
4 changes: 2 additions & 2 deletions src/netmessagemaker.h
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ class CNetMsgMaker
CNetMsgMaker(int nVersionIn) : nVersion(nVersionIn){}

template <typename... Args>
CSerializedNetMsg Make(int nFlags, std::string sCommand, Args&&... args)
CSerializedNetMsg Make(int nFlags, std::string sCommand, Args&&... args) const
{
CSerializedNetMsg msg;
msg.command = std::move(sCommand);
Expand All @@ -24,7 +24,7 @@ class CNetMsgMaker
}

template <typename... Args>
CSerializedNetMsg Make(std::string sCommand, Args&&... args)
CSerializedNetMsg Make(std::string sCommand, Args&&... args) const
{
return Make(0, std::move(sCommand), std::forward<Args>(args)...);
}
Expand Down

0 comments on commit fc7f2ff

Please sign in to comment.