| | |
| | | while (!q.empty()) q.pop_front(); |
| | | pthread_mutex_unlock(&mtx); |
| | | } |
| | | |
| | | void clearAll(std::function<void(T)> fn){ |
| | | pthread_mutex_lock(&mtx); |
| | | while (!q.empty()){ |
| | | T value = q.front(); |
| | | fn(value); |
| | | q.pop_front(); |
| | | } |
| | | pthread_mutex_unlock(&mtx); |
| | | } |
| | | private: |
| | | deque<T> q; |
| | | pthread_mutex_t mtx; |
| | |
| | | |
| | | ~GB28181API(){ |
| | | printf("GB28181API end!\n"); |
| | | m_rtpQueue.clearAll(); |
| | | // m_rtpQueue.clearAll(); |
| | | m_rtpQueue.clearAll([](frameBuffInfo *info){ |
| | | delete[] info->buff; |
| | | delete info; |
| | | }); |
| | | deleteCamera(); |
| | | } |
| | | |
| | |
| | | } |
| | | } |
| | | |
| | | void addCamera(string &rtsp){ |
| | | long addCamera(string &rtsp){ |
| | | // long userdata = 1001;// |
| | | printf("RTSPSTREAM_Open\n"); |
| | | handle = RTSPSTREAM_Open(rtsp.c_str(), streamCallBack, (long)this); |
| | | // return handle; |
| | | printf("RTSPSTREAM_Open, handle:%ld \n", handle); |
| | | return handle; |
| | | } |
| | | |
| | | void deleteCamera(){ |
| | | printf("RTSPSTREAM_Close\n"); |
| | | RTSPSTREAM_Close(handle); |
| | | if(handle != -1){ |
| | | RTSPSTREAM_Close(handle); |
| | | } |
| | | |
| | | handle = -1; |
| | | } |
| | | private: |