add rtsp server

houxiao

2016-12-22 1e58e1e6a5a7d08bdcf3c487bc900f75558e9eee

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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
#include "PL_RTSPServer.h" 
 
struct PL_RTSPServer_Internal 
{ 
    uint8_t buffer[1920*1080*4]; 
    size_t buffSize; 
    size_t buffSizeMax; 
 
    bool payError; 
     
    PL_RTSPServer_Internal() :  
        buffSize(0), buffSizeMax(sizeof(buffer)),  
        payError(true) 
    { 
    } 
     
    ~PL_RTSPServer_Internal() 
    { 
    } 
     
    void reset() 
    { 
        buffSize = 0; 
        payError = true; 
    } 
}; 
 
PipeLineElem* create_PL_RTSPServer() 
{ 
    return new PL_RTSPServer; 
} 
 
PL_RTSPServer::PL_RTSPServer() : internal(new PL_RTSPServer_Internal) 
{ 
} 
 
PL_RTSPServer::~PL_RTSPServer() 
{ 
    delete (PL_RTSPServer_Internal*)internal; 
    internal= nullptr; 
} 
 
bool PL_RTSPServer::init(void* args) 
{ 
    PL_RTSPServer_Internal* in = (PL_RTSPServer_Internal*)internal; 
    in->reset(); 
 
    return true; 
} 
 
void PL_RTSPServer::finit() 
{ 
    PL_RTSPServer_Internal* in = (PL_RTSPServer_Internal*)internal; 
     
} 
 
bool PL_RTSPServer::pay(const PipeMaterial& pm) 
{ 
    PL_RTSPServer_Internal* in = (PL_RTSPServer_Internal*)internal; 
     
    //in->buffer readly 
 
    //static size_t f=0; 
    //char fname[50]; 
    //sprintf(fname, "%u.bgra", ++f); 
    //FILE * pFile = fopen (fname,"wb"); 
    //fwrite (in->buffer , sizeof(char), in->buffSize, pFile); 
    //fclose(pFile); 
 
    return true; 
} 
 
bool PL_RTSPServer::gain(PipeMaterial& pm) 
{ 
    PL_RTSPServer_Internal* in = (PL_RTSPServer_Internal*)internal; 
 
    pm.buffer = in->buffer; 
    pm.buffSize = in->buffSize; 
    pm.former = this; 
    return true; 
}