THRIFT-926. cpp: Revert r750153 to make way for more flexible version
r750153 caused TNonblockingServer to reset its buffers every 512 calls.
A more configurable version was developed internally, so I'm reverting
this rev first to avoid conflicts.
git-svn-id: https://svn.apache.org/repos/asf/incubator/thrift/trunk@1005163 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/lib/cpp/src/server/TNonblockingServer.cpp b/lib/cpp/src/server/TNonblockingServer.cpp
index 6297030..73edd93 100644
--- a/lib/cpp/src/server/TNonblockingServer.cpp
+++ b/lib/cpp/src/server/TNonblockingServer.cpp
@@ -246,24 +246,8 @@
case APP_READ_REQUEST:
// We are done reading the request, package the read buffer into transport
// and get back some data from the dispatch function
- // If we've used these transport buffers enough times, reset them to avoid bloating
-
inputTransport_->resetBuffer(readBuffer_, readBufferPos_);
- ++numReadsSinceReset_;
- if (numWritesSinceReset_ < 512) {
- outputTransport_->resetBuffer();
- } else {
- // reset the capacity of the output transport if we used it enough times that it might be bloated
- try {
- outputTransport_->resetBuffer(true);
- numWritesSinceReset_ = 0;
- } catch (TTransportException &ttx) {
- GlobalOutput.printf("TTransportException: TMemoryBuffer::resetBuffer() %s", ttx.what());
- close();
- return;
- }
- }
-
+ outputTransport_->resetBuffer();
// Prepend four bytes of blank space to the buffer so we can
// write the frame size there later.
outputTransport_->getWritePtr(4);
@@ -359,27 +343,11 @@
case APP_SEND_RESULT:
- ++numWritesSinceReset_;
-
// N.B.: We also intentionally fall through here into the INIT state!
LABEL_APP_INIT:
case APP_INIT:
- // reset the input buffer if we used it enough times that it might be bloated
- if (numReadsSinceReset_ > 512)
- {
- void * new_buffer = std::realloc(readBuffer_, 1024);
- if (new_buffer == NULL) {
- GlobalOutput("TConnection::transition() realloc");
- close();
- return;
- }
- readBuffer_ = (uint8_t*) new_buffer;
- readBufferSize_ = 1024;
- numReadsSinceReset_ = 0;
- }
-
// Clear write buffer variables
writeBuffer_ = NULL;
writeBufferPos_ = 0;