EchoLinkQso.h

Go to the documentation of this file.

#ifndef ECHOLINK_QSO_INCLUDED
#define ECHOLINK_QSO_INCLUDED


/****************************************************************************
 *
 * System Includes
 *
 ****************************************************************************/

#include <sys/time.h>
#include <sigc++/signal_system.h>
#include <string>


/****************************************************************************
 *
 * Project Includes
 *
 ****************************************************************************/

extern "C" {
#include <gsm.h>
}
#include <AsyncTimer.h>
#include <AsyncIpAddress.h>


/****************************************************************************
 *
 * Local Includes
 *
 ****************************************************************************/



/****************************************************************************
 *
 * Forward declarations
 *
 ****************************************************************************/



/****************************************************************************
 *
 * Namespace
 *
 ****************************************************************************/

namespace EchoLink
{

/****************************************************************************
 *
 * Forward declarations inside the declared namespace
 *
 ****************************************************************************/



/****************************************************************************
 *
 * Defines & typedefs
 *
 ****************************************************************************/



/****************************************************************************
 *
 * Exported Global Variables
 *
 ****************************************************************************/



/****************************************************************************
 *
 * Class definitions
 *
 ****************************************************************************/

class Qso : public SigC::Object
{
  public:
    class GsmVoicePacket
    {
      public:
        unsigned char version;
        unsigned char pt;
        unsigned short seqNum;
        unsigned long time;
        unsigned long ssrc;
        unsigned char data[33*4];
    };

    typedef enum
    {
      STATE_DISCONNECTED, 
      STATE_CONNECTING,   
      STATE_BYE_RECEIVED, 
      STATE_CONNECTED     
    } State;
  
    Qso(const Async::IpAddress& ip, const std::string& callsign="",
        const std::string& name="", const std::string& info="");
    
    ~Qso(void);
  
    bool initOk(void) { return init_ok; }
    
    bool setLocalCallsign(const std::string& callsign);
    
    const std::string& localCallsign(void) const { return callsign; }
    
    bool setLocalName(const std::string& name);

    const std::string& localName(void) const { return name; }
    
    void setLocalInfo(const std::string& info);
        
    const std::string& localInfo(void) const { return local_stn_info; }
    
    bool connect(void);
    
    bool accept(void);
    
    bool disconnect(void);
    
    bool sendInfoData(const std::string& info="");
    
    bool sendChatData(const std::string& msg);
    
    const Async::IpAddress& remoteIp(void) const
    {
      return remote_ip;
    }
    
    int sendAudio(short *buf, int len);
    
    bool sendAudioRaw(GsmVoicePacket *packet);
    
    bool flushAudioSendBuffer(void);
    
    void setRemoteName(const std::string& name) { remote_name = name; }
    
    const std::string& remoteName(void) const { return remote_name; }
    
    void setRemoteCallsign(const std::string& call) { remote_call = call; }
    
    const std::string& remoteCallsign(void) const { return remote_call; }
    
    bool isRemoteInitiated(void) const { return is_remote_initiated; }
    
    bool receivingAudio(void) const { return receiving_audio; }
    
    SigC::Signal1<void, const std::string&> infoMsgReceived;
    
    SigC::Signal1<void, const std::string&> chatMsgReceived;
    
    SigC::Signal1<void, State> stateChange;
    
    SigC::Signal1<void, bool> isReceiving;
    
    SigC::Signal2<int, short*, int> audioReceived;
    
    SigC::Signal1<void, GsmVoicePacket*>  audioReceivedRaw;
    
    
  protected:
    
  private:
    static const int    KEEP_ALIVE_TIME         = 10000;
    static const int    MAX_CONNECT_RETRY_CNT   = 5;
    static const int    CON_TIMEOUT_TIME        = 50000;
    static const int    RX_INDICATOR_HANG_TIME  = 200;
    static const int    SEND_BUFFER_SIZE        = 4*160; // Four 20ms GSM frames
  
    bool                init_ok;
    char *              sdes_packet;
    int                 sdes_length;
    State               state;
    gsm                 gsmh;
    unsigned short      next_audio_seq;
    Async::Timer *      keep_alive_timer;
    int                 connect_retry_cnt;
    Async::Timer *      con_timeout_timer;
    std::string         callsign;
    std::string         name;
    std::string         local_stn_info;
    gsm_signal          send_buffer[SEND_BUFFER_SIZE];
    int                 send_buffer_cnt;
    Async::IpAddress    remote_ip;
    Async::Timer *      rx_indicator_timer;
    struct timeval      last_audio_packet_received;
    std::string         remote_name;
    std::string         remote_call;
    bool                is_remote_initiated;
    bool                receiving_audio;

    Qso(const Qso&);
    Qso& operator=(const Qso&);
    void printData(const unsigned char *buf, int len);
    void handleCtrlInput(unsigned char *buf, int len);
    inline void handleByePacket(unsigned char *buf, int len);
    inline void handleSdesPacket(unsigned char *buf, int len);
    void handleAudioInput(unsigned char *buf, int len);
    inline void handleNonAudioPacket(unsigned char *buf, int len);
    inline void handleAudioPacket(unsigned char *buf, int len);
    void micAudioRead(void *buf, size_t len);
    bool sendSdesPacket(void);
    void sendKeepAlive(Async::Timer *timer);
    void setState(State state);
    void connectionTimeout(Async::Timer *timer);
    bool setupConnection(void);
    void cleanupConnection(void);
    bool sendGsmPacket(void);
    void checkRxActivity(Async::Timer *timer);
    bool sendByePacket(void);

    
};  /* class Qso */


} /* namespace */

#endif /* ECHOLINK_QSO_INCLUDED */



/*
 * This file has not been truncated
 */

---