| | |
| | | pthread_mutex_lock(&mtx); |
| | | if (q.empty()) { |
| | | gettimeofday(&now, NULL); |
| | | t.tv_sec = now.tv_sec + 5; |
| | | t.tv_sec = now.tv_sec + 3; |
| | | t.tv_nsec = now.tv_usec * 1000; |
| | | // pthread_cond_wait(&cond, &mtx); |
| | | pthread_cond_timedwait(&cond, &mtx, &t); |
| | |
| | | return bufsize; |
| | | } |
| | | |
| | | static int capturePic(void *opaque, char *buf, int *bufsize) { |
| | | static int capturePic(void *opaque, char *buf, int *bufsize, const int tt) { |
| | | |
| | | GB28181API *_this = (GB28181API *) opaque; |
| | | int len = 0; |
| | | *bufsize = 0; |
| | | |
| | | int ttt = 0; |
| | | do { |
| | | if (ttt > tt) return 0; |
| | | ttt++; |
| | | |
| | | //从缓存中获取buffinfo |
| | | if (_this->m_rtpQueue.count_queue() == 0) { |
| | | // printf(" count_queue == 0 \n"); |
| | |
| | | } |
| | | |
| | | long addCamera(string &rtsp){ |
| | | static int count = 0; |
| | | int count = 0; |
| | | while (handle == -1 && count <= 3) { |
| | | count ++; |
| | | handle = RTSPSTREAM_Open(rtsp.c_str(), streamCallBack, (long) this); |