LowLatencyVideoPrototype/x264_destreamer.cpp at master · rsaxvc/LowLatencyVideoPrototype · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
using namespace std;

#include "x264_destreamer.h"

void x264_destreamer::write( const uint8_t * data, size_t bytes )
{
while( bytes )
	{
	input( *data );
	bytes--;
	data++;
	}
}

void x264_destreamer::input( uint8_t byte )
{
previous_state = ( ( previous_state & 0x00FFFFFF ) << 8 ) | byte;

if( previous_state == 0x00000001 )
	{
	if( sync && buffer.size() > 4 )
		{
		buffer.push_back(0);
		buffer.push_back(0);
		buffer.push_back(0);
		buffer.push_back(0);
		buffer.push_back(0);
		buffer.push_back(0);
		buffer.push_back(0);
		buffer.push_back(0);
		server.broadcast( &buffer[0], buffer.size()-8 );
		buffer.clear();
		}
	sync = true;
	}

if( sync )
	{
	buffer.push_back( ( previous_state & 0xFF000000 ) >> 24 );
	}

}

x264_destreamer::x264_destreamer()
{
previous_state = 0xFFFFFFFF;
sync = false;
}

x264_destreamer::~x264_destreamer()
{
}