mirror of
https://github.com/dashpay/dash.git
synced 2024-12-26 20:42:59 +01:00
b621cfb5fb
* serialization: teach serializers variadics Also add a variadic CDataStream ctor for ease-of-use. * connman is in charge of pushing messages The changes here are dense and subtle, but hopefully all is more explicit than before. - CConnman is now in charge of sending data rather than the nodes themselves. This is necessary because many decisions need to be made with all nodes in mind, and a model that requires the nodes calling up to their manager quickly turns to spaghetti. - The per-node-serializer (ssSend) has been replaced with a (quasi-)const send-version. Since the send version for serialization can only change once per connection, we now explicitly tag messages with INIT_PROTO_VERSION if they are sent before the handshake. With this done, there's no need to lock for access to nSendVersion. Also, a new stream is used for each message, so there's no need to lock during the serialization process. - This takes care of accounting for optimistic sends, so the nOptimisticBytesWritten hack can be removed. - -dropmessagestest and -fuzzmessagestest have not been preserved, as I suspect they haven't been used in years. * net: switch all callers to connman for pushing messages Drop all of the old stuff. * drop the optimistic write counter hack This is now handled properly in realtime. * net: remove now-unused ssSend and Fuzz * net: construct CNodeStates in place * net: handle version push in InitializeNode
116 lines
3.3 KiB
C++
116 lines
3.3 KiB
C++
// Copyright (c) 2010 Satoshi Nakamoto
|
|
// Copyright (c) 2009-2015 The Bitcoin Core developers
|
|
// Distributed under the MIT software license, see the accompanying
|
|
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
|
|
|
#ifndef BITCOIN_ALERT_H
|
|
#define BITCOIN_ALERT_H
|
|
|
|
#include "serialize.h"
|
|
#include "sync.h"
|
|
|
|
#include <map>
|
|
#include <set>
|
|
#include <stdint.h>
|
|
#include <string>
|
|
|
|
class CAlert;
|
|
class CNode;
|
|
class CConnman;
|
|
class uint256;
|
|
|
|
extern std::map<uint256, CAlert> mapAlerts;
|
|
extern CCriticalSection cs_mapAlerts;
|
|
|
|
/** Alerts are for notifying old versions if they become too obsolete and
|
|
* need to upgrade. The message is displayed in the status bar.
|
|
* Alert messages are broadcast as a vector of signed data. Unserializing may
|
|
* not read the entire buffer if the alert is for a newer version, but older
|
|
* versions can still relay the original data.
|
|
*/
|
|
class CUnsignedAlert
|
|
{
|
|
public:
|
|
int nVersion;
|
|
int64_t nRelayUntil; // when newer nodes stop relaying to newer nodes
|
|
int64_t nExpiration;
|
|
int nID;
|
|
int nCancel;
|
|
std::set<int> setCancel;
|
|
int nMinVer; // lowest version inclusive
|
|
int nMaxVer; // highest version inclusive
|
|
std::set<std::string> setSubVer; // empty matches all
|
|
int nPriority;
|
|
|
|
// Actions
|
|
std::string strComment;
|
|
std::string strStatusBar;
|
|
std::string strReserved;
|
|
|
|
ADD_SERIALIZE_METHODS;
|
|
|
|
template <typename Stream, typename Operation>
|
|
inline void SerializationOp(Stream& s, Operation ser_action, int nType, int nVersion) {
|
|
READWRITE(this->nVersion);
|
|
nVersion = this->nVersion;
|
|
READWRITE(nRelayUntil);
|
|
READWRITE(nExpiration);
|
|
READWRITE(nID);
|
|
READWRITE(nCancel);
|
|
READWRITE(setCancel);
|
|
READWRITE(nMinVer);
|
|
READWRITE(nMaxVer);
|
|
READWRITE(setSubVer);
|
|
READWRITE(nPriority);
|
|
|
|
READWRITE(LIMITED_STRING(strComment, 65536));
|
|
READWRITE(LIMITED_STRING(strStatusBar, 256));
|
|
READWRITE(LIMITED_STRING(strReserved, 256));
|
|
}
|
|
|
|
void SetNull();
|
|
|
|
std::string ToString() const;
|
|
};
|
|
|
|
/** An alert is a combination of a serialized CUnsignedAlert and a signature. */
|
|
class CAlert : public CUnsignedAlert
|
|
{
|
|
public:
|
|
std::vector<unsigned char> vchMsg;
|
|
std::vector<unsigned char> vchSig;
|
|
|
|
CAlert()
|
|
{
|
|
SetNull();
|
|
}
|
|
|
|
ADD_SERIALIZE_METHODS;
|
|
|
|
template <typename Stream, typename Operation>
|
|
inline void SerializationOp(Stream& s, Operation ser_action, int nType, int nVersion) {
|
|
READWRITE(vchMsg);
|
|
READWRITE(vchSig);
|
|
}
|
|
|
|
void SetNull();
|
|
bool IsNull() const;
|
|
uint256 GetHash() const;
|
|
bool IsInEffect() const;
|
|
bool Cancels(const CAlert& alert) const;
|
|
bool AppliesTo(int nVersion, const std::string& strSubVerIn) const;
|
|
bool AppliesToMe() const;
|
|
bool RelayTo(CNode* pnode, CConnman& connman) const;
|
|
bool Sign();
|
|
bool CheckSignature(const std::vector<unsigned char>& alertKey) const;
|
|
bool ProcessAlert(const std::vector<unsigned char>& alertKey, bool fThread = true); // fThread means run -alertnotify in a free-running thread
|
|
static void Notify(const std::string& strMessage, bool fThread);
|
|
|
|
/*
|
|
* Get copy of (active) alert object by hash. Returns a null alert if it is not found.
|
|
*/
|
|
static CAlert getAlertByHash(const uint256 &hash);
|
|
};
|
|
|
|
#endif // BITCOIN_ALERT_H
|