Home |  Recent changes |  Search |  Glossary |  Sitemap |  Login

About |  News |  SIP Resources |  Documentation |  Downloads |  Projects |  SIP Service |  Support          Project shortcuts:  SER |  SERweb |  SEMS

AmRtpStream.h

Go to the documentation of this file.

/*
 * $Id: AmRtpStream.h 950 2008-05-14 12:54:45Z sayer $
 *
 * Copyright (C) 2002-2003 Fhg Fokus
 *
 * This file is part of sems, a free SIP media server.
 *
 * sems is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version
 *
 * For a license to use the ser software under conditions
 * other than those described here, or to purchase support for this
 * software, please contact iptel.org by e-mail at the following addresses:
 *    info@iptel.org
 *
 * sems is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License 
 * along with this program; if not, write to the Free Software 
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
#ifndef _RtpStream_h_
#define _RtpStream_h_


#include "AmSdp.h"
#include "AmThread.h"
#include "SampleArray.h"
#include "AmRtpPacket.h"
#include "AmEvent.h"

#include <netinet/in.h>

#include <string>
#include <map>
#include <memory>
using std::string;
using std::auto_ptr;

// return values of AmRtpStream::receive
#define RTP_EMPTY        0 // no rtp packet available
#define RTP_PARSE_ERROR -1 // error while parsing rtp packet
#define RTP_TIMEOUT     -2 // last received packet is too old
#define RTP_DTMF        -3 // dtmf packet has been received
#define RTP_BUFFER_SIZE -4 // buffer overrun
#define RTP_UNKNOWN_PL  -5 // unknown payload


struct amci_payload_t;

class AmAudio;
class AmSession;
class SdpPayload;
typedef std::map<unsigned int, AmRtpPacket*, ts_less> ReceiveBuffer;


struct PacketMem {
#define MAX_PACKETS 32

  AmRtpPacket packets[MAX_PACKETS];
  bool        used[MAX_PACKETS];

  PacketMem();

  inline AmRtpPacket* newPacket();
  inline void freePacket(AmRtpPacket* p);
  inline void clear();
};


class AmRtpStream 
{
protected:
  static int next_port;
  static AmMutex port_mut;

  static int getNextPort();

  int         payload;
  unsigned int   sequence;

  int         last_payload;

  string             r_host;
  unsigned short     r_port;
#ifdef SUPPORT_IPV6
  struct sockaddr_storage r_saddr;
  struct sockaddr_storage l_saddr;
#else
  struct sockaddr_in r_saddr;
  struct sockaddr_in l_saddr;
#endif
  unsigned short     l_port;
  int                l_sd;

  struct timeval last_recv_time;

  unsigned int   l_ssrc;
  unsigned int   r_ssrc;
  bool           r_ssrc_i;

  bool              passive;      // passive mode ?

  auto_ptr<const SdpPayload> telephone_event_pt;


  PacketMem       mem;
  ReceiveBuffer   receive_buf;
  AmMutex         receive_mut;


  /* get next packet in buffer */
  int nextPacket(AmRtpPacket*& p);
  
  AmSession*         session;

  void setLocalPort();


public:

  AmRtpPacket* newPacket();
  void freePacket(AmRtpPacket* p);
  
  bool mute;
  bool hold;
  bool begin_talk;
  bool monitor_rtp_timeout;


  bool receiving;

  int send( unsigned int ts,
            unsigned char* buffer,
            unsigned int   size );

  int send_raw( char* packet, unsigned int length );

  int receive( unsigned char* buffer, unsigned int size,
               unsigned int& ts, int& payload);

  int ping();

  AmRtpStream(AmSession* _s=0);
  virtual ~AmRtpStream();

  void setLocalIP(const string& ip);
            
  int getLocalPort();

  int getRPort();
    
  string getRHost();

  void setRAddr(const string& addr, unsigned short port);

  void setPassiveMode(bool p) { passive = p; }
  bool getPassiveMode() { return passive; }

  unsigned int get_ssrc() { return l_ssrc; }

  void setTelephoneEventPT(const SdpPayload *pt) {
    telephone_event_pt.reset(pt);
  }

  int getTelephoneEventRate();

  virtual void init(const vector<SdpPayload*>& sdp_payloads);

  void pause();

  void resume();

  void setOnHold(bool on_hold);
  
  bool getOnHold();

  void setMonitorRTPTimeout(bool m) { monitor_rtp_timeout = m; }
  bool getMonitorRTPTimeout() { return monitor_rtp_timeout; }

  void icmpError();

  void bufferPacket(AmRtpPacket* p);

  /*
   * clear RTP timeout at time recv_time 
   */
  void clearRTPTimeout(struct timeval* recv_time);

  virtual unsigned int bytes2samples(unsigned int) const = 0;
};

class AmRtpTimeoutEvent
  : public AmEvent
{
        
public:
  AmRtpTimeoutEvent() 
    : AmEvent(0) { }
  ~AmRtpTimeoutEvent() { }
};

#endif

// Local Variables:
// mode:C++
// End:

---

Legal Notices |  Privacy Policy

Home |  Recent changes |  Search |  Glossary |  Sitemap |  Login

Copyright (c) 2001-2007 iptel.org. All rights reserved.

Sponsored by FhG FOKUS, iptelorg GmbH, and iptego GmbH