EPICS_driver_modules/StreamDevice
0
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Initial buffer size added

Browse Source
This commit is contained in:
zimoch
2010-09-29 07:21:14 +00:00
parent d987a9abb9
commit 2fa54cdfb1
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/StreamCore.cc
View File

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