srs中时间戳抖动处理

╰+攻爆jí腚メ 2022-06-07 11:38 140阅读 0赞

http://blog.csdn.net/lcalqf/article/details/59543410

**\[cpp\]**  [view plain][]   [copy][view plain]

1.  /\*\* 
2.  \* the time jitter algorithm: 
3.  \* 1. full, to ensure stream start at zero, and ensure stream monotonically increasing. 
4.  \* 2. zero, only ensure sttream start at zero, ignore timestamp jitter. 
5.  \* 3. off, disable the time jitter algorithm, like atc. 
6.  \*/  
7.  **enum** SrsRtmpJitterAlgorithm  
8.  \{  
9.      SrsRtmpJitterAlgorithmFULL = 0x01,  
10.     SrsRtmpJitterAlgorithmZERO,  
11.     SrsRtmpJitterAlgorithmOFF  
12. \};  
13. **int** \_srs\_time\_jitter\_string2int(std::string time\_jitter);  
14.   
15. /\*\* 
16. \* time jitter detect and correct, 
17. \* to ensure the rtmp stream is monotonically. 
18. \*/  
19. **class** SrsRtmpJitter  
20. \{  
21. **private**:  
22.     int64\_t last\_pkt\_time;  
23.     int64\_t last\_pkt\_correct\_time;  
24. **public**:  
25.     SrsRtmpJitter();  
26.     **virtual** ~SrsRtmpJitter();  
27. **public**:  
28.     /\*\* 
29.     \* detect the time jitter and correct it. 
30.     \* @param tba, the audio timebase, used to calc the "right" delta if jitter detected. 
31.     \* @param tbv, the video timebase, used to calc the "right" delta if jitter detected. 
32.     \* @param start\_at\_zero whether ensure stream start at zero. 
33.     \* @param mono\_increasing whether ensure stream is monotonically inscreasing. 
34.     \*/  
35.     **virtual** **int** correct(SrsSharedPtrMessage\* msg, **int** tba, **int** tbv, SrsRtmpJitterAlgorithm ag);  
36.     /\*\* 
37.     \* get current client time, the last packet time. 
38.     \*/  
39.     **virtual** **int** get\_time();  
40. \};

超过抖动区域，置为默认值，都是相对时间

**\[cpp\]**  [view plain][]   [copy][view plain]

1.  \#define CONST\_MAX\_JITTER\_MS         250  
2.  \#define CONST\_MAX\_JITTER\_MS\_NEG         -250  
3.  \#define DEFAULT\_FRAME\_TIME\_MS         10  
4.    
5.  // for 26ms per audio packet,  
6.  // 115 packets is 3s.  
7.  \#define SRS\_PURE\_AUDIO\_GUESS\_COUNT 115  
8.    
9.  // when got these videos or audios, pure audio or video, mix ok.  
10. \#define SRS\_MIX\_CORRECT\_PURE\_AV 10  
11.   
12. // the time to cleanup source in ms.  
13. \#define SRS\_SOURCE\_CLEANUP 30000  
14.   
15. **int** \_srs\_time\_jitter\_string2int(std::string time\_jitter)  
16. \{  
17.     **if** (time\_jitter == "full") \{  
18.         **return** SrsRtmpJitterAlgorithmFULL;  
19.     \} **else** **if** (time\_jitter == "zero") \{  
20.         **return** SrsRtmpJitterAlgorithmZERO;  
21.     \} **else** \{  
22.         **return** SrsRtmpJitterAlgorithmOFF;  
23.     \}  
24. \}  
25.   
26. SrsRtmpJitter::SrsRtmpJitter()  
27. \{  
28.     last\_pkt\_correct\_time = -1;  
29.     last\_pkt\_time = 0;  
30. \}  
31.   
32. SrsRtmpJitter::~SrsRtmpJitter()  
33. \{  
34. \}  
35.   
36. **int** SrsRtmpJitter::correct(SrsSharedPtrMessage\* msg, SrsRtmpJitterAlgorithm ag)  
37. \{  
38.     **int** ret = ERROR\_SUCCESS;  
39.       
40.     // for performance issue  
41.     **if** (ag != SrsRtmpJitterAlgorithmFULL) \{  
42.         // all jitter correct features is disabled, ignore.  
43.         **if** (ag == SrsRtmpJitterAlgorithmOFF) \{  
44.             **return** ret;  
45.         \}  
46.       
47.         // start at zero, but donot ensure monotonically increasing.  
48.         **if** (ag == SrsRtmpJitterAlgorithmZERO) \{  
49.             // for the first time, last\_pkt\_correct\_time is -1.  
50.             **if** (last\_pkt\_correct\_time == -1) \{  
51.                 last\_pkt\_correct\_time = msg->timestamp;  
52.             \}  
53.             msg->timestamp -= last\_pkt\_correct\_time;  
54.             **return** ret;  
55.         \}  
56.           
57.         // other algorithm, ignore.  
58.         **return** ret;  
59.     \}  
60.       
61.     // full jitter algorithm, do jitter correct.  
62.     // set to 0 for metadata.  
63.     **if** (!msg->is\_av()) \{  
64.         msg->timestamp = 0;  
65.         **return** ret;  
66.     \}  
67.       
68.     /\*\* 
69.     \* we use a very simple time jitter detect/correct algorithm: 
70.     \* 1. delta: ensure the delta is positive and valid, 
71.     \*     we set the delta to DEFAULT\_FRAME\_TIME\_MS, 
72.     \*     if the delta of time is nagative or greater than CONST\_MAX\_JITTER\_MS. 
73.     \* 2. last\_pkt\_time: specifies the original packet time, 
74.     \*     is used to detect next jitter. 
75.     \* 3. last\_pkt\_correct\_time: simply add the positive delta,  
76.     \*     and enforce the time monotonically. 
77.     \*/  
78.     int64\_t time = msg->timestamp;  
79.     int64\_t delta = time - last\_pkt\_time;  
80.   
81.     // if jitter detected, reset the delta.  
82.     **if** (delta < CONST\_MAX\_JITTER\_MS\_NEG || delta > CONST\_MAX\_JITTER\_MS) \{  
83.         // use default 10ms to notice the problem of stream.  
84.         // @see https://github.com/ossrs/srs/issues/425  
85.         delta = DEFAULT\_FRAME\_TIME\_MS;  
86.           
87.         srs\_info("jitter detected, last\_pts=%"PRId64", pts=%"PRId64", diff=%"PRId64", last\_time=%"PRId64", time=%"PRId64", diff=%"PRId64"",  
88.             last\_pkt\_time, time, time - last\_pkt\_time, last\_pkt\_correct\_time, last\_pkt\_correct\_time + delta, delta);  
89.     \} **else** \{  
90.         srs\_verbose("timestamp no jitter. time=%"PRId64", last\_pkt=%"PRId64", correct\_to=%"PRId64"",   
91.             time, last\_pkt\_time, last\_pkt\_correct\_time + delta);  
92.     \}  
93.       
94.     last\_pkt\_correct\_time = srs\_max(0, last\_pkt\_correct\_time + delta);  
95.       
96.     msg->timestamp = last\_pkt\_correct\_time;  
97.     last\_pkt\_time = time;  
98.       
99.     **return** ret;  
100. \}  
101.   
102. **int** SrsRtmpJitter::get\_time()  
103. \{  
104.     **return** (**int**)last\_pkt\_correct\_time;  
105. \}  
106.

[view plain]: http://blog.csdn.net/lcalqf/article/details/59543410#