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
113 lines
3.6 KiB
C++
113 lines
3.6 KiB
C++
#include "alert.h"
|
|
#include "clientversion.h"
|
|
#include "chainparams.h"
|
|
#include "init.h"
|
|
#include "net.h"
|
|
#include "utilstrencodings.h"
|
|
#include "utiltime.h"
|
|
|
|
/*
|
|
If you need to broadcast an alert, here's what to do:
|
|
|
|
1. Modify alert parameters below, see alert.* and comments in the code
|
|
for what does what.
|
|
|
|
2. run dashd with -printalert or -sendalert like this:
|
|
/path/to/dashd -printalert
|
|
|
|
One minute after starting up the alert will be broadcast. It is then
|
|
flooded through the network until the nRelayUntil time, and will be
|
|
active until nExpiration OR the alert is cancelled.
|
|
|
|
If you screw up something, send another alert with nCancel set to cancel
|
|
the bad alert.
|
|
*/
|
|
|
|
void ThreadSendAlert(CConnman& connman)
|
|
{
|
|
if (!mapArgs.count("-sendalert") && !mapArgs.count("-printalert"))
|
|
return;
|
|
|
|
// Wait one minute so we get well connected. If we only need to print
|
|
// but not to broadcast - do this right away.
|
|
if (mapArgs.count("-sendalert"))
|
|
MilliSleep(60*1000);
|
|
|
|
//
|
|
// Alerts are relayed around the network until nRelayUntil, flood
|
|
// filling to every node.
|
|
// After the relay time is past, new nodes are told about alerts
|
|
// when they connect to peers, until either nExpiration or
|
|
// the alert is cancelled by a newer alert.
|
|
// Nodes never save alerts to disk, they are in-memory-only.
|
|
//
|
|
CAlert alert;
|
|
alert.nRelayUntil = GetTime() + 15 * 60;
|
|
alert.nExpiration = GetTime() + 30 * 60 * 60;
|
|
alert.nID = 1; // keep track of alert IDs somewhere
|
|
alert.nCancel = 0; // cancels previous messages up to this ID number
|
|
|
|
// These versions are protocol versions
|
|
alert.nMinVer = 70000;
|
|
alert.nMaxVer = 70103;
|
|
|
|
//
|
|
// 1000 for Misc warnings like out of disk space and clock is wrong
|
|
// 2000 for longer invalid proof-of-work chain
|
|
// Higher numbers mean higher priority
|
|
alert.nPriority = 5000;
|
|
alert.strComment = "";
|
|
alert.strStatusBar = "URGENT: Upgrade required: see https://www.dash.org";
|
|
|
|
// Set specific client version/versions here. If setSubVer is empty, no filtering on subver is done:
|
|
// alert.setSubVer.insert(std::string("/Dash Core:0.12.0.58/"));
|
|
|
|
// Sign
|
|
if(!alert.Sign())
|
|
{
|
|
LogPrintf("ThreadSendAlert() : could not sign alert\n");
|
|
return;
|
|
}
|
|
|
|
// Test
|
|
CDataStream sBuffer(SER_NETWORK, CLIENT_VERSION);
|
|
sBuffer << alert;
|
|
CAlert alert2;
|
|
sBuffer >> alert2;
|
|
if (!alert2.CheckSignature(Params().AlertKey()))
|
|
{
|
|
printf("ThreadSendAlert() : CheckSignature failed\n");
|
|
return;
|
|
}
|
|
assert(alert2.vchMsg == alert.vchMsg);
|
|
assert(alert2.vchSig == alert.vchSig);
|
|
alert.SetNull();
|
|
printf("\nThreadSendAlert:\n");
|
|
printf("hash=%s\n", alert2.GetHash().ToString().c_str());
|
|
printf("%s", alert2.ToString().c_str());
|
|
printf("vchMsg=%s\n", HexStr(alert2.vchMsg).c_str());
|
|
printf("vchSig=%s\n", HexStr(alert2.vchSig).c_str());
|
|
|
|
// Confirm
|
|
if (!mapArgs.count("-sendalert"))
|
|
return;
|
|
while (connman.GetNodeCount(CConnman::CONNECTIONS_ALL) == 0 && !ShutdownRequested())
|
|
MilliSleep(500);
|
|
if (ShutdownRequested())
|
|
return;
|
|
|
|
// Send
|
|
printf("ThreadSendAlert() : Sending alert\n");
|
|
int nSent = 0;
|
|
{
|
|
g_connman->ForEachNode([&alert2, &nSent](CNode* pnode) {
|
|
if (alert2.RelayTo(pnode, *g_connman))
|
|
{
|
|
printf("ThreadSendAlert() : Sent alert to %s\n", pnode->addr.ToString().c_str());
|
|
nSent++;
|
|
}
|
|
});
|
|
}
|
|
printf("ThreadSendAlert() : Alert sent to %d nodes\n", nSent);
|
|
}
|