SerialPort.cpp

Go to the documentation of this file.

#include <dcl/Config.h>
 
#ifdef __WINNT__
    #include <windows.h>
#else
    #include <dcl/_unistd.h>
#endif
 
#include <dcl/SerialPort.h>
 
#if __DCL_HAVE_THIS_FILE__
#undef __THIS_FILE__
static const char_t __THIS_FILE__[] = __T("dcl/SerialPort.cpp");
#endif
 
__DCL_BEGIN_NAMESPACE
 
IMPLEMENT_CLASSINFO(SerialPort, PollAble)
 
#ifndef INVALID_HANDLE_VALUE
#define INVALID_HANDLE_VALUE    -1
#endif
 
SerialPort::~SerialPort()
{
#ifdef __WINNT__
    if (__overlapped.hEvent != NULL)
        CloseHandle(__overlapped.hEvent);
#endif
}
 
SerialPort::SerialPort(const String& _path, int _oflags,
    size_t _inQueue, size_t _outQueue
) __DCL_THROWS1(IOException*)
{
#ifdef __WINNT__
    __revents = 0;
    ZeroMemory(&__overlapped, sizeof(__overlapped));
#endif
    open(_path, _oflags, _inQueue, _outQueue);
}
 
void SerialPort::open(const String& _path, int _oflags,
    size_t _inQueue, size_t _outQueue
) __DCL_THROWS1(IOException*)
{
    File::open(_path, _oflags | File::NOCTTY);
 
#ifdef __WINNT__
    __DCL_ASSERT_PARAM(_inQueue > 0 && _outQueue > 0);
    do {
        if (!SetupComm(__handle, (DWORD)_inQueue, (DWORD)_outQueue))
            break;
 
        if (_oflags & File::NONBLOCK) {
            /*
            if (!SetCommMask(__handle, EV_RXCHAR))
                break;
            */
 
            // set read non-blocking
            COMMTIMEOUTS cto;
            if (!GetCommTimeouts(__handle, &cto))
                break;
 
            cto.ReadIntervalTimeout = MAXDWORD;
            cto.ReadTotalTimeoutConstant = 0;
            cto.ReadTotalTimeoutMultiplier = 0;
            if (!SetCommTimeouts(__handle, &cto))
                break;
        }
 
        // success
        return;
    } while (false);
 
    // failed
    DWORD dwSaveError = GetLastError();
    try {
        close();
    }
    catch (Exception* cause) {
        cause->destroy();
    }
    throw new IOException(_path, dwSaveError);
#endif
}
 
void SerialPort::setAttributes(
    SerialPort::BaudRate _baudRate,         // BR_9600
    SerialPort::ByteSize _byteSize,         // BS_8NO
    SerialPort::StopBits _stopBits,         // SB_1
    SerialPort::FlowControl _flowControl    // FC_NONE
) __DCL_THROWS1(IOException*)
{
#ifdef __WINNT__
    DCB dcb;
    ZeroMemory(&dcb, sizeof(dcb));
    dcb.DCBlength = sizeof(dcb);
    if (!GetCommState(__handle, &dcb))
        throw new IOException(toString(), GetLastError());
 
    dcb.BaudRate = _baudRate;
    switch (_byteSize) {
        case SerialPort::BS_8NO:
            dcb.ByteSize = 8;
            dcb.Parity = NOPARITY;
            break;
        case SerialPort::BS_7EVEN:
            dcb.ByteSize = 7;
            dcb.Parity = EVENPARITY;
            break;
        case SerialPort::BS_7ODD:
            dcb.ByteSize = 7;
            dcb.Parity = ODDPARITY;
            break;
    }
    dcb.fParity = dcb.Parity != NOPARITY;
 
    switch (_stopBits) {
        case SB_1:
            dcb.StopBits = ONESTOPBIT;
            break;
        case SB_2:
            dcb.StopBits = TWOSTOPBITS;
            break;
    }
 
    switch (_flowControl) {
        case FC_RTSCTS :
            dcb.fOutxCtsFlow = TRUE;
            dcb.fRtsControl = RTS_CONTROL_HANDSHAKE;
            break;
        case FC_XONXOFF :
            dcb.fOutX = dcb.fInX = TRUE;
            break;
        case FC_NONE:
            ;
    }
 
    if (!SetCommState(__handle, &dcb))
        throw new IOException(toString(), GetLastError());
    // success
#else
    /*
    Ref erence
        - Serial Programming Guide for POSIX Operation Systems.
            http://www.easysw.com/~mike/serial/serial.html
        - http://en.wikibooks.org/wiki/Serial_Programming/termios
        - man termiso(3)
        - 리눅스에서 시리얼통신(II).
            http://www.lug.or.kr/docs/LINUX/others/00-05-5.htm
    */
 
    struct termios config;
    if (tcgetattr(__handle, &config))
        throw new IOException(toString(), errno);
 
    // Raw mode , man 3 termios
    config.c_iflag &= ~(IGNBRK | BRKINT | PARMRK | ISTRIP
                           | INLCR | IGNCR | ICRNL | IXON);
    config.c_oflag &= ~OPOST;
    config.c_lflag &= ~(ECHO | ECHONL | ICANON | ISIG | IEXTEN);
 
    config.c_cflag |= CLOCAL | CREAD;
 
    // Flow Control
#ifdef CRTSCTS      // not in POSIX
    config.c_cflag &= ~CRTSCTS;
#endif
    config.c_iflag &= ~(IXON | IXOFF | IXANY);
    switch (_flowControl) {
        case SerialPort::FC_NONE :
            break;
        case SerialPort::FC_RTSCTS :
#ifdef CRTSCTS
            config.c_cflag |= CRTSCTS;
#endif
            break;
        case SerialPort::FC_XONXOFF :
            config.c_iflag |= IXON | IXOFF;
            break;
        default :
            __DCL_ASSERT(false);
    }
 
    // Stop Bits
    if (_stopBits == SerialPort::SB_1)
        config.c_cflag &= ~CSTOPB;
    else
        config.c_cflag |= CSTOPB;
 
    // Byte Size
    switch (_byteSize) {
        case SerialPort::BS_8NO :       // 8Bit, No parity
            config.c_iflag &= ~INPCK;   // enable input parity check
            config.c_cflag &= ~(CSIZE | PARENB);
            config.c_cflag |= CS8;
            break;
        case SerialPort::BS_7EVEN :     // 7Bit, Even parity
            config.c_iflag |= INPCK;
            config.c_cflag &= ~(CSIZE | PARODD);
            config.c_cflag |= CS7 | PARENB;
            break;
        case SerialPort::BS_7ODD :      // 7Bit, Odd parity
            config.c_iflag |= INPCK;
            config.c_cflag &= ~CSIZE;
            config.c_cflag |= CS7 | PARENB | PARODD;
            break;
        default :
            __DCL_ASSERT(false);
    }
 
    cfsetispeed(&config, _baudRate);
    cfsetospeed(&config, _baudRate);
 
    config.c_cc[VMIN] = 1;
    config.c_cc[VTIME] = 5;         // 5/10 초
 
    if (tcsetattr(__handle, TCSANOW, &config))
        throw new IOException(toString(), errno);
 
    // success
#endif
}
 
