jessequ
/
AMQP-CPP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fixed reallocation bug

This commit is contained in:
Emiel Bruijntjes 2016-06-22 13:49:49 +02:00
parent 2a0b0de409
commit 5e88fd3e75
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/tcpconnected.h
View File

@ -48,6 +48,13 @@ private:
*/ */
TcpInBuffer _in; TcpInBuffer _in;
/**
* Cached reallocation instruction
* @var size_t
*/
size_t _reallocate = 0;
/** /**
* Helper method to report an error * Helper method to report an error
* @return bool Was an error reported? * @return bool Was an error reported?
@ -162,6 +169,9 @@ public:
// restore the buffer as member // restore the buffer as member
_in = std::move(buffer); _in = std::move(buffer);
// do we have to reallocate?
if (_reallocate) { _in.reallocate(_reallocate); _reallocate = 0; }
} }
// keep same object // keep same object
@ -201,8 +211,8 @@ public:
*/ */
virtual uint16_t reportNegotiate(uint16_t heartbeat) override virtual uint16_t reportNegotiate(uint16_t heartbeat) override
{ {
// allocate a buffer that is big enough for the biggest possible frame // remember that we have to reallocated (_in member can not be accessed because it is moved away)
_in.reallocate(_connection->maxFrame()); _reallocate = _connection->maxFrame();
// pass to base // pass to base
return TcpState::reportNegotiate(heartbeat); return TcpState::reportNegotiate(heartbeat);