Convert everything except wallet/qt to new serialization

This commit is contained in:
Pieter Wuille 2020-03-11 09:35:50 -07:00
parent 2b1f85e8c5
commit 4eb5643e35
17 changed files with 70 additions and 212 deletions

View File

@ -20,9 +20,7 @@
struct nontrivial_t { struct nontrivial_t {
int x; int x;
nontrivial_t() :x(-1) {} nontrivial_t() :x(-1) {}
ADD_SERIALIZE_METHODS SERIALIZE_METHODS(nontrivial_t, obj) { READWRITE(obj.x); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {READWRITE(x);}
}; };
static_assert(!IS_TRIVIALLY_CONSTRUCTIBLE<nontrivial_t>::value, static_assert(!IS_TRIVIALLY_CONSTRUCTIBLE<nontrivial_t>::value,
"expected nontrivial_t to not be trivially constructible"); "expected nontrivial_t to not be trivially constructible");

View File

@ -66,15 +66,7 @@ public:
CBloomFilter(const unsigned int nElements, const double nFPRate, const unsigned int nTweak, unsigned char nFlagsIn); CBloomFilter(const unsigned int nElements, const double nFPRate, const unsigned int nTweak, unsigned char nFlagsIn);
CBloomFilter() : isFull(true), isEmpty(false), nHashFuncs(0), nTweak(0), nFlags(0) {} CBloomFilter() : isFull(true), isEmpty(false), nHashFuncs(0), nTweak(0), nFlags(0) {}
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CBloomFilter, obj) { READWRITE(obj.vData, obj.nHashFuncs, obj.nTweak, obj.nFlags); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
READWRITE(vData);
READWRITE(nHashFuncs);
READWRITE(nTweak);
READWRITE(nFlags);
}
void insert(const std::vector<unsigned char>& vKey); void insert(const std::vector<unsigned char>& vKey);
void insert(const COutPoint& outpoint); void insert(const COutPoint& outpoint);

View File

@ -16,13 +16,7 @@ struct FlatFilePos
int nFile; int nFile;
unsigned int nPos; unsigned int nPos;
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(FlatFilePos, obj) { READWRITE(VARINT_MODE(obj.nFile, VarIntMode::NONNEGATIVE_SIGNED), VARINT(obj.nPos)); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
READWRITE(VARINT_MODE(nFile, VarIntMode::NONNEGATIVE_SIGNED));
READWRITE(VARINT(nPos));
}
FlatFilePos() : nFile(-1), nPos(0) {} FlatFilePos() : nFile(-1), nPos(0) {}

View File

@ -39,14 +39,7 @@ struct DBVal {
uint256 header; uint256 header;
FlatFilePos pos; FlatFilePos pos;
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(DBVal, obj) { READWRITE(obj.hash, obj.header, obj.pos); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
READWRITE(hash);
READWRITE(header);
READWRITE(pos);
}
}; };
struct DBHeightKey { struct DBHeightKey {
@ -78,17 +71,14 @@ struct DBHashKey {
explicit DBHashKey(const uint256& hash_in) : hash(hash_in) {} explicit DBHashKey(const uint256& hash_in) : hash(hash_in) {}
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(DBHashKey, obj) {
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
char prefix = DB_BLOCK_HASH; char prefix = DB_BLOCK_HASH;
READWRITE(prefix); READWRITE(prefix);
if (prefix != DB_BLOCK_HASH) { if (prefix != DB_BLOCK_HASH) {
throw std::ios_base::failure("Invalid format for block filter index DB hash key"); throw std::ios_base::failure("Invalid format for block filter index DB hash key");
} }
READWRITE(hash); READWRITE(obj.hash);
} }
}; };

View File

