Use flag to indicate new frame arrived

deepseg.cc

@@ -170,7 +170,7 @@ typedef struct {
 	timinginfo_t *pti;
 	pthread_mutex_t lock_raw;
 	pthread_mutex_t lock_mask;
-	pthread_cond_t condition_new_frame;
+	bool new_frame;
 	bool running;
 } calcinfo_t;
 
@@ -212,7 +212,7 @@ void init_tensorflow(calcinfo_t &info) {
 
 	info.lock_raw = PTHREAD_MUTEX_INITIALIZER;
 	info.lock_mask = PTHREAD_MUTEX_INITIALIZER;
-	info.condition_new_frame = PTHREAD_COND_INITIALIZER;
+	info.new_frame = false;
 	info.running = false;
 
 	info.raw_next = &info.buf1;
@@ -223,12 +223,16 @@ void calc_mask(calcinfo_t &info) {
 	timestamp_t t = timestamp();
 	cv::Mat *raw_tmp;
 
-	// change frame buffer pointer
-	pthread_mutex_lock(&info.lock_raw);
+	// wait for new frame to arrive
 	timestamp_t t0 = timestamp();
-	pthread_cond_wait(&info.condition_new_frame, &info.lock_raw); // wait for new frame to arrive
+	while (!info.new_frame) {
+		usleep(1000);
+	}
 	info.pti->ai_condns = diffnanosecs(timestamp(), t0);
 	t0 = timestamp();
+	// change frame buffer pointer
+	pthread_mutex_lock(&info.lock_raw);
+	info.new_frame = false;
 	raw_tmp = info.raw_next;
 	info.raw_next = info.raw_current;
 	info.raw_current = raw_tmp;
@@ -525,7 +529,7 @@ int main(int argc, char* argv[]) {
 		pthread_mutex_lock(&calcinfo.lock_raw);
 		ti.lockns=timestamp();
 		*calcinfo.raw_next = raw.clone();
-		pthread_cond_signal(&calcinfo.condition_new_frame);
+		calcinfo.new_frame = true;
 		pthread_mutex_unlock(&calcinfo.lock_raw);
 		ti.copyns=timestamp();