Differential D733 Diff 1868 src/seeder/bitcoin.cpp

Changeset View

Standalone View

src/seeder/bitcoin.cpp

#include "bitcoin.h"		#include "bitcoin.h"

#include "db.h"		#include "db.h"
		#include "hash.h"
#include "netbase.h"		#include "netbase.h"
#include "serialize.h"		#include "serialize.h"
#include "streams.h"		#include "streams.h"
#include "uint256.h"		#include "uint256.h"

#include <algorithm>		#include <algorithm>

// Weither we are on testnet or mainnet.		// Weither we are on testnet or mainnet.
bool fTestNet;		bool fTestNet;

// The network magic to use.		// The network magic to use.
CMessageHeader::MessageMagic netMagic = {0xe3, 0xe1, 0xf3, 0xe8};		CMessageHeader::MessageMagic netMagic = {0xe3, 0xe1, 0xf3, 0xe8};

#define BITCOIN_SEED_NONCE 0x0539a019ca550825ULL		#define BITCOIN_SEED_NONCE 0x0539a019ca550825ULL

static const uint32_t allones(-1);		static const uint32_t allones(-1);

class CNode {		class CSeederNode {
SOCKET sock;		SOCKET sock;
CDataStream vSend;		CDataStream vSend;
CDataStream vRecv;		CDataStream vRecv;
uint32_t nHeaderStart;		uint32_t nHeaderStart;
uint32_t nMessageStart;		uint32_t nMessageStart;
int nVersion;		int nVersion;
std::string strSubVer;		std::string strSubVer;
int nStartingHeight;		int nStartingHeight;
▲ Show 20 Lines • Show All 205 Lines • ▼ Show 20 Lines	bool ProcessMessages() {
if (ProcessMessage(strCommand, vMsg)) return true;		if (ProcessMessage(strCommand, vMsg)) return true;
// printf("%s: done processing %s\n", ToString(you).c_str(),		// printf("%s: done processing %s\n", ToString(you).c_str(),
// strCommand.c_str());		// strCommand.c_str());
} while (1);		} while (1);
return false;		return false;
}		}

public:		public:
CNode(const CService &ip, std::vector<CAddress> *vAddrIn)		CSeederNode(const CService &ip, std::vector<CAddress> *vAddrIn)
: vSend(SER_NETWORK, 0), vRecv(SER_NETWORK, 0), nHeaderStart(-1),		: vSend(SER_NETWORK, 0), vRecv(SER_NETWORK, 0), nHeaderStart(-1),
nMessageStart(-1), nVersion(0), vAddr(vAddrIn), ban(0), doneAfter(0),		nMessageStart(-1), nVersion(0), vAddr(vAddrIn), ban(0), doneAfter(0),
you(ip, ServiceFlags(NODE_NETWORK \| NODE_BITCOIN_CASH)) {		you(ip, ServiceFlags(NODE_NETWORK \| NODE_BITCOIN_CASH)) {
if (time(nullptr) > 1329696000) {		if (time(nullptr) > 1329696000) {
vSend.SetVersion(209);		vSend.SetVersion(209);
vRecv.SetVersion(209);		vRecv.SetVersion(209);
}		}
}		}
▲ Show 20 Lines • Show All 62 Lines • ▼ Show 20 Lines	public:

int GetStartingHeight() { return nStartingHeight; }		int GetStartingHeight() { return nStartingHeight; }
};		};

bool TestNode(const CService &cip, int &ban, int &clientV,		bool TestNode(const CService &cip, int &ban, int &clientV,
std::string &clientSV, int &blocks,		std::string &clientSV, int &blocks,
std::vector<CAddress> *vAddr) {		std::vector<CAddress> *vAddr) {
try {		try {
CNode node(cip, vAddr);		CSeederNode node(cip, vAddr);
bool ret = node.Run();		bool ret = node.Run();
if (!ret) {		if (!ret) {
ban = node.GetBan();		ban = node.GetBan();
} else {		} else {
ban = 0;		ban = 0;
}		}
clientV = node.GetClientVersion();		clientV = node.GetClientVersion();
clientSV = node.GetClientSubVersion();		clientSV = node.GetClientSubVersion();
blocks = node.GetStartingHeight();		blocks = node.GetStartingHeight();
// printf("%s: %s!!!\n", cip.ToString().c_str(), ret ? "GOOD" : "BAD");		// printf("%s: %s!!!\n", cip.ToString().c_str(), ret ? "GOOD" : "BAD");
return ret;		return ret;
} catch (std::ios_base::failure &e) {		} catch (std::ios_base::failure &e) {
ban = 0;		ban = 0;
return false;		return false;
}		}
}		}

/*
int main(void) {
CService ip("bitcoin.sipa.be", 8333, true);
std::vector<CAddress> vAddr;
vAddr.clear();
int ban = 0;
bool ret = TestNode(ip, ban, vAddr);
printf("ret=%s ban=%i vAddr.size()=%i\n", ret ? "good" : "bad", ban,
(int)vAddr.size());
}
*/