@ -21,12 +21,10 @@ struct CDiskTxPos : public FlatFilePos
{ {
unsigned int nTxOffset; // after header unsigned int nTxOffset; // after header
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CDiskTxPos, obj)
{
template <typename Stream, typename Operation> READWRITEAS(FlatFilePos, obj);
inline void SerializationOp(Stream& s, Operation ser_action) { READWRITE(VARINT(obj.nTxOffset));
READWRITEAS(FlatFilePos, *this);
READWRITE(VARINT(nTxOffset));
} }
CDiskTxPos(const FlatFilePos &blockIn, unsigned int nTxOffsetIn) : FlatFilePos(blockIn.nFile, blockIn.nPos), nTxOffset(nTxOffsetIn) { CDiskTxPos(const FlatFilePos &blockIn, unsigned int nTxOffsetIn) : FlatFilePos(blockIn.nFile, blockIn.nPos), nTxOffset(nTxOffsetIn) {

View File

@ -99,12 +99,7 @@ class CNetAddr
friend bool operator!=(const CNetAddr& a, const CNetAddr& b) { return !(a == b); } friend bool operator!=(const CNetAddr& a, const CNetAddr& b) { return !(a == b); }
friend bool operator<(const CNetAddr& a, const CNetAddr& b); friend bool operator<(const CNetAddr& a, const CNetAddr& b);
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CNetAddr, obj) { READWRITE(obj.ip); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
READWRITE(ip);
}
friend class CSubNet; friend class CSubNet;
}; };
@ -136,14 +131,7 @@ class CSubNet
friend bool operator!=(const CSubNet& a, const CSubNet& b) { return !(a == b); } friend bool operator!=(const CSubNet& a, const CSubNet& b) { return !(a == b); }
friend bool operator<(const CSubNet& a, const CSubNet& b); friend bool operator<(const CSubNet& a, const CSubNet& b);
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CSubNet, obj) { READWRITE(obj.network, obj.netmask, obj.valid); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
READWRITE(network);
READWRITE(netmask);
READWRITE(valid);
}
}; };
/** A combination of a network address (CNetAddr) and a (TCP) port */ /** A combination of a network address (CNetAddr) and a (TCP) port */
@ -171,13 +159,7 @@ class CService : public CNetAddr
CService(const struct in6_addr& ipv6Addr, unsigned short port); CService(const struct in6_addr& ipv6Addr, unsigned short port);
explicit CService(const struct sockaddr_in6& addr); explicit CService(const struct sockaddr_in6& addr);
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CService, obj) { READWRITE(obj.ip, Using<BigEndianFormatter<2>>(obj.port)); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
READWRITE(ip);
READWRITE(Using<BigEndianFormatter<2>>(port));
}
}; };
#endif // BITCOIN_NETADDRESS_H #endif // BITCOIN_NETADDRESS_H

View File

@ -35,16 +35,7 @@ public:
m_coins_count(coins_count), m_coins_count(coins_count),
m_nchaintx(nchaintx) { } m_nchaintx(nchaintx) { }
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(SnapshotMetadata, obj) { READWRITE(obj.m_base_blockhash, obj.m_coins_count, obj.m_nchaintx); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action)
{
READWRITE(m_base_blockhash);
READWRITE(m_coins_count);
READWRITE(m_nchaintx);
}
}; };
#endif // BITCOIN_NODE_UTXO_SNAPSHOT_H #endif // BITCOIN_NODE_UTXO_SNAPSHOT_H

View File

@ -48,12 +48,7 @@ public:
CFeeRate& operator+=(const CFeeRate& a) { nSatoshisPerK += a.nSatoshisPerK; return *this; } CFeeRate& operator+=(const CFeeRate& a) { nSatoshisPerK += a.nSatoshisPerK; return *this; }
std::string ToString() const; std::string ToString() const;
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CFeeRate, obj) { READWRITE(obj.nSatoshisPerK); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
READWRITE(nSatoshisPerK);
}
}; };
#endif // BITCOIN_POLICY_FEERATE_H #endif // BITCOIN_POLICY_FEERATE_H

View File

