bug fix

houxiao

2017-03-21 23c3323984f984d36248f107a320a8717b430049

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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
#include "CameraWrapper.h" 
#include <logger.h> 
#include <Logger/src/logger.hpp> 
 
CameraWrapper::~CameraWrapper() 
{ 
    stop(); 
    delete pipeLine; 
} 
 
bool CameraWrapper::start() 
{ 
    LOG_INFO << "CameraWrapper::start" << LOG_ENDL; 
 
    running = true; 
    int ret = pthread_create(&live_daemon_thid, NULL, CameraWrapper::live_daemon_thd, this); 
    if(ret != 0) 
    { 
        LOGP(ERROR, "pthread_create: %s/n", strerror(ret)); 
        running = false; 
        return false; 
    } 
 
    return true; 
} 
 
void CameraWrapper::stop() 
{ 
    LOG_INFO << "CameraWrapper::stop" << LOG_ENDL; 
     
    if (!running) 
        return; 
 
    running = false; 
    pthread_join(live_daemon_thid, NULL); 
} 
 
bool CameraWrapper::initPl() 
{ 
    PL_RTSPClient* rtspClient = (PL_RTSPClient*)pipeLine->push_elem("PL_RTSPClient"); 
    bool ret = rtspClient->init(&rtspConfig); 
    if (!ret) 
    { 
        LOG_ERROR << "rtspClient.init error" << LOG_ENDL; 
        return  false; 
    } 
 
    PL_AndroidMediaCodecDecoder* amcDecoder = (PL_AndroidMediaCodecDecoder*)pipeLine->push_elem("PL_AndroidMediaCodecDecoder"); 
    ret = amcDecoder->init(&amcdConfig); 
    if (!ret) 
    { 
        LOG_ERROR << "amcDecoder.init error" << LOG_ENDL; 
        return  false; 
    } 
 
#ifdef USE_ST_SDK 
    PL_SensetimeFaceTrack* sfTrack = (PL_SensetimeFaceTrack*)pipeLine->push_elem("PL_SensetimeFaceTrack"); 
    ret = sfTrack->init(&sftConfig); 
    if (!ret) 
    { 
        LOG_ERROR << "sfTrack.init error" << LOG_ENDL; 
        return  false; 
    } 
#endif 
 
    return true; 
} 
 
/*static*/ void* CameraWrapper::live_daemon_thd(void* arg) 
{ 
    LOG_INFO << "CameraWrapper::live_daemon_thd start" << LOG_ENDL; 
 
    CameraWrapper& cameraWrapper = *(CameraWrapper*)arg; 
 
    while(cameraWrapper.running) 
    { 
        PipeLineElem* last = cameraWrapper.pipeLine->pipe(); 
        bool ret = cameraWrapper.pipeLine->check_pipe_complete(last); 
        LOG_DEBUG << "pipe ret=" << ret << LOG_ENDL; 
 
        if (!ret) 
            continue; 
         
        if (cameraWrapper.faceCacheLocked) 
            continue; 
         
        PipeMaterial pm; 
        ret = last->gain(pm); 
         
        if (!ret) 
            continue; 
         
        int faceCount = cameraWrapper.faceCache.cachePm(pm); 
         
        if (faceCount != 0 && cameraWrapper.faceCallback != 0) 
        { 
            // #todo jni thread may not able to invoke java callback 
            //env->CallVoidMethod(obj, callback, cameraIdx , faceCount); 
        } 
    } 
     
    LOG_INFO << "CameraWrapper::live_daemon_thd stop, ret=" << LOG_ENDL; 
} 
 
void CameraWrapper::lockFace() 
{ 
    faceCacheLocked = true; 
} 
 
void CameraWrapper::releaseFace() 
{ 
    faceCacheLocked = false; 
}