patch.h

Go to the documentation of this file.

/*
 * patch.h
 *
 * Media stream patch thread.
 *
 * Open Phone Abstraction Library (OPAL)
 * Formally known as the Open H323 project.
 *
 * Copyright (c) 2001 Equivalence 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: 29334 $
 * $Author: rjongbloed $
 * $Date: 2013-03-27 14:08:07 +1100 (Wed, 27 Mar 2013) $
 */

#ifndef OPAL_OPAL_PATCH_H
#define OPAL_OPAL_PATCH_H

#ifdef P_USE_PRAGMA
#pragma interface
#endif

#include <opal/buildopts.h>

#include <opal/mediastrm.h>
#include <opal/mediacmd.h>
#include <codec/ratectl.h>

#include <list>

class OpalTranscoder;

class OpalMediaPatch : public PSafeObject
{
    PCLASSINFO(OpalMediaPatch, PObject);
  public:
    OpalMediaPatch(
      OpalMediaStream & source       
    );

    ~OpalMediaPatch();

    void PrintOn(
      ostream & strm    
    ) const;

    virtual void Start();

    virtual bool OnStartMediaPatch();

    virtual void Close();

    PBoolean AddSink(
      const OpalMediaStreamPtr & stream            
    );

    void RemoveSink(
      const OpalMediaStream & stream  
    );

    OpalMediaStream & GetSource() const { return source; }

    OpalMediaStreamPtr GetSink(PINDEX i = 0) const;

    OpalMediaFormat GetSinkFormat(PINDEX i = 0) const;

    void AddFilter(
      const PNotifier & filter,   
      const OpalMediaFormat & stage = OpalMediaFormat() 
    );

    bool RemoveFilter(
      const PNotifier & filter,   
      const OpalMediaFormat & stage = OpalMediaFormat() 
    );

    virtual void FilterFrame(
      RTP_DataFrame & frame,
      const OpalMediaFormat & mediaFormat
    );

    virtual bool UpdateMediaFormat(
      const OpalMediaFormat & mediaFormat  
    );

    virtual PBoolean ExecuteCommand(
      const OpalMediaCommand & command,   
      PBoolean fromSink                       
    );

    virtual bool SetPaused(
      bool pause    
    );

    virtual PBoolean PushFrame(
      RTP_DataFrame & frame   
    );

    bool SetBypassPatch(
      const OpalMediaPatchPtr & patch
    );

    virtual OpalTranscoder * GetAndLockSinkTranscoder(PINDEX i = 0) const;
    virtual void UnLockSinkTranscoder() const;

    virtual bool ResetTranscoders();
    bool EnableJitterBuffer(bool enab = true);

#if OPAL_STATISTICS
    virtual void GetStatistics(OpalMediaStatistics & statistics, bool fromSink) const;
#endif


  protected:
    PDECLARE_NOTIFIER(OpalMediaCommand, OpalMediaPatch, InternalOnMediaCommand1);
    void InternalOnMediaCommand2(OpalMediaCommand * command);
                
    virtual void Main();
    void StopThread();
    bool DispatchFrame(RTP_DataFrame & frame);

    OpalMediaStream & source;

    class Sink : public PObject {
        PCLASSINFO(Sink, PObject);
      public:
        Sink(OpalMediaPatch & p, const OpalMediaStreamPtr & s);
        ~Sink();
        bool CreateTranscoders();
        bool UpdateMediaFormat(const OpalMediaFormat & mediaFormat);
        bool ExecuteCommand(const OpalMediaCommand & command);
        bool WriteFrame(RTP_DataFrame & sourceFrame);
#if OPAL_STATISTICS
        void GetStatistics(OpalMediaStatistics & statistics, bool fromSource) const;
#endif

        OpalMediaPatch  &  patch;
        OpalMediaStreamPtr stream;
        OpalTranscoder   * primaryCodec;
        OpalTranscoder   * secondaryCodec;
        RTP_DataFrameList  intermediateFrames;
        RTP_DataFrameList  finalFrames;
        bool               writeSuccessful;

        RTP_DataFrame::PayloadTypes m_lastPayloadType;
        unsigned                    m_consecutivePayloadTypeMismatches;
        bool CannotTranscodeFrame(OpalTranscoder & codec, RTP_DataFrame & frame);

#if OPAL_VIDEO
        void SetRateControlParameters(const OpalMediaFormat & mediaFormat);
        bool RateControlExceeded(bool & forceIFrame);
        OpalVideoRateController * rateController;
#endif
    };
    PList<Sink> sinks;

    class Filter : public PObject {
        PCLASSINFO(Filter, PObject);
      public:
        Filter(const PNotifier & n, const OpalMediaFormat & s) : notifier(n), stage(s) { }
        PNotifier notifier;
        OpalMediaFormat stage;
    };
    PList<Filter> filters;

    OpalMediaPatchPtr m_bypassToPatch;
    OpalMediaPatchPtr m_bypassFromPatch;
    PSyncPoint        m_bypassEnded;

    PThread * patchThread;
    PMutex patchThreadMutex;

  private:
    P_REMOVE_VIRTUAL(bool, OnPatchStart(), false);
};

class OpalPassiveMediaPatch : public OpalMediaPatch
{
    PCLASSINFO(OpalPassiveMediaPatch, OpalMediaPatch);
  public:

    OpalPassiveMediaPatch(
      OpalMediaStream & source       
    );

    virtual void Start();

  protected:
    bool m_started;
};


#endif // OPAL_OPAL_PATCH_H


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