Beesnest/Adapters/BnSerialPort/BnSerialPort.cpp

Go to the documentation of this file.

#include "BnSerialPort.h"


BnSerialPort::BnSerialPort (const char* name, bool (*pGetParam)(const char*, char*, int))
:nLastErrCode (0), isInitErr (false), hPort (NULL)
{
    sName = name;
    pfGetParam = pGetParam;

    /* Get parameters. */
    char path[100];
    char val[100] = {0};

    sprintf (path, "Adapters->%s->COM", name);
    if (pGetParam (path, val, 9))
        sPortName = val;
    else
        sPortName = DEFAULT_PORT;

    sprintf (path, "Adapters->%s->Settings", name);
    if (pGetParam (path, val, 99))
        sPortSettings = val;
    else
        sPortSettings = DEFAULT_SETTINGS;
    if ((hPort = CreateFile (sPortName.c_str (), GENERIC_READ | GENERIC_WRITE,
        0, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL)) == NULL)
    {
        nLastErrCode = GetLastError ();
        isInitErr = true;
        return;
    }
    /* Open the port. */
    DCB param;
    if (GetCommState (hPort, &param) == 0)
    {
        nLastErrCode = GetLastError ();
        isInitErr = true;
        return;
    }
    if (BuildCommDCB (sPortSettings.c_str (), &param) == 0)
    {
        nLastErrCode = GetLastError ();
        isInitErr = true;
        return;
    }
    param.DCBlength = sizeof param;
    if (SetCommState (hPort, &param) == 0)
    {
        nLastErrCode = GetLastError ();
        isInitErr = true;
        return;
    }
    /* Set timeouts. */
    oTimes.ReadTotalTimeoutConstant = 0;
    oTimes.ReadTotalTimeoutMultiplier = 0;
    oTimes.ReadIntervalTimeout = 0;
    oTimes.WriteTotalTimeoutConstant = 0;
    oTimes.WriteTotalTimeoutMultiplier = 0;

    sprintf (path, "Adapters->%s->Read-Interval-Timeout", name);
    if (pGetParam (path, val, 9))
        oTimes.ReadIntervalTimeout = atoi (val);
    sprintf (path, "Adapters->%s->Read-Total-Timeout-Multiplier", name);
    if (pGetParam (path, val, 9))
        oTimes.ReadTotalTimeoutMultiplier = atoi (val);
    sprintf (path, "Adapters->%s->Read-Total-Timeout-Constant", name);
    if (pGetParam (path, val, 9))
        oTimes.ReadTotalTimeoutConstant = atoi (val);
    sprintf (path, "Adapters->%s->Write-Total-Timeout-Multiplier", name);
    if (pGetParam (path, val, 9))
        oTimes.WriteTotalTimeoutMultiplier = atoi (val);
    sprintf (path, "Adapters->%s->Write-Total-Timeout-Constant", name);
    if (pGetParam (path, val, 9))
        oTimes.WriteTotalTimeoutConstant = atoi (val);

    if (SetCommTimeouts (hPort, &oTimes) == 0)
    {
        nLastErrCode = GetLastError ();
        isInitErr = true;
    }
}

BnSerialPort::~BnSerialPort ()
{
    ClosePort ();
}

void BnSerialPort::ClosePort ()
{
    if (IsPortOpen ())
    {
        nLastErrCode = CloseHandle (hPort);
        hPort = NULL;
    }
}

void BnSerialPort::AddLastErrorCode ()
{
    if (nLastErrCode)
    {
        char buff [50];
        sprintf (buff, " Error Number: %d", nLastErrCode);
        sRetMsg += buff;
    }
}

BufferHolder BnSerialPort::Read (BufferHolder address) throw (BufferHolder)
{
    if (isInitErr)
    {   /* If Init failed throw an exception. */
        sRetMsg = "Cannot open " + sPortName;
        AddLastErrorCode ();
        throw BufferHolder (sRetMsg.c_str ());
    }

    sRetMsg.clear ();

    if (address.empty ())
    {
        char buff[100];
        unsigned long ret;
        do
        {
            ReadFile (hPort, buff, 99, &ret, NULL);
            buff [ret] = 0;
            sRetMsg += buff;
        }
        while (ret > 0);
        nLastErrCode = GetLastError ();
        return BufferHolder (sRetMsg.c_str ());
    }

    string cmd (address.pointer, address.size);
    if (cmd == "_LastError")
    {
        if (!nLastErrCode)
            sRetMsg = "OK";
        else
            AddLastErrorCode ();
    }

    return BufferHolder (sRetMsg.c_str ());
}

bool BnSerialPort::Write (BufferHolder address, BufferHolder value) throw (BufferHolder)
{
    if (isInitErr)
    {   /* If Init failed throw an exception. */
        sRetMsg = "Cannot open " + sPortName;
        AddLastErrorCode ();
        throw BufferHolder (sRetMsg.c_str ());
    }

    if (address.empty ()) return false;
    unsigned long ret;
    nLastErrCode = 0;
    WriteFile (hPort, address.pointer, address.size, &ret, NULL);
    if (ret == 0)
        nLastErrCode = GetLastError ();
    return nLastErrCode == 0;
}