RtpTransmitter.hxx
上传用户:sy_wanhua
上传日期:2013-07-25
资源大小:3048k
文件大小:8k
源码类别:

流媒体/Mpeg4/MP4

开发平台:

C/C++

  1. #ifndef RTPTRANSMITTER_HXX
  2. #define RTPTRANSMITTER_HXX
  3. /* ====================================================================
  4.  * The Vovida Software License, Version 1.0 
  5.  * 
  6.  * Copyright (c) 2000 Vovida Networks, Inc.  All rights reserved.
  7.  * 
  8.  * Redistribution and use in source and binary forms, with or without
  9.  * modification, are permitted provided that the following conditions
  10.  * are met:
  11.  * 
  12.  * 1. Redistributions of source code must retain the above copyright
  13.  *    notice, this list of conditions and the following disclaimer.
  14.  * 
  15.  * 2. Redistributions in binary form must reproduce the above copyright
  16.  *    notice, this list of conditions and the following disclaimer in
  17.  *    the documentation and/or other materials provided with the
  18.  *    distribution.
  19.  * 
  20.  * 3. The names "VOCAL", "Vovida Open Communication Application Library",
  21.  *    and "Vovida Open Communication Application Library (VOCAL)" must
  22.  *    not be used to endorse or promote products derived from this
  23.  *    software without prior written permission. For written
  24.  *    permission, please contact vocal@vovida.org.
  25.  *
  26.  * 4. Products derived from this software may not be called "VOCAL", nor
  27.  *    may "VOCAL" appear in their name, without prior written
  28.  *    permission of Vovida Networks, Inc.
  29.  * 
  30.  * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED
  31.  * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  32.  * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, TITLE AND
  33.  * NON-INFRINGEMENT ARE DISCLAIMED.  IN NO EVENT SHALL VOVIDA
  34.  * NETWORKS, INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT DAMAGES
  35.  * IN EXCESS OF $1,000, NOR FOR ANY INDIRECT, INCIDENTAL, SPECIAL,
  36.  * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
  37.  * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
  38.  * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
  39.  * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  40.  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
  41.  * USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH
  42.  * DAMAGE.
  43.  * 
  44.  * ====================================================================
  45.  * 
  46.  * This software consists of voluntary contributions made by Vovida
  47.  * Networks, Inc. and many individuals on behalf of Vovida Networks,
  48.  * Inc.  For more information on Vovida Networks, Inc., please see
  49.  * <http://www.vovida.org/>.
  50.  *
  51.  */
  52. static const char* const RtpTransmitter_hxx_Version =
  53.     "$Id: RtpTransmitter.hxx,v 1.16 2001/05/07 19:12:50 kle Exp $";
  54. #include <sys/types.h>
  55. #include <map>
  56. #include "rtpTypes.h"
  57. #include "UdpStack.hxx"
  58. #include "NtpTime.hxx"
  59. #include "NetworkAddress.h"
  60. class RtpPacket;
  61. class RtcpReceiver;
  62. /// Data structure for RTP Transmitter
  63. class RtpTransmitter
  64. {
  65.     public:
  66.         /// constructor using port range
  67.         RtpTransmitter (const char* remoteHost, int remoteMinPort,
  68.                         int remoteMaxPort,
  69.                         RtpPayloadType apiFormat = rtpPayloadPCMU,
  70.                         RtpPayloadType networkFormat = rtpPayloadPCMU,
  71.                         RtpReceiver* receivePort = 0);
  72.         /// construtor using specified port
  73.         RtpTransmitter (const char* remoteHost, int remotePort = 5000,
  74.                         RtpPayloadType apiFormat = rtpPayloadPCMU,
  75.                         RtpPayloadType networkFormat = rtpPayloadPCMU,
  76.                         RtpReceiver* receiver = 0);
  77.         /// consturctor init (don't call this function)
  78.         void constructRtpTransmitter (RtpPayloadType apiFormat,
  79.                                       RtpPayloadType networkFormat);
  80.         ///
  81.         ~RtpTransmitter ();
  82.         /// Creates a packet with transmitter's payload type and SRC number
  83.         RtpPacket* createPacket (int npadSize = 0, int csrc_count = 0);
  84.         ///
  85.         int transmit (RtpPacket* packet, bool eventFlag = false);
  86.         ///
  87.         int transmitRaw (char* buffer, int data_len);
  88.         ///
  89.         RtpSrc getSSRC ()
  90.         {
  91.             return ssrc;
  92.         }
  93.         ///
  94.         int getPacketSent ()
  95.         {
  96.             return packetSent;
  97.         }
  98.         ///
  99.         int getPayloadSent ()
  100.         {
  101.             return payloadSent;
  102.         }
  103.         ///
  104.         RtpSeqNumber getPrevSequence ()
  105.         {
  106.             return prevSequence;
  107.         }
  108.         ///
  109.         RtpTime getPrevRtpTime ()
  110.         {
  111.             return prevRtpTime;
  112.         }
  113.         ///
  114.         void setMarkerOnce()
  115.         {
  116.             markerOnce = true;
  117.         }
  118.         ///
  119.         void setApiFormat (RtpPayloadType type, int no_samples, int packetSize = 0,
  120.                            RtpPacket* p = NULL, bool print = true);
  121.         ///
  122.         int getApiPktSampleSize ()
  123.         {
  124.             return api_pktSampleSize;
  125.         }
  126.         ///
  127.         void setApiPktSize (int size)
  128.         {
  129.             api_pktSampleSize = size;
  130.         }
  131.         ///
  132.         void setNetworkFormat (RtpPayloadType type, int no_samples, int packetSize = 0,
  133.                                RtpPacket* p = NULL, bool print = true);
  134.         ///
  135.         int getNetworkPktSampleSize ()
  136.         {
  137.             return network_pktSampleSize;
  138.         }
  139.         ///
  140.         void setNetworkPktSize (int size)
  141.         {
  142.             network_pktSampleSize = size;
  143.         }
  144.         /// Port this stack is sending its singal
  145.         int getPort ()
  146.         {
  147.             return myStack->getTxPort();
  148.         }
  149.         /// Socket File Descriptor used for select()
  150.         int getSocketFD ()
  151.         {
  152.             return myStack->getSocketFD();
  153.         }
  154.         /// transmitter error code;
  155.         RtpTransmitterError transmitterError;
  156.         /// get ptr of my UdpStack
  157.         UdpStack* getUdpStack()
  158.         {
  159.             return myStack;
  160.         }
  161.         ///
  162.         NetworkAddress* getRemoteAddr ()
  163.         {
  164.             return &remoteAddr;
  165.         }
  166.         ///
  167.         void setRemoteAddr (const NetworkAddress& theAddr) ;
  168.     private:
  169.         /// outgoing buffer size, including RTP header
  170.         static const int OUT_BUFFER_SIZE = 8192;
  171.         /// local SRC number
  172.         RtpSrc ssrc;
  173.         /// inital NTP time
  174.         NtpTime seedNtpTime;
  175.         /// inital RTP time
  176.         RtpTime seedRtpTime;
  177.         /// RTP time of previous packet
  178.         RtpTime prevRtpTime;
  179.         /// NTP time of previous packet
  180.         NtpTime prevNtpTime;
  181.         /// previous packet's sequence
  182.         RtpSeqNumber prevSequence;
  183.         /// numbers of packet sent
  184.         int packetSent;
  185.         /// total bytes of payload sent
  186.         int payloadSent;
  187.         /// allow RTCP stack to probe for information
  188.         friend class RtcpTransmitter;
  189.         /// allow RTCP stack to probe for information
  190.         friend class RtcpReceiver;
  191.         /// format of payload for stack
  192.         RtpPayloadType apiFormat;
  193.         RtpPayloadType networkFormat;
  194.         /// number of samples per RTP packet on api (typical 160 or 240)
  195.         int api_pktSampleSize;
  196.         int network_pktSampleSize;
  197.         /// number of bytes per sample  (typical 1 or 2, used for endian conversion)
  198.         int apiFormat_perSampleSize;
  199.         int networkFormat_perSampleSize;
  200.         /// payload specific sample rate
  201.         int apiFormat_clockRate;
  202.         int networkFormat_clockRate;
  203.         /// payload sizes
  204.         int apiFormat_payloadSize;   // api_pktSampleSize*apiFormat_perSampleSize
  205.         int networkFormat_payloadSize;   // network_pktSampleSize * networkFormat_perSampleSize
  206.         /// marker once
  207.         bool markerOnce;
  208.         /// my UDP stack
  209.         UdpStack* myStack;
  210.         ///
  211.         bool freeStack;
  212.         /// buffer outgoing rtp pkt to network
  213.         char outBuff[8192];
  214.         int outPos;
  215.         int recPos;
  216.         NetworkAddress remoteAddr;
  217. };
  218. #endif // RTPTRANSMITTER_HXX