/***************************************************************
* StreamDevice record interface for analog input records       *
*                                                              *
* (C) 1999 Dirk Zimoch (zimoch@delta.uni-dortmund.de)          *
* (C) 2005 Dirk Zimoch (dirk.zimoch@psi.ch)                    *
*                                                              *
* This is an EPICS record Interface for StreamDevice.          *
* Please refer to the HTML files in ../doc/ for a detailed     *
* documentation.                                               *
*                                                              *
* If you do any changes in this file, you are not allowed to   *
* redistribute it any more. If there is a bug or a missing     *
* feature, send me an email and/or your patch. If I accept     *
* your changes, they will go to the next release.              *
*                                                              *
* DISCLAIMER: If this software breaks something or harms       *
* someone, it's your problem.                                  *
*                                                              *
***************************************************************/

#include "devStream.h"
#include <aiRecord.h>
#include <epicsExport.h>

static long readData (dbCommon *record, format_t *format)
{
    aiRecord *ai = (aiRecord *) record;

    switch (format->type)
    {
        case DBF_DOUBLE:
        {
            double val;
            if (streamScanf (record, format, &val)) return ERROR;
            if (ai->aslo != 0.0) val *= ai->aslo;
            val += ai->aoff;
            if (!INIT_RUN && ai->smoo != 0.0)
            {
                val = ai->val * ai->smoo + val * (1.0 - ai->smoo);
            }
            ai->val = val;
            return DO_NOT_CONVERT;
        }
        case DBF_LONG:
        {
            long rval;
            if (streamScanf (record, format, &rval)) return ERROR;
            ai->rval = rval;
            return OK;
        }
    }
    return ERROR;
}

static long writeData (dbCommon *record, format_t *format)
{
    aiRecord *ai = (aiRecord *) record;
    double val;

    switch (format->type)
    {
        case DBF_DOUBLE:
        {
            val = ai->val - ai->aoff;
            if (ai->aslo != 0) val /= ai->aslo;
            return streamPrintf (record, format, val);
        }
        case DBF_LONG:
        {
            return streamPrintf (record, format, (long) ai->rval);
        }
    }
    return ERROR;
}

static long initRecord (dbCommon *record)
{
    aiRecord *ai = (aiRecord *) record;

    return streamInitRecord (record, &ai->inp, readData, writeData) == ERROR ?
        ERROR : OK;
}

struct {
    long number;
    DEVSUPFUN report;
    DEVSUPFUN init;
    DEVSUPFUN init_record;
    DEVSUPFUN get_ioint_info;
    DEVSUPFUN read;
    DEVSUPFUN special_linconv;
} devaiStream = {
    6,
    streamReport,
    streamInit,
    initRecord,
    streamGetIointInfo,
    streamRead,
    NULL
};

epicsExportAddress(dset,devaiStream);