use gb tcp

zhangmeng

2022-07-20 b3dd7bdf54aff8c85a36d9637258050e68820abd

 csrc/thirdparty/gb28181/include/PsToEs.hpp

@@ -43,7 +43,7 @@
        pthread_mutex_lock(&mtx);
        if (q.empty()) {
            gettimeofday(&now, NULL);
            t.tv_sec = now.tv_sec + 3;
            t.tv_sec = now.tv_sec + 12;
            t.tv_nsec = now.tv_usec * 1000;
//            pthread_cond_wait(&cond, &mtx);
            pthread_cond_timedwait(&cond, &mtx, &t);
@@ -77,7 +77,8 @@
      pthread_mutex_unlock(&mtx);
    }
   
   void clearAll(std::function<void(T)> fn){
    template<class F>
   void clearAll(F&& fn){
      pthread_mutex_lock(&mtx);
      while (!q.empty()){
         T value = q.front();