svn commit: r561877 - /incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AsynchIOAcceptor.cpp

[as...@apache.org]

Author: astitcher
Date: Wed Aug  1 10:17:06 2007
New Revision: 561877

URL: http://svn.apache.org/viewvc?view=rev&rev=561877
Log:
Recoded writing code so that it doesn't allocate framing::Buffer on the heap

Modified:
    incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AsynchIOAcceptor.cpp

Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AsynchIOAcceptor.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AsynchIOAcceptor.cpp?view=diff&rev=561877&r1=561876&r2=561877
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AsynchIOAcceptor.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/sys/AsynchIOAcceptor.cpp Wed Aug  1 10:17:06 2007
@@ -190,7 +190,7 @@
 	if (!frameQueueClosed)
 		frameQueue.push(frame);
 	}
-	
+
 	// Activate aio for writing here
 	aio->queueWrite();
 }
@@ -263,46 +263,40 @@
 		return;
 	}
 	
-	// Try and get a queued buffer if not then construct new one
-	AsynchIO::Buffer* buff = aio->getQueuedBuffer();
-	if (!buff)
-		buff = new Buff;
-	std::auto_ptr<framing::Buffer> out(new framing::Buffer(buff->bytes, buff->byteCount));
-	int buffUsed = 0;
-
-	while (!frameQueue.empty()) {
+	do {
+		// Try and get a queued buffer if not then construct new one
+		AsynchIO::Buffer* buff = aio->getQueuedBuffer();
+		if (!buff)
+			buff = new Buff;
+		framing::Buffer out(buff->bytes, buff->byteCount);
+		int buffUsed = 0;
+	
 		framing::AMQFrame frame = frameQueue.front();
-		frameQueue.pop();
-
-		// Encode output frame
 		int frameSize = frame.size();
+		while (frameSize <= int(out.available())) {
+			frameQueue.pop();
+	
+			// Encode output frame	
+			frame.encode(out);
+			buffUsed += frameSize;
+			QPID_LOG(debug, "SENT: " << frame);
+			
+			if (frameQueue.empty())
+				break;
+			frame = frameQueue.front();
+			frameSize = frame.size();
+		}
+		// If frame was egregiously large complain
 		if (frameSize > buff->byteCount)
 			THROW_QPID_ERROR(FRAMING_ERROR, "Could not write frame, too large for buffer.");
-		
-		// If we've filled current buffer then flush and get new one
-		if (frameSize > int(out->available())) {
-			buff->dataCount = buffUsed;
-			aio->queueWrite(buff);
-
-			buff = aio->getQueuedBuffer();
-			if (!buff)
-				buff = new Buff;
-			out.reset(new framing::Buffer(buff->bytes, buff->byteCount));
-			buffUsed = 0;			
-		}
-
-		frame.encode(*out);
-		buffUsed += frameSize;
-		QPID_LOG(debug, "SENT: " << frame);
-	}
-
-	buff->dataCount = buffUsed;
-	aio->queueWrite(buff);
+	
+		buff->dataCount = buffUsed;
+		aio->queueWrite(buff);
+	} while (!frameQueue.empty());
 
 	if (frameQueueClosed) {
 		aio->queueWriteClose();
 	}
-	
 }
 
 }} // namespace qpid::sys