You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2007/12/17 12:01:04 UTC
svn commit: r604823 -
/incubator/qpid/trunk/qpid/cpp/src/qpid/client/ExecutionHandler.cpp
Author: gsim
Date: Mon Dec 17 03:01:02 2007
New Revision: 604823
URL: http://svn.apache.org/viewvc?rev=604823&view=rev
Log:
Fixed fragmentation (content bodies were 1 byte smaller than they could be due to including end of frame marker in the overhead)
Modified:
incubator/qpid/trunk/qpid/cpp/src/qpid/client/ExecutionHandler.cpp
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/client/ExecutionHandler.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/client/ExecutionHandler.cpp?rev=604823&r1=604822&r2=604823&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/client/ExecutionHandler.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/client/ExecutionHandler.cpp Mon Dec 17 03:01:02 2007
@@ -206,7 +206,7 @@
if(data_length > 0){
header.setEof(false);
out(header);
- u_int32_t frag_size = maxFrameSize - AMQFrame::frameOverhead();
+ u_int32_t frag_size = maxFrameSize - (AMQFrame::frameOverhead() - 1 /*end of frame marker included in overhead but not in size*/);
if(data_length < frag_size){
AMQFrame frame(in_place<AMQContentBody>(content.getData()));
frame.setBof(false);