localep.h

Go to the documentation of this file.

/*
 * localep.h
 *
 * Local EndPoint/Connection.
 *
 * Open Phone Abstraction Library (OPAL)
 * Formally known as the Open H323 project.
 *
 * Copyright (c) 2008 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 Phone Abstraction Library.
 *
 * The Initial Developer of the Original Code is Equivalence Pty. Ltd.
 *
 * Contributor(s): ______________________________________.
 *
 * $Revision: 31065 $
 * $Author: rjongbloed $
 * $Date: 2013-12-11 17:08:05 +1100 (Wed, 11 Dec 2013) $
 */

#ifndef OPAL_OPAL_LOCALEP_H
#define OPAL_OPAL_LOCALEP_H

#ifdef P_USE_PRAGMA
#pragma interface
#endif

#include <opal/buildopts.h>

#include <opal/endpoint.h>

class OpalLocalConnection;


#define OPAL_LOCAL_PREFIX "local"


class OpalLocalEndPoint : public OpalEndPoint
{
    PCLASSINFO(OpalLocalEndPoint, OpalEndPoint);
  public:
    OpalLocalEndPoint(
      OpalManager & manager,        
      const char * prefix = OPAL_LOCAL_PREFIX  
    );

    ~OpalLocalEndPoint();

    virtual OpalMediaFormatList GetMediaFormats() const;

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

    PSafePtr<OpalLocalConnection> GetLocalConnectionWithLock(
      const PString & token,     
      PSafetyMode mode = PSafeReadWrite   
    ) { return GetConnectionWithLockAs<OpalLocalConnection>(token, mode); }

    virtual OpalLocalConnection * CreateConnection(
      OpalCall & call,    
      void * userData,    
      unsigned options,   
      OpalConnection::StringOptions * stringOptions 
    );

    virtual bool OnOutgoingSetUp(
      const OpalLocalConnection & connection 
    );

    virtual bool OnOutgoingCall(
      const OpalLocalConnection & connection 
    );

    virtual bool OnIncomingCall(
      OpalLocalConnection & connection 
    );

    virtual bool AlertingIncomingCall(
      const PString & token, 
      OpalConnection::StringOptions * options = NULL,  
      bool withMedia = false  
    );

    virtual bool AcceptIncomingCall(
      const PString & token, 
      OpalConnection::StringOptions * options = NULL  
    );

    virtual bool RejectIncomingCall(
      const PString & token,                 
      const OpalConnection::CallEndReason & reason = OpalConnection::EndedByAnswerDenied 
    );

    virtual bool OnUserInput(
      const OpalLocalConnection & connection, 
      const PString & indication    
    );

    virtual bool OnReadMediaFrame(
      const OpalLocalConnection & connection, 
      const OpalMediaStream & mediaStream,    
      RTP_DataFrame & frame                   
    );

    virtual bool OnWriteMediaFrame(
      const OpalLocalConnection & connection, 
      const OpalMediaStream & mediaStream,    
      RTP_DataFrame & frame                   
    );

    virtual bool OnReadMediaData(
      const OpalLocalConnection & connection, 
      const OpalMediaStream & mediaStream,    
      void * data,                            
      PINDEX size,                            
      PINDEX & length                         
    );

    virtual bool OnWriteMediaData(
      const OpalLocalConnection & connection, 
      const OpalMediaStream & mediaStream,    
      const void * data,                      
      PINDEX length,                          
      PINDEX & written                        
    );

    enum Synchronicity {
      e_Synchronous,        
      e_Asynchronous,       
      e_SimulateSyncronous  
    };

    virtual Synchronicity GetSynchronicity(
      const OpalMediaFormat & mediaFormat,  
      bool isSource                         
    ) const;

    Synchronicity GetDefaultAudioSynchronicity() const { return m_defaultAudioSynchronicity; }

    void SetDefaultAudioSynchronicity(Synchronicity sync) { m_defaultAudioSynchronicity = sync; }

    Synchronicity GetDefaultVideoSourceSynchronicity() const { return m_defaultVideoSourceSynchronicity; }

    void SetDefaultVideoSourceSynchronicity(Synchronicity sync) { m_defaultVideoSourceSynchronicity = sync; }

    bool IsDeferredAlerting() const { return m_deferredAlerting; }

    void SetDeferredAlerting(bool defer) { m_deferredAlerting = defer; }

    bool IsDeferredAnswer() const { return m_deferredAnswer; }

    void SetDeferredAnswer(bool defer) { m_deferredAnswer = defer; }

  protected:
    bool m_deferredAlerting;
    bool m_deferredAnswer;

    Synchronicity m_defaultAudioSynchronicity;
    Synchronicity m_defaultVideoSourceSynchronicity;

  private:
    P_REMOVE_VIRTUAL(OpalLocalConnection *, CreateConnection(OpalCall &, void *), 0);
    P_REMOVE_VIRTUAL(bool, IsSynchronous() const, false);
};


class OpalLocalConnection : public OpalConnection
{
    PCLASSINFO(OpalLocalConnection, OpalConnection);
  public:
    OpalLocalConnection(
      OpalCall & call,              
      OpalLocalEndPoint & endpoint, 
      void * userData,              
      unsigned options,             
      OpalConnection::StringOptions * stringOptions, 
      char tokenPrefix = 'L'        
    );

    ~OpalLocalConnection();

    virtual PBoolean OnIncomingConnection(unsigned int options, OpalConnection::StringOptions * stringOptions);

    virtual PBoolean IsNetworkConnection() const { return false; }

    virtual void OnApplyStringOptions();

    virtual PBoolean SetUpConnection();

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

    virtual PBoolean SetConnected();

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

    virtual OpalMediaStreamPtr OpenMediaStream(
      const OpalMediaFormat & mediaFormat, 
      unsigned sessionID,                  
      bool isSource                        
    );

    virtual PBoolean SendUserInputString(
      const PString & value                   
    );

    virtual bool OnOutgoingSetUp();

    virtual bool OnOutgoing();

    virtual bool OnIncoming();

    virtual void AlertingIncoming(
      bool withMedia = false  
    );

    virtual void AcceptIncoming();


    void * GetUserData() const  { return m_userData; }

    void SetUserData(void * v)  { m_userData = v; }

  protected:
    friend class PSafeWorkNoArg<OpalLocalConnection>;
    void InternalAcceptIncoming();

    OpalLocalEndPoint & endpoint;
    void * m_userData;
};


class OpalLocalMediaStream : public OpalMediaStream, public OpalMediaStreamPacing
{
    PCLASSINFO(OpalLocalMediaStream, OpalMediaStream);
  public:
    OpalLocalMediaStream(
      OpalLocalConnection & conn,          
      const OpalMediaFormat & mediaFormat, 
      unsigned sessionID,                  
      bool isSource,                       
      OpalLocalEndPoint::Synchronicity synchronicity 
    );

    virtual PBoolean ReadPacket(
      RTP_DataFrame & packet
    );

    virtual PBoolean WritePacket(
      RTP_DataFrame & packet
    );

    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() { }

    OpalLocalEndPoint::Synchronicity m_synchronicity;
};


#endif // OPAL_OPAL_LOCALEP_H


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