void SerialPort::purge(int _flags)
    __DCL_THROWS1(IOException*)
{
    __DCL_ASSERT_HANDLE(__handle != INVALID_HANDLE_VALUE);
    __DCL_ASSERT_PARAM(1 <= _flags && _flags <= 3);
 
#ifdef __WINNT__
    if (!PurgeComm(__handle,
        (_flags & PURGE_RX ? PURGE_RXABORT | PURGE_RXCLEAR : 0)
        | (_flags & PURGE_TX ? PURGE_TXABORT | PURGE_TXCLEAR : 0)))
        throw new IOException(toString(), GetLastError());
 
#else
    if (tcflush(__handle, --_flags))
        throw new IOException(toString(), errno);
 
#endif
}
 
bool SerialPort::access(const String& _path)
{
#ifdef __WINNT__
    SECURITY_ATTRIBUTES securityAttributes = { sizeof(SECURITY_ATTRIBUTES), NULL, TRUE };
    HANDLE handle = CreateFileW(
        _path,                          // __in     LPCTSTR lpFileName,
        GENERIC_READ | GENERIC_WRITE,   // __in     DWORD dwDesiredAccess,
        0,                              // __in     DWORD dwShareMode,
        &securityAttributes,            // __in     LPSECURITY_ATTRIBUTES lpSecurityAttributes,
        OPEN_EXISTING,                  // __in     DWORD dwCreationDisposition,
        0,                              // __in     DWORD dwFlagsAndAttributes,
        NULL                            // __in     HANDLE hTemplateFile
        );
    if (handle != INVALID_HANDLE_VALUE) {
        CloseHandle(handle);
        return true;
    }
    return false;
 
#else
    return  __access(_path, R_OK | W_OK);
 
#endif
}
 
bool SerialPort::onEvent(short _events, PollThread* _pPollThread)
    __DCL_THROWS1(IOException*)
{
    return true;
}
 
#ifdef __WINNT__
// used only SerialPollThread
bool SerialPort::waitCommEvent()
{
    __DCL_ASSERT(__overlapped.hEvent != NULL);
 
    __overlapped.Internal = 0;
    __overlapped.InternalHigh = 0;
    __overlapped.Offset = 0;
    __overlapped.OffsetHigh = 0;
 
    // VS 2008의 디버깅 추적에서 이 문장이 지나고 나면 메모리 문제를 보고한다.
    // 여기서 리턴을 해도 여전히 문제가 있는 것으로 추정된다.
    // 2011-04-26
    if (::WaitCommEvent(handle(),  &__revents,    &__overlapped)) {
        SetEvent(__overlapped.hEvent);
        return true;
    }
 
    if (GetLastError() == ERROR_IO_PENDING)
        return true;
 
    __DCL_TRACE1(__T("WaitCommEvent: %d\n"), GetLastError());
    return false;
}
#endif
 
__DCL_END_NAMESPACE