apps/astreamer/rtp_stream.h

Go to the documentation of this file.

#ifndef __H_RTP_STREAM__
#define __H_RTP_STREAM__

#include <sys/time.h>
#include <string>
#include <pthread.h>
#include "socket.h"

using namespace std;

extern int fd_stream;

class RTP_Stream {
public:
        RTP_Stream(void);
        virtual ~RTP_Stream() {};

        int ptype(void) { return _ptype; };
        virtual void Start(string ip, int port);
        virtual void Stop(void);
protected:
        void init_pthread(void *__this);
        pthread_t pth;
        int pth_id;
        static void *pthread_f(void *_this);
        void *thread(void);
        pthread_mutex_t pthm_flow;
//      virtual bool process(void) = 0;
        virtual long process(void) = 0;

        int _ptype;
        bool _play;
        Socket *rtp_socket;
        Socket *rtcp_socket;

        unsigned short packet_num;
        unsigned long SSRC;

        struct timeval f_tv;
        struct timeval rtcp_tv; // time of last SR
        long rtcp_delay;
        unsigned long timestamp;

        unsigned long rtp_packets;
        unsigned long rtp_octets;
        unsigned long rtcp_c;

        void rtcp(void);
        void rtcp_send_sr(void);
        void rtcp_send_sdes(void);

        string stream_name;

        static int _fd;
};

#endif //__H_RTP_STREAM__

---