mirror of
https://github.com/XRPLF/rippled.git
synced 2025-12-06 17:27:55 +00:00
ad12e318ba
not responding. This version uses static timing. A peer takes a position every 12 seconds and a position is valid for 20 seconds. It might make sense to either make that timing adaptive or include a "validity time" field in the position. However, I think this is really only going to be an issue in fairly small networks (which is why we are seeing it).
92 lines
2.5 KiB
C++
92 lines
2.5 KiB
C++
|
|
#include "LedgerProposal.h"
|
|
|
|
#include <boost/make_shared.hpp>
|
|
|
|
#include "key.h"
|
|
#include "Application.h"
|
|
#include "HashPrefixes.h"
|
|
|
|
LedgerProposal::LedgerProposal(const uint256& pLgr, uint32 seq, const uint256& tx, uint32 closeTime,
|
|
const NewcoinAddress& naPeerPublic) :
|
|
mPreviousLedger(pLgr), mCurrentHash(tx), mCloseTime(closeTime), mProposeSeq(seq), mPublicKey(naPeerPublic)
|
|
{
|
|
// XXX Validate key.
|
|
// if (!mKey->SetPubKey(pubKey))
|
|
// throw std::runtime_error("Invalid public key in proposal");
|
|
|
|
mPeerID = mPublicKey.getNodeID();
|
|
mTime = boost::posix_time::second_clock::universal_time();
|
|
}
|
|
|
|
|
|
LedgerProposal::LedgerProposal(const NewcoinAddress& naSeed, const uint256& prevLgr,
|
|
const uint256& position, uint32 closeTime) :
|
|
mPreviousLedger(prevLgr), mCurrentHash(position), mCloseTime(closeTime), mProposeSeq(0)
|
|
{
|
|
mPublicKey = NewcoinAddress::createNodePublic(naSeed);
|
|
mPrivateKey = NewcoinAddress::createNodePrivate(naSeed);
|
|
mPeerID = mPublicKey.getNodeID();
|
|
mTime = boost::posix_time::second_clock::universal_time();
|
|
}
|
|
|
|
LedgerProposal::LedgerProposal(const uint256& prevLgr, const uint256& position, uint32 closeTime) :
|
|
mPreviousLedger(prevLgr), mCurrentHash(position), mCloseTime(closeTime), mProposeSeq(0)
|
|
{
|
|
mTime = boost::posix_time::second_clock::universal_time();
|
|
}
|
|
|
|
uint256 LedgerProposal::getSigningHash() const
|
|
{
|
|
Serializer s((32 + 32 + 32 + 256 + 256) / 8);
|
|
|
|
s.add32(sHP_Proposal);
|
|
s.add32(mProposeSeq);
|
|
s.add32(mCloseTime);
|
|
s.add256(mPreviousLedger);
|
|
s.add256(mCurrentHash);
|
|
|
|
return s.getSHA512Half();
|
|
}
|
|
|
|
bool LedgerProposal::checkSign(const std::string& signature, const uint256& signingHash)
|
|
{
|
|
return mPublicKey.verifyNodePublic(signingHash, signature);
|
|
}
|
|
|
|
void LedgerProposal::changePosition(const uint256& newPosition, uint32 closeTime)
|
|
{
|
|
mCurrentHash = newPosition;
|
|
mCloseTime = closeTime;
|
|
mTime = boost::posix_time::second_clock::universal_time();
|
|
++mProposeSeq;
|
|
}
|
|
|
|
std::vector<unsigned char> LedgerProposal::sign(void)
|
|
{
|
|
std::vector<unsigned char> ret;
|
|
|
|
mPrivateKey.signNodePrivate(getSigningHash(), ret);
|
|
// XXX If this can fail, find out sooner.
|
|
// if (!mPrivateKey.signNodePrivate(getSigningHash(), ret))
|
|
// throw std::runtime_error("unable to sign proposal");
|
|
|
|
return ret;
|
|
}
|
|
|
|
Json::Value LedgerProposal::getJson() const
|
|
{
|
|
Json::Value ret = Json::objectValue;
|
|
ret["previous_ledger"] = mPreviousLedger.GetHex();
|
|
ret["transaction_hash"] = mCurrentHash.GetHex();
|
|
ret["close_time"] = mCloseTime;
|
|
ret["propose_seq"] = mProposeSeq;
|
|
|
|
if (mPublicKey.isValid())
|
|
ret["peer_id"] = mPublicKey.humanNodePublic();
|
|
|
|
return ret;
|
|
}
|
|
|
|
// vim:ts=4
|