Experimental Physics and
Industrial Control System

Thanks,
Dirk

Hello all,

I ran into a problem when reading from a serial device using I/O Intr processing with streamDevice.
The device sends a string every 100 ms and this string is converted into numbers using scalcout record ( silly spaces between sign and numbers fail ai record conversion).
The conversion works, but depending on the poll period, I loose a lot of strings.
If using a poll period of 50 ms, I get none conversions at all.
100 ms poll period converts about every other string, 500ms poll period converts 4-5 strings every 500 ms.

This is the db:
record (scalcout, "VRZ720:$(host)$(port)02") {
    field (DTYP, "stream")
    field (OUT,  "@VRZ720.proto getYAxis VRZ01")
    field (SCAN, "I/O Intr")
         field (CALC, "AA=='-'?-1*A:A")
}

This is the protocol:
InTerminator = LF LF;
PollPeriod = 50;
ReadTimeout = 30;
getYAxis {
in "X=%*[+-]%*f%*[ RDrd]\r\nY=%(AA)[+-]%(A)f%*[ RDrd]\r";
}

This is an example string, which is sent to the device every 100ms.
X=- 757.4302 R\r\nY=-  75.6267 R\r\n\n

The problem is caused by the first call to pasynOctet->read with readTimeout 0 if EOS is set.
If using eos asynInterposeEos will return asynTimeout even if some characters have been
received, but not yet the eos-string. The timeout aborts the stream protocol and the partial string is discarded. If using a long poll period chances grow, that a full string is in the
buffer at the first read which will be properly processed. But you don't want to process
only once a second, if strings are delivered every 100 ms.

If preventing the stream protocol from aborting, even if the first read is a timeout, allows to read again and accumulate partial strings until eos is received.
The second call to pasynOctet->read has timeout=ReadTimeout, which must be long
enough to read the full string.
I attached a patch (which hopefully doesn't break existing code) to do this.

Jens

--- old/AsynDriverInterface.cc  2010-01-08 16:46:59.870812999 +0100
+++ new/AsynDriverInterface.cc  2010-01-08 17:05:33.404224396 +0100
@@ -807,6 +807,11 @@
         }
         // pasynOctet->read() has already cut off terminator.

+ // Timeout is considered success, if reading with EOS in AsyncRead
+ // mode and at least one octet was received
+ if ((status == asynTimeout) && streameos && (ioAction == AsyncReadMore))
+ status = asynSuccess;
+
switch (status)
{
case asynSuccess:
@@ -823,7 +828,16 @@
// ignore what we got from here.
// input was already handeled by asynReadHandler()
// read until no more input is available
- readMore = -1;
+ if (streameoslen && (eomReason & ASYN_EOM_EOS)){
+ if (replyTimeout != 0.0) {
+ ioAction = AsyncRead;
+ startTimer(replyTimeout);
+ }
+ readMore = 0;
+ }
+ else {
+ readMore = -1;
+ }
break;
}
#ifndef NO_TEMPORARY

References:

streamDevice and I/O Intr processing Jens . Eden

Navigate by Date:

Prev: Software Architect Position at the Thirty Meter Telescope Corinne Boyer

Next: Device support for Intelligent Instrumentation EDAS-1000 Rod Nussbaumer

Index: 1994  1995  1996  1997  1998  1999  2000  2001  2002  2003  2004  2005  2006  2007  2008  2009  <2010>  2011  2012  2013  2014  2015  2016  2017  2018  2019  2020  2021  2022  2023  2024 

Navigate by Thread:

Prev: streamDevice and I/O Intr processing Jens . Eden

Next: 2 Group Leader openings at the APS Andrew Johnson

Index: 1994  1995  1996  1997  1998  1999  2000  2001  2002  2003  2004  2005  2006  2007  2008  2009  <2010>  2011  2012  2013  2014  2015  2016  2017  2018  2019  2020  2021  2022  2023  2024