@ -33,17 +33,7 @@ public:
SetNull(); SetNull();
} }
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CBlockHeader, obj) { READWRITE(obj.nVersion, obj.hashPrevBlock, obj.hashMerkleRoot, obj.nTime, obj.nBits, obj.nNonce); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
READWRITE(this->nVersion);
READWRITE(hashPrevBlock);
READWRITE(hashMerkleRoot);
READWRITE(nTime);
READWRITE(nBits);
READWRITE(nNonce);
}
void SetNull() void SetNull()
{ {
@ -89,12 +79,10 @@ public:
*(static_cast<CBlockHeader*>(this)) = header; *(static_cast<CBlockHeader*>(this)) = header;
} }
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CBlock, obj)
{
template <typename Stream, typename Operation> READWRITEAS(CBlockHeader, obj);
inline void SerializationOp(Stream& s, Operation ser_action) { READWRITE(obj.vtx);
READWRITEAS(CBlockHeader, *this);
READWRITE(vtx);
} }
void SetNull() void SetNull()
@ -131,14 +119,12 @@ struct CBlockLocator
explicit CBlockLocator(const std::vector<uint256>& vHaveIn) : vHave(vHaveIn) {} explicit CBlockLocator(const std::vector<uint256>& vHaveIn) : vHave(vHaveIn) {}
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CBlockLocator, obj)
{
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
int nVersion = s.GetVersion(); int nVersion = s.GetVersion();
if (!(s.GetType() & SER_GETHASH)) if (!(s.GetType() & SER_GETHASH))
READWRITE(nVersion); READWRITE(nVersion);
READWRITE(vHave); READWRITE(obj.vHave);
} }
void SetNull() void SetNull()

View File

@ -26,13 +26,7 @@ public:
COutPoint(): n(NULL_INDEX) { } COutPoint(): n(NULL_INDEX) { }
COutPoint(const uint256& hashIn, uint32_t nIn): hash(hashIn), n(nIn) { } COutPoint(const uint256& hashIn, uint32_t nIn): hash(hashIn), n(nIn) { }
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(COutPoint, obj) { READWRITE(obj.hash, obj.n); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
READWRITE(hash);
READWRITE(n);
}
void SetNull() { hash.SetNull(); n = NULL_INDEX; } void SetNull() { hash.SetNull(); n = NULL_INDEX; }
bool IsNull() const { return (hash.IsNull() && n == NULL_INDEX); } bool IsNull() const { return (hash.IsNull() && n == NULL_INDEX); }
@ -103,14 +97,7 @@ public:
explicit CTxIn(COutPoint prevoutIn, CScript scriptSigIn=CScript(), uint32_t nSequenceIn=SEQUENCE_FINAL); explicit CTxIn(COutPoint prevoutIn, CScript scriptSigIn=CScript(), uint32_t nSequenceIn=SEQUENCE_FINAL);
CTxIn(uint256 hashPrevTx, uint32_t nOut, CScript scriptSigIn=CScript(), uint32_t nSequenceIn=SEQUENCE_FINAL); CTxIn(uint256 hashPrevTx, uint32_t nOut, CScript scriptSigIn=CScript(), uint32_t nSequenceIn=SEQUENCE_FINAL);
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CTxIn, obj) { READWRITE(obj.prevout, obj.scriptSig, obj.nSequence); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
READWRITE(prevout);
READWRITE(scriptSig);
READWRITE(nSequence);
}
friend bool operator==(const CTxIn& a, const CTxIn& b) friend bool operator==(const CTxIn& a, const CTxIn& b)
{ {
@ -143,13 +130,7 @@ public:
CTxOut(const CAmount& nValueIn, CScript scriptPubKeyIn); CTxOut(const CAmount& nValueIn, CScript scriptPubKeyIn);
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CTxOut, obj) { READWRITE(obj.nValue, obj.scriptPubKey); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
READWRITE(nValue);
READWRITE(scriptPubKey);
}
void SetNull() void SetNull()
{ {

View File

@ -46,16 +46,7 @@ public:
std::string GetCommand() const; std::string GetCommand() const;
bool IsValid(const MessageStartChars& messageStart) const; bool IsValid(const MessageStartChars& messageStart) const;
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CMessageHeader, obj) { READWRITE(obj.pchMessageStart, obj.pchCommand, obj.nMessageSize, obj.pchChecksum); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action)
{
READWRITE(pchMessageStart);
READWRITE(pchCommand);
READWRITE(nMessageSize);
READWRITE(pchChecksum);
}
char pchMessageStart[MESSAGE_START_SIZE]; char pchMessageStart[MESSAGE_START_SIZE];
char pchCommand[COMMAND_SIZE]; char pchCommand[COMMAND_SIZE];
@ -327,23 +318,19 @@ public:
void Init(); void Init();
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CAddress, obj)
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action)
{ {
if (ser_action.ForRead()) SER_READ(obj, obj.Init());
Init();
int nVersion = s.GetVersion(); int nVersion = s.GetVersion();
if (s.GetType() & SER_DISK) if (s.GetType() & SER_DISK) {
READWRITE(nVersion); READWRITE(nVersion);
}
if ((s.GetType() & SER_DISK) || if ((s.GetType() & SER_DISK) ||
(nVersion >= CADDR_TIME_VERSION && !(s.GetType() & SER_GETHASH))) (nVersion >= CADDR_TIME_VERSION && !(s.GetType() & SER_GETHASH))) {
READWRITE(nTime); READWRITE(obj.nTime);
uint64_t nServicesInt = nServices; }
READWRITE(nServicesInt); READWRITE(Using<CustomUintFormatter<8>>(obj.nServices));
nServices = static_cast<ServiceFlags>(nServicesInt); READWRITEAS(CService, obj);
READWRITEAS(CService, *this);
} }
// TODO: make private (improves encapsulation) // TODO: make private (improves encapsulation)
@ -382,14 +369,7 @@ public:
CInv(); CInv();
CInv(int typeIn, const uint256& hashIn); CInv(int typeIn, const uint256& hashIn);
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CInv, obj) { READWRITE(obj.type, obj.hash); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action)
{
READWRITE(type);
READWRITE(hash);
}
friend bool operator<(const CInv& a, const CInv& b); friend bool operator<(const CInv& a, const CInv& b);

