From 2fa54cdfb1dfdefe477d24d3dad8fd9cac480d28 Mon Sep 17 00:00:00 2001
From: zimoch <zimoch>
Date: Wed, 29 Sep 2010 07:21:14 +0000
Subject: [PATCH] Initial buffer size added

---
 src/StreamCore.cc | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/StreamCore.cc b/src/StreamCore.cc
index 17bc0bd..f9e5e40 100644
--- a/src/StreamCore.cc
+++ b/src/StreamCore.cc
@@ -245,6 +245,7 @@ compile(StreamProtocolParser::Protocol* protocol)
     inTerminatorDefined = false;
     outTerminatorDefined = false;
     
+    unsigned long bufferSize = 0;
     unsigned short ignoreExtraInput = false;
     if (!protocol->getEnumVariable("extrainput", ignoreExtraInput,
         extraInputNames))
@@ -259,10 +260,12 @@ compile(StreamProtocolParser::Protocol* protocol)
         protocol->getNumberVariable("maxinput", maxInput) &&
         // use replyTimeout as default for pollPeriod
         protocol->getNumberVariable("replytimeout", pollPeriod) &&
-        protocol->getNumberVariable("pollperiod", pollPeriod)))
+        protocol->getNumberVariable("pollperiod", pollPeriod) &&
+        protocol->getNumberVariable("buffersize", bufferSize)))
     {
         return false;
     }
+    inputBuffer.grow(bufferSize);
     if (!(protocol->getStringVariable("terminator", inTerminator, &inTerminatorDefined) &&
         protocol->getStringVariable("terminator", outTerminator, &outTerminatorDefined) &&
         protocol->getStringVariable("interminator", inTerminator, &inTerminatorDefined) &&