chenke
2017-08-09 2a12817d4ae31a591f788f3fbb82916e385e9e2d
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
82
83
84
85
86
#include "PL_StaticJpegSource.h"
 
extern "C"
{
    #include <libyuv.h>
}
 
struct PL_StaticJpegSource_Internal
{
    uint8_t buffer[1920*1080*4];
    size_t buffSize;
    size_t buffSizeMax;
 
    bool payError;
    
    PL_StaticJpegSource_Internal() : 
        buffSize(0), buffSizeMax(sizeof(buffer)), 
        payError(true)
    {
    }
    
    ~PL_StaticJpegSource_Internal()
    {
    }
    
    void reset()
    {
        buffSize = 0;
        payError = true;
    }
};
 
PipeLineElem* create_PL_StaticJpegSource()
{
    return new PL_StaticJpegSource;
}
 
PL_StaticJpegSource::PL_StaticJpegSource() : internal(new PL_StaticJpegSource_Internal)
{
}
 
PL_StaticJpegSource::~PL_StaticJpegSource()
{
    delete (PL_StaticJpegSource_Internal*)internal;
    internal= nullptr;
}
 
bool PL_StaticJpegSource::init(void* args)
{
    PL_StaticJpegSource_Internal* in = (PL_StaticJpegSource_Internal*)internal;
    in->reset();
 
    return true;
}
 
void PL_StaticJpegSource::finit()
{
    PL_StaticJpegSource_Internal* in = (PL_StaticJpegSource_Internal*)internal;
    
}
 
bool PL_StaticJpegSource::pay(const PipeMaterial& pm)
{
    PL_StaticJpegSource_Internal* in = (PL_StaticJpegSource_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_StaticJpegSource::gain(PipeMaterial& pm)
{
    PL_StaticJpegSource_Internal* in = (PL_StaticJpegSource_Internal*)internal;
 
    pm.buffer = in->buffer;
    pm.buffSize = in->buffSize;
    pm.former = this;
    return true;
}