View File

@ -49,18 +49,13 @@ struct CCoin {
uint32_t nHeight; uint32_t nHeight;
CTxOut out; CTxOut out;
ADD_SERIALIZE_METHODS;
CCoin() : nHeight(0) {} CCoin() : nHeight(0) {}
explicit CCoin(Coin&& in) : nHeight(in.nHeight), out(std::move(in.out)) {} explicit CCoin(Coin&& in) : nHeight(in.nHeight), out(std::move(in.out)) {}
template <typename Stream, typename Operation> SERIALIZE_METHODS(CCoin, obj)
inline void SerializationOp(Stream& s, Operation ser_action)
{ {
uint32_t nTxVerDummy = 0; uint32_t nTxVerDummy = 0;
READWRITE(nTxVerDummy); READWRITE(nTxVerDummy, obj.nHeight, obj.out);
READWRITE(nHeight);
READWRITE(out);
} }
}; };

View File

@ -18,13 +18,7 @@ struct KeyOriginInfo
return std::equal(std::begin(a.fingerprint), std::end(a.fingerprint), std::begin(b.fingerprint)) && a.path == b.path; return std::equal(std::begin(a.fingerprint), std::end(a.fingerprint), std::begin(b.fingerprint)) && a.path == b.path;
} }
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(KeyOriginInfo, obj) { READWRITE(obj.fingerprint, obj.path); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action)
{
READWRITE(fingerprint);
READWRITE(path);
}
void clear() void clear()
{ {

View File

@ -412,12 +412,7 @@ public:
CScript(std::vector<unsigned char>::const_iterator pbegin, std::vector<unsigned char>::const_iterator pend) : CScriptBase(pbegin, pend) { } CScript(std::vector<unsigned char>::const_iterator pbegin, std::vector<unsigned char>::const_iterator pend) : CScriptBase(pbegin, pend) { }
CScript(const unsigned char* pbegin, const unsigned char* pend) : CScriptBase(pbegin, pend) { } CScript(const unsigned char* pbegin, const unsigned char* pend) : CScriptBase(pbegin, pend) { }
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CScript, obj) { READWRITEAS(CScriptBase, obj); }
template <typename Stream, typename Operation>
inline void SerializationOp(Stream& s, Operation ser_action) {
READWRITEAS(CScriptBase, *this);
}
CScript& operator+=(const CScript& b) CScript& operator+=(const CScript& b)
{ {

View File

@ -331,25 +331,27 @@ struct StringContentsSerializer {
} }
StringContentsSerializer& operator+=(const StringContentsSerializer& s) { return *this += s.str; } StringContentsSerializer& operator+=(const StringContentsSerializer& s) { return *this += s.str; }
ADD_SERIALIZE_METHODS; template<typename Stream>
void Serialize(Stream& s) const
{
for (size_t i = 0; i < str.size(); i++) {
s << str[i];
}
}
template <typename Stream, typename Operation> template<typename Stream>
inline void SerializationOp(Stream& s, Operation ser_action) { void Unserialize(Stream& s)
if (ser_action.ForRead()) { {
str.clear(); str.clear();
char c = 0; char c = 0;
while (true) { while (true) {
try { try {
READWRITE(c); s >> c;
str.push_back(c); str.push_back(c);
} catch (const std::ios_base::failure&) { } catch (const std::ios_base::failure&) {
break; break;
} }
} }
} else {
for (size_t i = 0; i < str.size(); i++)
READWRITE(str[i]);
}
} }
}; };

