ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-20 11:05:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Bugfixes.

Browse Source
This commit is contained in:
JoelKatz
2012-01-19 16:14:47 -08:00
parent 06d69888fd
commit 95a74ee904
4 changed files with 17 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
PackedMessage.cpp
View File

@@ -20,7 +20,13 @@ PackedMessage::PackedMessage(MessagePointer msg, int type)
assert(msg_size);
mBuffer.resize(HEADER_SIZE + msg_size);
encodeHeader(msg_size,type);
if(msg_size) mMsg->SerializeToArray(&mBuffer[HEADER_SIZE], msg_size);
if(msg_size)
{
mMsg->SerializeToArray(&mBuffer[HEADER_SIZE], msg_size);
#ifdef DEBUG
std::cerr << "PackedMessage: type=" << type << ", datalen=" << msg_size << std::endl;
#endif
}
}
bool PackedMessage::operator == (const PackedMessage& other)

5
PackedMessage.h
View File

@@ -26,12 +26,13 @@ const unsigned HEADER_SIZE = 6;
class PackedMessage : public boost::enable_shared_from_this<PackedMessage>
{
std::vector<uint8_t> mBuffer;
// Encodes the size and type into a header at the beginning of buf
//
void encodeHeader(unsigned size, int type);
std::vector<uint8_t> mBuffer;
public:
typedef boost::shared_ptr< ::google::protobuf::Message > MessagePointer;
typedef boost::shared_ptr<PackedMessage> pointer;

6
Peer.cpp
View File

@@ -5,6 +5,8 @@
//#include <boost/log/trivial.hpp>
#include <boost/bind.hpp>
#include "json/writer.h"
#include "Peer.h"
#include "KnownNodeList.h"
#include "Config.h"
@@ -123,7 +125,7 @@ void Peer::processReadBuffer()
{
int type=PackedMessage::getType(mReadbuf);
#ifdef DEBUG
std::cerr << "PRB(" << type << ")" << std::endl;
std::cerr << "PRB(" << type << "), len=" << (mReadbuf.size()-HEADER_SIZE) << std::endl;
#endif
switch(type)
{
@@ -295,6 +297,8 @@ void Peer::recvTransaction(newcoin::TMTransaction& packet)
{ // transaction fails basic validity tests
#ifdef DEBUG
std::cerr << "Transaction from peer fails validity tests" << std::endl;
Json::StyledStreamWriter w;
w.write(std::cerr, tx->getJson(true));
#endif
return;
}

3
Transaction.cpp
View File

@@ -68,6 +68,7 @@ Transaction::Transaction(const std::vector<unsigned char> &t, bool validate) : m
mFromPubKey=theApp->getPubKeyCache().store(mAccountFrom, mFromPubKey);
updateID();
updateFee();
if(!validate || checkSign())
mStatus=NEW;
@@ -130,11 +131,11 @@ Serializer::pointer Transaction::getRaw(bool prefix) const
Serializer::pointer ret(new Serializer(77));
if(prefix) ret->add32(0x54584e00u);
ret->add160(mAccountTo);
ret->addRaw(mFromPubKey->GetPubKey());
ret->add64(mAmount);
ret->add32(mFromAccountSeq);
ret->add32(mSourceLedger);
ret->add32(mIdent);
ret->addRaw(mFromPubKey->GetPubKey());
assert( (prefix&&(ret->getLength()==77)) || (!prefix&&(ret->getLength()==73)) );
return ret;
}