mirror of
https://github.com/dashpay/dash.git
synced 2024-12-29 13:59:06 +01:00
118 lines
2.9 KiB
C++
118 lines
2.9 KiB
C++
|
|
// Copyright (c) 2009-2012 The Dash Core developers
|
|
// Distributed under the MIT/X11 software license, see the accompanying
|
|
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
|
#ifndef INSTANTX_H
|
|
#define INSTANTX_H
|
|
|
|
#include "sync.h"
|
|
#include "net.h"
|
|
#include "key.h"
|
|
#include "util.h"
|
|
#include "base58.h"
|
|
#include "main.h"
|
|
#include "spork.h"
|
|
|
|
/*
|
|
At 15 signatures, 1/2 of the masternode network can be owned by
|
|
one party without comprimising the security of InstantX
|
|
(1000/2150.0)**10 = 0.00047382219560689856
|
|
(1000/2900.0)**10 = 2.3769498616783657e-05
|
|
|
|
### getting 5 of 10 signatures w/ 1000 nodes of 2900
|
|
(1000/2900.0)**5 = 0.004875397277841433
|
|
*/
|
|
#define INSTANTX_SIGNATURES_REQUIRED 6
|
|
#define INSTANTX_SIGNATURES_TOTAL 10
|
|
|
|
using namespace std;
|
|
using namespace boost;
|
|
|
|
class CConsensusVote;
|
|
class CTransaction;
|
|
class CTransactionLock;
|
|
|
|
static const int MIN_INSTANTX_PROTO_VERSION = 70103;
|
|
|
|
extern map<uint256, CTransaction> mapTxLockReq;
|
|
extern map<uint256, CTransaction> mapTxLockReqRejected;
|
|
extern map<uint256, CConsensusVote> mapTxLockVote;
|
|
extern std::map<COutPoint, uint256> mapLockedInputs;
|
|
extern int nCompleteTXLocks;
|
|
|
|
|
|
int64_t CreateNewLock(CTransaction tx);
|
|
|
|
bool IsIXTXValid(const CTransaction& txCollateral);
|
|
|
|
// if two conflicting locks are approved by the network, they will cancel out
|
|
bool CheckForConflictingLocks(CTransaction& tx);
|
|
|
|
void ProcessMessageInstantX(CNode* pfrom, std::string& strCommand, CDataStream& vRecv);
|
|
|
|
//check if we need to vote on this transaction
|
|
void DoConsensusVote(CTransaction& tx, int64_t nBlockHeight);
|
|
|
|
//process consensus vote message
|
|
bool ProcessConsensusVote(CNode *pnode, CConsensusVote& ctx);
|
|
|
|
// keep transaction locks in memory for an hour
|
|
void CleanTransactionLocksList();
|
|
|
|
// verify if transaction is currently locked
|
|
bool IsLockedIXTransaction(uint256 txHash);
|
|
|
|
// get the actual uber og accepted lock signatures
|
|
int GetTransactionLockSignatures(uint256 txHash);
|
|
|
|
// verify if transaction lock timed out
|
|
bool IsTransactionLockTimedOut(uint256 txHash);
|
|
|
|
int64_t GetAverageVoteTime();
|
|
|
|
class CConsensusVote
|
|
{
|
|
public:
|
|
CTxIn vinMasternode;
|
|
uint256 txHash;
|
|
int nBlockHeight;
|
|
std::vector<unsigned char> vchMasterNodeSignature;
|
|
|
|
uint256 GetHash() const;
|
|
|
|
bool SignatureValid();
|
|
bool Sign();
|
|
|
|
ADD_SERIALIZE_METHODS;
|
|
|
|
template <typename Stream, typename Operation>
|
|
inline void SerializationOp(Stream& s, Operation ser_action, int nType, int nVersion) {
|
|
READWRITE(txHash);
|
|
READWRITE(vinMasternode);
|
|
READWRITE(vchMasterNodeSignature);
|
|
READWRITE(nBlockHeight);
|
|
}
|
|
};
|
|
|
|
class CTransactionLock
|
|
{
|
|
public:
|
|
int nBlockHeight;
|
|
uint256 txHash;
|
|
std::vector<CConsensusVote> vecConsensusVotes;
|
|
int nExpiration;
|
|
int nTimeout;
|
|
|
|
bool SignaturesValid();
|
|
int CountSignatures();
|
|
void AddSignature(CConsensusVote& cv);
|
|
|
|
uint256 GetHash()
|
|
{
|
|
return txHash;
|
|
}
|
|
};
|
|
|
|
|
|
#endif
|