View File

@ -29,15 +29,13 @@ public:
memcpy(charstrval, charstrvalin, sizeof(charstrval)); memcpy(charstrval, charstrvalin, sizeof(charstrval));
} }
ADD_SERIALIZE_METHODS; SERIALIZE_METHODS(CSerializeMethodsTestSingle, obj)
{
template <typename Stream, typename Operation> READWRITE(obj.intval);
inline void SerializationOp(Stream& s, Operation ser_action) { READWRITE(obj.boolval);
READWRITE(intval); READWRITE(obj.stringval);
READWRITE(boolval); READWRITE(obj.charstrval);
READWRITE(stringval); READWRITE(obj.txval);
READWRITE(charstrval);
READWRITE(txval);
} }
bool operator==(const CSerializeMethodsTestSingle& rhs) bool operator==(const CSerializeMethodsTestSingle& rhs)
@ -54,11 +52,10 @@ class CSerializeMethodsTestMany : public CSerializeMethodsTestSingle
{ {
public: public:
using CSerializeMethodsTestSingle::CSerializeMethodsTestSingle; using CSerializeMethodsTestSingle::CSerializeMethodsTestSingle;
ADD_SERIALIZE_METHODS;
template <typename Stream, typename Operation> SERIALIZE_METHODS(CSerializeMethodsTestMany, obj)
inline void SerializationOp(Stream& s, Operation ser_action) { {
READWRITE(intval, boolval, stringval, charstrval, txval); READWRITE(obj.intval, obj.boolval, obj.stringval, obj.charstrval, obj.txval);
} }
}; };

View File

@ -36,19 +36,7 @@ struct CoinEntry {
char key; char key;
explicit CoinEntry(const COutPoint* ptr) : outpoint(const_cast<COutPoint*>(ptr)), key(DB_COIN) {} explicit CoinEntry(const COutPoint* ptr) : outpoint(const_cast<COutPoint*>(ptr)), key(DB_COIN) {}
template<typename Stream> SERIALIZE_METHODS(CoinEntry, obj) { READWRITE(obj.key, obj.outpoint->hash, VARINT(obj.outpoint->n)); }
void Serialize(Stream &s) const {
s << key;
s << outpoint->hash;
s << VARINT(outpoint->n);
}
template<typename Stream>
void Unserialize(Stream& s) {
s >> key;
s >> outpoint->hash;
s >> VARINT(outpoint->n);
}
}; };
} }