---

MsgTransport.h

Go to the documentation of this file.

/*
 * MsgTransport.h
 *
 * Copyright 2003, MobileSpear Inc. (www.mobilespear.com). All rights reserved.
 * Copyright 2003, David Resnick. All rights reserved.
 *
 * See the file doc\license.txt for the terms of usage and distribution.
 */

#ifndef _BOGOTEL_MSGTRANSPORT_H
#define _BOGOTEL_MSGTRANSPORT_H

#include <boost/thread/mutex.hpp>
#include <boost/thread/condition.hpp>
#include <boost/thread/thread.hpp>

#include <gclib.h> // for CRN

#include <string>
#include <map>
#include <deque>

namespace bogotel {

    class CBgtRt;

    typedef std::map<long, std::string, std::less<long> > MAP_LONG2STR;
    typedef std::deque<std::string> DEQUE_STRING;

    #define INVALID_CRN 0

    enum MessageClass {
        MC_SIGNAL = 0,
        MC_VOICE,
        MC_INVALID
    } ;

    enum MessageType {
        MT_INVALID = 0,
        MT_MAKE_CALL,
        MT_ACCEPT_CALL,
        MT_ANSWER_CALL,
        MT_DROPCALL,
        MT_RELEASE_CALL,
        MT_PLAY_WAV,
        MT_PLAY_WAV_FINISHED,
        MT_PLAY_DTMF,
        MT_PLAY_DTMF_FINISHED
    } ;

    enum ParmType {
        PT_INVALID = 0,
        PT_ANI,
        PT_DNIS,
        PT_WAV_FILENAME,
        PT_DTMF
    } ;

    class CMsg
    {
    public:
        MessageType m_type;
        MessageClass m_class;
        long m_id;
        CRN m_crn;

        CMsg();
        virtual ~CMsg();
        void addParam(enum ParmType pt, std::string strParm);
        void addParam(enum ParmType pt, char *szParm);
        std::string getParam(enum ParmType pt);
        void clear();
        void init(MessageType type, MessageClass cls, long lId);
        char *toString(char *szDmp, size_t iDmpLen);
        int init(char *szMsg);
        void getMsgTypeString(char *szType, int iMaxLen);

    protected:
        MAP_LONG2STR m_mapParam;
    };

    class CMsgTransport  
    {
    public:
        CMsgTransport(CBgtRt *pBgtRt);
        virtual ~CMsgTransport();

        int init();
        int sendMsg(CMsg *pMsg);

        static void do_thread_listen(void* param);
        static void do_thread_talk(void* param);

        static int openListenerSocket(struct sockaddr_in *pAddr,int *pFd,u_short usPort);
    private:
        int openTalkerSocket();
        void runListener();
        void runTalker();

        boost::thread* m_pthrdListener;
        boost::thread* m_pthrdTalker;

        boost::mutex m_mtxStartup;
        boost::condition m_condStartup;
        bool m_bListenerStarted;

        bool m_bStopTalker;
        bool m_bStopListener;

        boost::mutex m_mtxDeque;

        boost::mutex m_mtxAddedToQueue;
        boost::condition m_condEvent;

        u_short m_usMyPort;
        u_short m_usOppPort;
        std::string m_strOppIp;
        CBgtRt *m_pBgtRt;
        DEQUE_STRING m_deqMsg;

        struct sockaddr_in m_addrListener;    /* my socket address information */
        int m_fdListener;

        struct sockaddr_in m_addrTalker;
        int m_fdTalker;

    };
}

#endif // ! _BOGOTEL_MSG_TRANSPORT_H

---