/home/toby/moos-ivp/MOOS-2375-Oct0611/Core/MOOSGenLib/MOOSSerialPort.h

Go to the documentation of this file.

//
//   MOOS - Mission Oriented Operating Suite
//
//   A suit of Applications and Libraries for Mobile Robotics Research
//   Copyright (C) 2001-2005 Massachusetts Institute of Technology and
//   Oxford University.
//
//   This software was written by Paul Newman at MIT 2001-2002 and Oxford
//   University 2003-2005. email: pnewman@robots.ox.ac.uk.
//
//   This file is part of a  MOOS Core Component.
//
//   This program is free software; you can redistribute it and/or
//   modify it under the terms of the GNU General Public License as
//   published by the Free Software Foundation; either version 2 of the
//   License, or (at your option) any later version.
//
//   This program is distributed in the hope that it will be useful,
//   but WITHOUT ANY WARRANTY; without even the implied warranty of
//   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
//   General Public License for more details.
//
//   You should have received a copy of the GNU General Public License
//   along with this program; if not, write to the Free Software
//   Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
//   02111-1307, USA.
//
// MOOSSerialPort.h: interface for the CMOOSSerialPort class.
//

#if !defined(MOOSERIALPORTH)
#define MOOSSERIALPORTH

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000

#ifdef _WIN32
    #define DEFAULT_PORT  "COM1"
#else
    #define DEFAULT_PORT  "/dev/ttyS0"
#endif

#define DEFAULT_BAUDRATE 9600
#define TELEGRAM_LEN 1000

#include "MOOSLock.h"

#include <string>
#include <list>
//using namespace std;

typedef std::list<std::string> STRING_LIST;


class CMOOSSerialPort
{
public:
    std::string GetPortName();
    virtual bool Close();
    char GetTermCharacter();
    void SetTermCharacter(char cTermChar);
    int GetBaudRate(){return m_nBaudRate;};

    virtual int Flush(){return -1;};

    bool IsStreaming();
    bool IsVerbose(){return m_bVerbose;};
    bool GetLatest(std::string & sWhat,double & dfWhen);

    bool GetEarliest(std::string &sWhat, double &dfWhen);


    class CMOOSSerialTelegram
    {
    public:
        CMOOSSerialTelegram(const std::string & sWhat,double dfWhen):
          m_sTelegram(sWhat),m_dfTime(dfWhen){};

        std::string m_sTelegram;
        double m_dfTime;
    };
    typedef std::list<CMOOSSerialTelegram> TELEGRAM_LIST;

    TELEGRAM_LIST m_InBox;
    TELEGRAM_LIST m_OutBox;
    CMOOSLock m_InBoxLock;
    CMOOSLock m_OutBoxLock;
    CMOOSLock m_PortLock;

    bool CommsLoop();

    CMOOSSerialPort();
    virtual ~CMOOSSerialPort();


    virtual bool Configure(STRING_LIST sParams);

    //crucial functions...
    virtual bool Create(const char * pPortNum=DEFAULT_PORT, int nBaudRate=DEFAULT_BAUDRATE)=0;
    virtual int  ReadNWithTimeOut(char * pBuff, int  nBufferLen,double Timeout=0.5, double* pTime = NULL);
    virtual int  Write(const char* Str,int nLen, double* pTime=NULL)=0;

    //returns a complete telegram in sTelegram (block of terminated characters)
    bool GetTelegram(std::string &sTelegram,double dfTimeOut,double *pTime=NULL);
    
    bool GetTelegramOrAccumulate(std::string &sTelegram,double dfTimeOut,double *pTime=NULL);
    
    // This version of ReadNWithTimeOut returns a negative value to signal an error
    virtual int  ReadNWithTimeOut2(char * pBuff, int nBufferLen, double Timeout=0.5, double* pTime = NULL);

    void SetIsCompleteReplyCallBack(bool (*pfn)(char *pData, int nLen, int nRead) );

    virtual void Break();

protected:
    //termination character the serial port is interested in
    char m_cTermCharacter;

#ifdef _WIN32
    HANDLE m_hCommsThread;
#endif


#ifdef _WIN32
    typedef unsigned long THREAD_ID;
#else
    typedef pthread_t THREAD_ID;
#endif


    THREAD_ID        m_nCommsThreadID;


    bool StartThreads();

    bool m_bStreaming;

    bool m_bVerbose;

    virtual int GrabN(char * pBuffer,int nRequired)=0;

    bool (*m_pfnUserIsCompleteReplyCallBack)( char *pData, int nLen, int nRead);

    bool IsCompleteReply(char * pData,int nLen, int nRead);

       bool m_bHandShaking;

    std::string m_sPort;

    int m_nBaudRate;

    bool m_bQuit;

        bool m_bUseCsmExt;

};

#endif //