capi_ep.h

Go to the documentation of this file.

/*
 * capi_ep.h
 *
 * ISDN via CAPI EndPoint
 *
 * Open Phone Abstraction Library
 *
 * Copyright (c) 2010 Vox Lucida Pty. Ltd.
 *
 * The contents of this file are subject to the Mozilla Public License
 * Version 1.0 (the "License"); you may not use this file except in
 * compliance with the License. You may obtain a copy of the License at
 * http://www.mozilla.org/MPL/
 *
 * Software distributed under the License is distributed on an "AS IS"
 * basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
 * the License for the specific language governing rights and limitations
 * under the License.
 *
 * The Original Code is Open H323 Library.
 *
 * The Initial Developer of the Original Code is Vox Lucida Pty. Ltd.
 *
 * Contributor(s): ______________________________________.
 *
 * $Revision: 31407 $
 * $Author: rjongbloed $
 * $Date: 2014-02-07 18:19:26 +1100 (Fri, 07 Feb 2014) $
 */

#ifndef OPAL_LIDS_CAPI_EP_H
#define OPAL_LIDS_CAPI_EP_H

#ifdef P_USE_PRAGMA
#pragma interface
#endif

#include <opal_config.h>

#if OPAL_CAPI

#include <opal/endpoint.h>
#include <ptclib/qchannel.h>


class OpalCapiFunctions;
class OpalCapiConnection;
struct OpalCapiMessage;


#define OPAL_OPT_CAPI_B_PROTO  "B-Proto"  


class OpalCapiEndPoint : public OpalEndPoint
{
  PCLASSINFO(OpalCapiEndPoint, OpalEndPoint);

  public:
    OpalCapiEndPoint(
      OpalManager & manager   
    );

    ~OpalCapiEndPoint();

    virtual PSafePtr<OpalConnection> MakeConnection(
      OpalCall & call,          
      const PString & party,    
      void * userData = NULL,   
      unsigned int options = 0,  
      OpalConnection::StringOptions * stringOptions  = NULL 
    );

    virtual OpalMediaFormatList GetMediaFormats() const;

    virtual OpalCapiConnection * CreateConnection(
      OpalCall & call,        
      void * userData,        
      unsigned int options,     
      OpalConnection::StringOptions * stringOptions, 
      unsigned controller,
      unsigned bearer
    );

    unsigned OpenControllers();

    PString GetDriverInfo() const;



  protected:
    bool GetFreeLine(unsigned & controller, unsigned & bearer);
    PDECLARE_NOTIFIER(PThread, OpalCapiEndPoint, ProcessMessages);
    virtual void ProcessMessage(const OpalCapiMessage & message);
    void ProcessConnectInd(const OpalCapiMessage & message);
    virtual bool PutMessage(OpalCapiMessage & message);

    OpalCapiFunctions * m_capi;
    PThread           * m_thread;
    unsigned            m_applicationId;
    PSyncPoint          m_listenCompleted;

    struct Controller {
      Controller() : m_active(false) { }

      bool GetFreeLine(unsigned & bearer);

      bool         m_active;
      vector<bool> m_bearerInUse;
    };
    typedef std::vector<Controller> ControllerVector;
    ControllerVector m_controllers;
    PMutex           m_controllerMutex;

    struct IdToConnMap : public std::map<unsigned, PSafePtr<OpalCapiConnection> >
    {
      bool Forward(const OpalCapiMessage & message, unsigned id);
      PMutex m_mutex;
    };

    IdToConnMap m_cbciToConnection;
    IdToConnMap m_plciToConnection;

  friend class OpalCapiConnection;
};


class OpalCapiConnection : public OpalConnection
{
  PCLASSINFO(OpalCapiConnection, OpalConnection);

  public:
    OpalCapiConnection(
      OpalCall & call,              
      OpalCapiEndPoint & endpoint,  
      unsigned int options,         
      OpalConnection::StringOptions * stringOptions, 
      unsigned controller,
      unsigned bearer
    );

    virtual bool IsNetworkConnection() const;

    virtual PBoolean SetUpConnection();

    virtual PBoolean SetAlerting(
      const PString & calleeName,   
      PBoolean withMedia                
    );

    virtual PBoolean SetConnected();

    virtual void OnReleased();

    virtual PString GetDestinationAddress();

    virtual OpalMediaFormatList GetMediaFormats() const;

    virtual OpalMediaStream * CreateMediaStream(
      const OpalMediaFormat & mediaFormat, 
      unsigned sessionID,                  
      PBoolean isSource                        
    );

    virtual PBoolean SendUserInputTone(
      char tone,    
      int duration  
    );

    virtual void OnApplyStringOptions();



  protected:
    virtual void ProcessMessage(const OpalCapiMessage & message);
    virtual bool PutMessage(OpalCapiMessage & message);

    OpalCapiEndPoint & m_endpoint;
    unsigned           m_controller; // 1..127
    unsigned           m_bearer;
    DWORD              m_PLCI;
    DWORD              m_NCCI;

    PSyncPoint m_disconnected;

    PBYTEArray m_Bprotocol;

  friend class OpalCapiEndPoint;
  friend struct OpalCapiEndPoint::IdToConnMap;
  friend class OpalCapiMediaStream;
};


class OpalCapiMediaStream : public OpalMediaStream
{
    PCLASSINFO(OpalCapiMediaStream, OpalMediaStream);
  public:
    OpalCapiMediaStream(
      OpalCapiConnection & conn,            
      const OpalMediaFormat & mediaFormat,  
      unsigned sessionID,                   
      PBoolean isSource                     
    );


    virtual PBoolean ReadData(
      BYTE * data,      
      PINDEX size,      
      PINDEX & length   
    );

    virtual PBoolean WriteData(
      const BYTE * data,   
      PINDEX length,       
      PINDEX & written     
    );

    virtual PBoolean IsSynchronous() const;



  protected:
    virtual void InternalClose();

    OpalCapiConnection & m_connection;
    PQueueChannel        m_queue;
    PSyncPoint           m_written;
    PAdaptiveDelay       m_delay;

  friend class OpalCapiConnection;
};


#endif // OPAL_CAPI

#endif // OPAL_LIDS_CAPI_EP_H


// End of File ///////////////////////////////////////////////////////////////