Blame view

src/decoder/gb28181/rtp/RTPUdpReceiver.h 1.34 KB
c8285c8d   Hu Chunming   GB28181 UDP 有重大进展...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
  #ifndef _RTP_UDP_RECEIVER_H_

  #define _RTP_UDP_RECEIVER_H_

  

  #include "rtpsessionparams.h"

  #include "rtpudpv4transmitter.h"

  #include "rtpsession.h"

  #include "rtppacket.h"

  #include <queue>

  #include <iostream>

  #include <thread>

  #include <string>

  #include <mutex>

  

  #include "RTPReceiver.h"

  

  

c8285c8d   Hu Chunming   GB28181 UDP 有重大进展...
17
18
19
20
21
22
23
24
25
26
27
28
  using namespace jrtplib;

  using namespace std;

  

  

  class UdpRTPSession;

  

  class RTPUdpReceiver: public RTPReceiver

  {

  public:

  	RTPUdpReceiver();

  	~RTPUdpReceiver();

  

74d1e6a8   Hu Chunming   完成gb28181大体的代码,未完...
29
  	virtual bool Open(string channel_id);

c8285c8d   Hu Chunming   GB28181 UDP 有重大进展...
30
31
  	virtual bool virtual bool IsOpened() ;() virtual bool IsOpened() ;

  	virtual void virtual void Close() ;() virtual void Close() ;

69ee81f3   Hu Chunming   提交websocket clien...
32
  	virtual bool RequestStream();

74d1e6a8   Hu Chunming   完成gb28181大体的代码,未完...
33
  

c8285c8d   Hu Chunming   GB28181 UDP 有重大进展...
34
35
  public:

  	int OnRtpRecv();

9a922a54   Hu Chunming   自动请求流修改到了sip服务端,解...
36
  	int CheckConnecting();

c8285c8d   Hu Chunming   GB28181 UDP 有重大进展...
37
38
  

  private:

69ee81f3   Hu Chunming   提交websocket clien...
39
  	bool wait_times(int times);

c8285c8d   Hu Chunming   GB28181 UDP 有重大进展...
40
  

69ee81f3   Hu Chunming   提交websocket clien...
41
42
43
44
45
46
  private:

      std::thread*      	m_rtpThreadPtr{nullptr}; 					// RTP接收线程

  	std::thread*      	m_connThreadPtr{nullptr}; 					// 判断流是否还在的线程

  

  	RTPSession*	  		m_rtpSessionPtr{nullptr};					// RTP会话

  	RTPSession 			m_rtpSession;				

c8285c8d   Hu Chunming   GB28181 UDP 有重大进展...
47
48
49
50
51
52
  

      std::atomic_bool    m_bOpened;

  

  	int64_t 			m_idleCount;

  	int64_t 			m_noDataCount;//线程计数,用于打开流成功但是实际没流过来

  

69ee81f3   Hu Chunming   提交websocket clien...
53
54
  	RTPSessionParams* 	m_sessparamsPtr{nullptr};

  	RTPUDPv4TransmissionParams* m_transparamsPtr{nullptr};

74d1e6a8   Hu Chunming   完成gb28181大体的代码,未完...
55
56
  

  	string 				m_sip_channel_id;

69ee81f3   Hu Chunming   提交websocket clien...
57
58
  

  	std::atomic_bool 	m_bNoData{false};

9a922a54   Hu Chunming   自动请求流修改到了sip服务端,解...
59
  	bool 				m_bRecvExit{false};

c8285c8d   Hu Chunming   GB28181 UDP 有重大进展...
60
61
62
  };

  

  #endif  // _RTP_UDP_RECEIVER_H_